Research And Implementation Of Distributed Complex Event Processing Method For Internet Of Things

The research and application of Internet of Things technology have brought huge productive forces and productivity improvement to the relevant industries.Internet of things middleware is an important part of the Internet of Things technology.It is the middle layer of the hardware equipment and the upper application system,which can connect the data of the underlying equipment affording the data filtering and cleaning,the format conversion and the data transmission,and provide the corresponding service for the upper application.However the Internet of things can not process real-time data.Complex event processing technology uses event description language to describe the business logic in the application of Internet of things.Based on event pattern detection,event abstraction,event aggregation and conversion technology,it can complete the calculation process in memory and realize the objective of real-time event processing.When faced with the growing data in the Internet of Things,complex event processing technology can deal with these massive real-time data streams in real time and efficiently,and realize the high throughput and low latency of the Internet of Things system.In this paper,the author works on the distributed complex event processing method and realizes a integrated system about the Internet of things and distributed Complex Event Processing based on the research of the Internet of Things in our lab and combined with distributed computing technology,complex event processing technology and related open source components.The main work is as follows:1)It works on the technology of Internet of Things middleware and complex event processing,and puts forward a method of integrating based on them in distributed environment.2)It implements a complex event processing system to subscribe and encapsulate the event flow from the middleware based on the distributed publish / subscribe model.3)It proposes and implements a dynamical rule management method,which can add,delete and modify EPL rules in the system dynamically,and also load it dynamically into complex event processing engine.4)It proposes and implements a multi-data source loading method in a complex event processing system,which can switch the read data source dynamically during the operation of complex event processing engine.5)It extends the state control method of the Esper engine,designs and implements the monitoring and control methods of the Esper engine.Finally,this paper carries on the function test and the performance test to the system,including the different kinds of important functions test and event processing performance test.The result indicated that this system satisfies the established goal basically.