The Design And Implementation Of Complex Event Processing Engine Based On Distributed Event Communication

With the advent of era of big data in Internet of Things (IoT), people have a urgent demand to real-time complex event processing (CEP), and pay more and more attention to complex event processing (CEP). However, traditional complex event processing based on centralized structure, which exists disadvantages, such as higher latency, lower concurrency and irreversible failure of single node and so on. These disadvantages are caused by network congestion and instability factors of network. Whereas, it is necessary to provide a new complex event processing engine based on distributed event communication system.New complex event processing engine based on distributed event communication system, depending on device layer and application layer, develops a distributed real-time complex event processing mechanism and virtual data services platform.Complex event processing engine based on distributed event communication system, is composed of four main modules, which are distributed event communication system, structured name system, Data source module of complex event and complex event listener. It is high-concurrency, low latency and real-time big data processing. On the other hand, the issues also describe two core algorithms about data source real-time connection and event listening.Finally, we conduct functional testing and performance testing. As for functional testing, we conduct functional verification on simulate environment, which contains simple events and complex events. The test methods are proved to be feasible by the test results. On the other hand, compared traditional centralized complex event processing to new complex event processing engine based on distributed event communication system, we perform the throughput test and latency test, as to, a performance analysis and real-time monitoring test. Experimental results show that new complex event processing engine has higher throughput and lower latency than other CEP engines.