The invention belongs to the technical field of
Internet of Things data access, and particularly relates to a Netty-based
mass data access method and
system in
Internet of Things application, and the method comprises the steps: after a Netty
server of an access layer node receives a terminal message, identifying the type of the message, and storing the message in a local blocking
queue through thread lock-free scheduling; the exclusive consumption thread of the blocking
queue pulls the message data from the
queue, and if the message is core data, the thread calls a load balancing module to select the message data for forwarding; otherwise, the thread sends the message data to the kafka forwarding exclusive Topic partition through the local Kafka
client; the Netty
server side of the
data analysis layer node receives or pulls the message data from the Kafka, converts the message data into structured data, and sends the structured data to the Kafka business exclusive Topic partition. According to the invention, the
advantage that Netty can undertake hundreds of thousands of terminal communication is fully exerted, and service decoupling is realized.