一种实现分布式消息处理的系统及方法

摘要

本发明公开了一种实现分布式消息处理的系统及方法，用于提高消息处理系统的通用性及灵活性，该系统包括：表达式模块中包括有规则项、函数、运算符、表达式、宏变量及触发器；设置模块，用于接收用户利用表达式模块建立的消息处理逻辑表达式，并将消息处理逻辑表达式发送给同步模块；消息处理逻辑表达式由规则项、函数、运算符、表达式、宏变量中的一种或多种组成；同步模块，用于将消息处理逻辑表达式实时发送给消息处理模块；消息处理模块，用于根据消息处理逻辑表达式，更新自身保存的消息处理逻辑表达式；接收所需处理的消息，读取最新的消息处理逻辑表达式，按照最新的消息处理逻辑表达式对应的消息处理逻辑对所需处理的消息进行处理。

主权项

一种实现分布式消息处理的系统，其特征在于，所述系统包括：表达式模块、设置模块、同步模块以及至少一个消息处理模块；所述表达式模块中包括有规则项、函数、运算符、表达式、宏变量以及触发器；所述触发器用于当所需处理的消息满足消息处理逻辑表达式时触发对应的处理操作；所述设置模块，用于接收用户利用所述表达式模块建立的消息处理逻辑表达式，并将所述消息处理逻辑表达式发送给同步模块；所述消息处理逻辑表达式由所述规则项、所述函数、所述运算符、所述表达式、所述宏变量中的一种或多种组成；所述同步模块，用于将接收到的所述消息处理逻辑表达式实时发送给所述消息处理模块；消息处理模块，用于根据所述同步模块实时发送的消息处理逻辑表达式，更新自身保存的消息处理逻辑表达式；接收所需处理的消息，读取最新的消息处理逻辑表达式，按照所述最新的消息处理逻辑表达式对应的消息处理逻辑对所述所需处理的消息进行处理。