一种发布订阅系统及其通知消息处理方法

摘要

本发明公开了一种通知消息处理方法，包括：通知代理通过内部发布者在订阅实体的负荷未超出设定阈值时转发通知消息至订阅实体，订阅实体通过推理实体将满足过滤条件的通知消息发送至与订阅实体关联的推送端点，推送端点转发通知消息至与推送端点关联的消息接收实体，并通过消息接收实体将通知消息发送至订阅者。本发明同时还公开了一种应用通知消息处理方法的发布订阅系统，使用本发明的技术方案，能够主动发送通知消息至订阅者，平衡发布订阅系统负荷，进一步的，还提高了发布/订阅系统的处理效率。

主权项

一种发布订阅系统，其特征在于，所述发布订阅系统包括订阅者、通知代理、发布者、内部发布者、与所述内部发布者对应的订阅实体、由所述订阅者建立的与所述订阅者对应的消息接收实体、由所述通知代理建立的推送端点、以及由所述订阅实体建立的推理实体；其中，所述通知代理，用于接收所述发布者发送的通知消息并转发至所述内部发布者；所述内部发布者，用于确定所述订阅实体的当前负荷未超过设定阈值时，将所述通知消息通过所述订阅实体转发至所述推理实体；所述推理实体，用于确定通知消息满足所述推理实体的初始化过滤条件时，发送通知消息至与所述订阅实体关联的推送端点；所述推送端点，用于转发通知消息至与所述推送端点关联的消息接收实体；所述消息接收实体，用于将接收的通知消息发送至所述订阅者；所述通知代理还用于在接收到所述订阅者发送的订阅请求时，建立订阅实体，以所述订阅请求携带的订阅名、关键字和过滤条件初始化建立的订阅实体，并将所述订阅请求携带的推送端点地址在订阅实体注册，关联所述推送端点和所述订阅实体；接收订阅实体返回的订阅地址，保存所述订阅实体初始化订阅名和订阅实体地址的映射关系；所述通知代理，还用于接收到所述订阅者建立推送端点的请求消息时，建立所述推送端点；将所述请求消息携带的消息接收实体地址在推送端点进行注册，关联所述消息接收实体和所述推送端点，并在接收所述推送端点返回的推送端点地址时，转发至所述订阅者；所述通知代理，还用于接收所述发布者发送的通知消息后，根据订阅关系描述，确定携带关键字与所述通知消息携带的关键字匹配的订阅请求和/或从属订阅请求，并按语义优先级对匹配的订阅请求和/或从属订阅请求进行排序，按照所述排序将所述通知消息发送至根据匹配的订阅请求和/或从属订阅请求建立的订阅实体对应的内部发布者。