A data transmission method and system based on project Reactor framework

Abstract

The invention provides a data transmission method and system based on the Project Reactor framework, including: the device side obtains the data detected by the sensor in real time, and sends the data detected by the sensor in real time to the data acquisition engine of the cloud platform; the data of the device side and the cloud platform The MQTT protocol is used for communication between the acquisition engines; the data acquisition engine of the cloud platform is constructed using the Project Reactor framework; the data acquisition engine of the cloud platform uses Reactive Spring Cloud Stream to construct a responsive message communication component, and sends the data detected by the sensor in real time to the Kafka message The middleware forwards the real-time detection data of the sensors in the Kafka message middleware to the big data platform or database; the data collection engine of the cloud platform uses Spring Reactive Data to build a responsive data access component, and forwards the real-time detection data of the sensors in the Kafka message middleware to the big data platform or database. MongoDB. The present invention is more efficient in the transmission of data.

Description

technical field [0001] The invention belongs to the technical field of data acquisition, and more particularly, relates to a data transmission method and system based on a Project Reactor framework. Background technique [0002] Chinese invention application CN201210228761.3 discloses a simple and efficient socket communication framework based on nio. It adopts an architecture mode in which the TCP connection establishment part and the IO read and write processing part are separated. In the IO read and write part, a message buffer queue is designed to improve the efficiency of read and write. But using the nio programming interface is cumbersome. [0003] Chinese invention application CN201610993370.9 discloses a large-scale concurrent data forwarding method based on Netty, including the construction of a data receiver and a transponder. The data receiver is mainly responsible for receiving data information from a remote host, and the data transponder is mainly responsible...

AI Technical Summary

Problems solved by technology

[0004] Aiming at the defects of the prior art, the object of the present invention is to provide a data transmission method and system based on the Project Reactor framework, aiming to solve the problem that the existing data transmission method uses NIO programming or the Netty framework interface is relatively cumbersome and the network communication capability is poor

Images