[發(fā)明專利]基于zookeeper的消息服務(wù)接入方法和設(shè)備

在審

• 申請?zhí)枺?/td>: 202010696833.1
• 申請日: 2020-07-20
• 公開（公告）號: CN111884844A
• 公開（公告）日: 2020-11-03
• 發(fā)明（設(shè)計）人: 任賀;張強(qiáng);雷鳴;邱城曉;李力;楊東平;劉愛輝;李曉棟;孫代勇;申延云
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司;建信金融科技有限責(zé)任公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08
• 代理公司: 北京三友知識產(chǎn)權(quán)代理有限公司 11127
• 代理人: 孫乳筍;周永君

本發(fā)明提供一種基于zookeeper的消息服務(wù)接入方法和設(shè)備，該方法包括：獲取服務(wù)端發(fā)送的配置信息變更消息；根據(jù)該配置信息變更消息更新本地配置信息；將更新后的配置信息發(fā)送至注冊了對應(yīng)watcher監(jiān)聽的客戶端，通過利用zookeeper的watcher監(jiān)聽機(jī)制，在配置信息更新后，及時將更新后的配置信息發(fā)送至注冊了對應(yīng)watcher監(jiān)聽的客戶端，防止服務(wù)異常。

技術(shù)領(lǐng)域

本發(fā)明涉及計算機(jī)技術(shù)領(lǐng)域，尤其涉及一種基于zookeeper的消息服務(wù)接入方法和設(shè)備。

背景技術(shù)

在企業(yè)級的消息平臺中，除了可以支撐大量的消息傳輸功能外，方便應(yīng)用接入和方便服務(wù)端的管理成為一個重要需求。

在企業(yè)級的消息平臺中，有很多應(yīng)用需要通過消息客戶端接入消息平臺，如何組織和管理這些客戶端以及參數(shù)配置，是解決大規(guī)模擴(kuò)展消息平臺的關(guān)鍵技術(shù)。

目前，基于注冊中心管理各個客戶端的配置參數(shù)，服務(wù)端為每個客戶端分配消息服務(wù)碼，并將每個客戶端連接使用的隊列名等配置參數(shù)加載至注冊中心，服務(wù)地址也是靜態(tài)寫到注冊中心。客戶端在接入消息平臺時，先使用消息服務(wù)碼連接注冊到注冊中心獲取配置信息，再依據(jù)配置信息建立到消息平臺的連接。

但是，配置信息是靜態(tài)寫到注冊中心的，配置信息變更后或者服務(wù)端擴(kuò)容時，無法及時更新到客戶端，導(dǎo)致服務(wù)異常。

發(fā)明內(nèi)容

針對現(xiàn)有技術(shù)中的問題，本發(fā)明提供一種基于zookeeper的消息服務(wù)接入方法和設(shè)備，能夠至少部分地解決現(xiàn)有技術(shù)中存在的問題。

為了實現(xiàn)上述目的，本發(fā)明采用如下技術(shù)方案：

第一方面，提供一種基于zookeeper的消息服務(wù)接入方法，包括：

獲取服務(wù)端發(fā)送的配置信息變更消息；

根據(jù)該配置信息變更消息更新本地配置信息；

將更新后的配置信息發(fā)送至注冊了對應(yīng)watcher監(jiān)聽的客戶端。

進(jìn)一步地，基于zookeeper的消息服務(wù)接入方法還包括：

獲取該客戶端發(fā)送的消息服務(wù)碼；

將與該消息服務(wù)碼對應(yīng)的配置信息發(fā)送至該客戶端。

進(jìn)一步地，基于zookeeper的消息服務(wù)接入方法還包括：

向該服務(wù)端發(fā)送探測消息；

若預(yù)設(shè)時間內(nèi)未接收到該服務(wù)端反饋的消息，則注銷該服務(wù)端。

第二方面，提供一種zookeeper設(shè)備，包括：

變更消息獲取模塊，獲取服務(wù)端發(fā)送的配置信息變更消息；

信息更新模塊，根據(jù)該配置信息變更消息更新本地配置信息；

信息發(fā)送模塊，將更新后的配置信息發(fā)送至注冊了對應(yīng)watcher監(jiān)聽的客戶端。

進(jìn)一步地，zookeeper設(shè)備還包括：

消息服務(wù)碼獲取模塊，獲取該客戶端發(fā)送的消息服務(wù)碼；

配置信息發(fā)送模塊，將與該消息服務(wù)碼對應(yīng)的配置信息發(fā)送至該客戶端。

進(jìn)一步地，zookeeper設(shè)備還包括：

探測模塊，向該服務(wù)端發(fā)送探測消息；

服務(wù)端注銷模塊，若預(yù)設(shè)時間內(nèi)未接收到該服務(wù)端反饋的消息，則注銷該服務(wù)端。

第三方面，提供一種基于zookeeper的消息服務(wù)接入方法，包括：