[發(fā)明專利]基于RabbitMQ的分布式消息發(fā)布系統(tǒng)

在審

• 申請?zhí)枺?/td>: 201810041672.5
• 申請日: 2018-01-16
• 公開（公告）號: CN108199896A
• 公開（公告）日: 2018-06-22
• 發(fā)明（設(shè)計(jì)）人: 王劍冰;劉波;肖憶南
• 申請（專利權(quán)）人: 中電福富信息科技有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08
• 代理公司: 福州君誠知識產(chǎn)權(quán)代理有限公司 35211
• 代理人: 彭東

1.基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：其包括管理平臺模塊、數(shù)據(jù)節(jié)點(diǎn)模塊和客戶端模塊；

管理平臺模塊包括平臺前端和平臺后臺程序集群，平臺前端連接平臺后臺程序集群，平臺后臺程序集群通過內(nèi)置事件總線維持元數(shù)據(jù)的一致；

平臺后臺程序集群與數(shù)據(jù)節(jié)點(diǎn)和客戶端通訊連接，客戶端連接數(shù)據(jù)節(jié)點(diǎn)；

數(shù)據(jù)節(jié)點(diǎn)具有多個(gè)分組，每個(gè)分組包括多個(gè)VBroker，每個(gè)VBroker包括一個(gè)Broker或者一對Broker鏡像；

管理平臺模塊集成數(shù)據(jù)節(jié)點(diǎn)的自動(dòng)部署、隊(duì)列/廣播的維護(hù)以及數(shù)據(jù)節(jié)點(diǎn)的狀態(tài)監(jiān)控；

客戶端模塊通過管理平臺模塊獲取數(shù)據(jù)節(jié)點(diǎn)集群的配置信息，并將請求均勻發(fā)至數(shù)據(jù)節(jié)點(diǎn)，數(shù)據(jù)節(jié)點(diǎn)用于消息的收發(fā)處理。

2.根據(jù)權(quán)利要求1所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述管理平臺模塊的自動(dòng)部署具體為在平臺前端一鍵完成Erlang環(huán)境、配置文件修改及RabbitMQ部署的操作。

3.根據(jù)權(quán)利要求1所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述管理平臺模塊的隊(duì)列/廣播的維護(hù)功能提供三種方式的廣播：匿名方式、持久化方式和擴(kuò)展通配方式。

4.根據(jù)權(quán)利要求1所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述管理平臺模塊的隊(duì)列/廣播的維護(hù)功能在廣播前將一個(gè)消費(fèi)ID綁定到TOPIC上并由后臺程序創(chuàng)建一用于消息收發(fā)的物理隊(duì)列。

5.根據(jù)權(quán)利要求1所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述管理平臺模塊對數(shù)據(jù)節(jié)點(diǎn)的狀態(tài)監(jiān)控具體為管理平臺模塊定期采集數(shù)據(jù)節(jié)點(diǎn)的運(yùn)行狀態(tài)，并在出現(xiàn)異常情況時(shí)發(fā)出告警，如有數(shù)據(jù)節(jié)點(diǎn)異常關(guān)閉則自動(dòng)拉起。

6.根據(jù)權(quán)利要求1所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述客戶端模塊內(nèi)置路由策略，客戶端模塊通過路由策略將消息均勻地分發(fā)到分組內(nèi)的各個(gè)數(shù)據(jù)節(jié)點(diǎn)上。

7.根據(jù)權(quán)利要求1或3所述的基于RabbitMQ的分布式消息發(fā)布系統(tǒng)，其特征在于：所述客戶端模塊內(nèi)置故障數(shù)據(jù)節(jié)點(diǎn)的隔離和重試功能。