-
公开(公告)号:CN103037000B
公开(公告)日:2015-07-08
申请号:CN201210562319.4
申请日:2012-12-21
Applicant: 北京邮电大学
Abstract: 本发明公开了一种通知消息处理方法,包括:通知代理通过内部发布者在订阅实体的负荷未超出设定阈值时转发通知消息至订阅实体,订阅实体通过推理实体将满足过滤条件的通知消息发送至与订阅实体关联的推送端点,推送端点转发通知消息至与推送端点关联的消息接收实体,并通过消息接收实体将通知消息发送至订阅者。本发明同时还公开了一种应用通知消息处理方法的发布订阅系统,使用本发明的技术方案,能够主动发送通知消息至订阅者,平衡发布订阅系统负荷,进一步的,还提高了发布/订阅系统的处理效率。
-
公开(公告)号:CN103037000A
公开(公告)日:2013-04-10
申请号:CN201210562319.4
申请日:2012-12-21
Applicant: 北京邮电大学
Abstract: 本发明公开了一种通知消息处理方法,包括:通知代理通过内部发布者在订阅实体的负荷未超出设定阈值时转发通知消息至订阅实体,订阅实体通过推理实体将满足过滤条件的通知消息发送至与订阅实体关联的推送端点,推送端点转发通知消息至与推送端点关联的消息接收实体,并通过消息接收实体将通知消息发送至订阅者。本发明同时还公开了一种应用通知消息处理方法的发布订阅系统,使用本发明的技术方案,能够主动发送通知消息至订阅者,平衡发布订阅系统负荷,进一步的,还提高了发布/订阅系统的处理效率。
-
公开(公告)号:CN102355413A
公开(公告)日:2012-02-15
申请号:CN201110248653.8
申请日:2011-08-26
Applicant: 北京邮电大学
Abstract: 本发明公开了一种大规模实时统一消息空间的方法及其系统,该系统基于集群技术,具有自配置能力和负载均衡的发布/订阅功能,该系统建立在以集群为单位的系统架构上,集群架构将参与发布/订阅的代理主机划分在一个个集群之中,集群之间组织成树的形式进行管理,并通过集群的代表进行交互。系统包括客户端、路由模块、数据模块和管理者模块。其中路由模块负责管理路由信息,维护订阅表;数据模块负责接收来自客户端的订阅和通知,并进行消息的发送和接收;管理者模块负责维护由集群形成的树状拓扑。利用本发明能够实现订阅和通知的高效路由,具有配置简单、可扩展性强以及负载均衡等优点。
-
公开(公告)号:CN102355413B
公开(公告)日:2015-08-19
申请号:CN201110248653.8
申请日:2011-08-26
Applicant: 北京邮电大学
Abstract: 本发明公开了一种大规模实时统一消息空间的方法及其系统,该系统基于集群技术,具有自配置能力和负载均衡的发布/订阅功能,该系统建立在以集群为单位的系统架构上,集群架构将参与发布/订阅的代理主机划分在一个个集群之中,集群之间组织成树的形式进行管理,并通过集群的代表进行交互。系统包括客户端、路由模块、数据模块和管理者模块。其中路由模块负责管理路由信息,维护订阅表;数据模块负责接收来自客户端的订阅和通知,并进行消息的发送和接收;管理者模块负责维护由集群形成的树状拓扑。利用本发明能够实现订阅和通知的高效路由,具有配置简单、可扩展性强以及负载均衡等优点。
-
-
-