| With the development of the Internet of Things technology,the era of the Internet of Everything is getting closer and closer to us.A variety of sensing devices combined with IoT applications have brought convenience to people's lives and greatly improved social production efficiency.However,in general,these applications are independent of each other,and information cannot be fully utilized to form an information island.However,in the era of Internet of Everything,a wider range of interconnection and intercommunication is required,and in many scenarios,multisensor data and real-time interaction are required to complete,so it is necessary to realize real-time sharing of sensor information.For the current application in the Internet of Things,if a third party wants to obtain sensor information of an application,it generally passes through the application's website or the open data resource service of the application.However,in the IoT scenario where the real-time requirements are relatively high,the requirements are often not met.IoT information is not only real-time,but also because of the heterogeneity of sensor information in the Internet of Things from different sensors and different protocols.And with the development of the Internet of Things,there are more and more IoT devices,resulting in a huge amount of IoT information.Therefore,based on the current imperfection of sensor information in real-time sharing of IoT applications,combined with the massive,heterogeneous and real-time characteristics of sensor information in the Internet of Things,a real-time sensor middleware solution is proposed.Firstly,based on relevant industry standards,mass sensors are classified based on metadata,making the sensor easy to find and locate.Then use Netty,a high-performance communication framework to build a data communication service to collect sensor information in real time.Then,Netty is used to construct a message push service combined with a message queue to realize real-time sharing of sensor information based on the subscription/release mode.Finally,the cache is used to optimize the storage model and the ELK architecture monitors and warns the entire middleware to improve the real-time sharing efficiency and reliability of sensor information.Finally,the SpringBoot build example is used to test the function and performance of the sensor information real-time sharing middleware,and the experimental results are in line with expectations. |