Optimize The Filtration Performance Of Subscribe And Distribution Platform

Subscribe and distribution platform is a middleware system in which each participant of distributed system can interact by publish/subscribe approach. Platform is responsible for sending a message which meet certain conditions to the appropriate client subscriptions, message filtering can be distributed, high-performance, highly available distributed services based on the message header and message content. A critical indicator of the project is real-time (dynamic), which simultaneously connected clients as much as possible, message distribution filtration rate to as fast as possible. Although loosely coupled systems with scalability characteristics, however, to meet real-time requirements, the filter efficiency of the distribution has been the bottleneck of the system.The goal of the topics is to design and implement the filter module of system, so that it meets the following characteristics:consistent entrances message sequence (consistency); distributed messages correctly according to clients’subscriptions (correctness); concurrent processing for large quantities of message filtering and distribution (efficiency); filter and distribution process stably under high pressure conditions (stability).To achieve the above requirements, this paper studied the Drools rules engine and RETE algorithm, the algorithm used in the filtering rules to achieve high performance levels. On designing of the software, it uses a multi-level concurrency approach which greatly improves the parallel processing capability of the system. Using the above approach maximizes the CPU utilization, so that the amount of messages filtered per unit time as large as possible, and ultimately achieve the performance requirements of the system.When developing the system, Java language development environment which is called Eclipse was usd, as well as oracle database. Development process in accordance with the development of ideas and methods of software engineering, through needs analysising, designing, coding, implementation, testing stage, the final completion of the development of the module. When developing the system, Websphere MQ, spring, Netty, Drools and other frameworks were used. And in order to improve concurrency, concurrent programming java and lock-free queue technology were used.