[發明專利]基于Qconf的消息隊列高可用系統及方法

有效

• 申請號: 201710390305.1
• 申請日: 2017-05-27
• 公開（公告）號: CN107315641B
• 公開（公告）日: 2018-08-14
• 發明（設計）人: 顧偉濤
• 申請（專利權）人: 杭州銘師堂教育科技發展有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54;H04L12/803
• 代理公司: 杭州求是專利事務所有限公司 33200
• 代理人: 劉靜;邱啟旺

1.一種基于Qconf的消息隊列高可用系統，其特征在于，該系統包括應用程序端、Qconf客戶端、Qconf服務端、Qconf管理端、Qconf監控節點和消息隊列服務端：

應用程序端：運行應用程序的服務器，應用程序調用對應的Qconf擴展接口，解析傳入的參數：zk服務節點，得到消息隊列的IP和端口，然后應用程序和所述消息隊列建立連接，進而和所述消息隊列交互讀寫請求；

Qconf客戶端：包括Qconf agent服務、應用程序對應的Qconf擴展；Qconf客戶端和應用程序同機部署，用于和Qconf服務端交互，獲取最新的消息隊列zk服務節點信息；

Qconf服務端：部署zookeeper集群，存儲消息隊列zk服務節點信息；

Qconf管理端：通過調用Qconf服務端接口，對消息隊列zk服務節點進行添加、刪除、更新和獲取操作，Qconf管理端部署Qconf管理擴展，用于管理人員管理zk服務節點；

Qconf監控節點：部署Qconf監控服務，監控消息隊列zk服務節點存活，能夠實現所述消息隊列zk服務節點上下線；在一臺服務器上部署Qconf監控節點，可以監控Qconf服務端所有的消息隊列zk服務節點；

消息隊列服務端：是部署消息隊列的服務器，采用集群形式部署消息隊列，不同的消息隊列集群，采用端口號唯一標識；所有消息隊列集群的IP和端口信息，保存在消息隊列元信息中。

2.根據權利要求1所述的一種基于Qconf的消息隊列高可用系統，其特征在于，所述消息隊列服務端包括消息隊列服務管理模塊：采用一個磁盤節點和兩個內存節點形式部署消息隊列；一個消息隊列集群中所有成員的端口保持一致，不同的消息隊列集群，端口不同，采用端口唯一標識所述消息隊列集群。

3.根據權利要求1所述的一種基于Qconf的消息隊列高可用系統，其特征在于，所述Qconf管理端包括管理zk服務節點模塊，需要傳入的參數：zk服務節點、消息隊列的IP以及端口和zookeeper連接字符串；zookeeper連接字符串表示zookeeper集群所有成員的IP和端口組成的字符串；

通過掃描消息隊列元信息，獲取消息隊列IP和端口，所述端口是指zk服務節點對應的消息隊列集群的端口，每個zk服務節點表示一個消息隊列集群；所述zk服務節點的值是該端口對應的消息隊列集群所有成員的IP和端口；對zk服務節點的操作包括：調用Qconf管理端接口，進行添加zk服務節點、為zk服務節點新增值、為zk服務節點刪除值、zk服務節點上下線、獲取zk服務節點的所有成員。

4.根據權利要求1所述的一種基于Qconf的消息隊列高可用系統，其特征在于，所述Qconf客戶端包括Qconf客戶端管理模塊，需要傳入的參數：zookeeper連接字符串；按照Qconf部署要求，部署Qconf客戶端服務，Qconf客戶端配置文件需要設置zookeeper連接字符串，然后啟動Qconf客戶端服務；查看Qconf客戶端進程是否啟動；如果修改了Qconf客戶端配置文件，需要重啟Qconf客戶端服務；部署Qconf客戶端服務后，按照Qconf擴展部署要求在應用程序端部署應用程序相應的Qconf擴展。

5.根據權利要求1所述的一種基于Qconf的消息隊列高可用系統，其特征在于，所述應用程序端包括解析服務節點模塊和應用程序訪問模塊；

所述解析服務節點模塊需要傳入的參數：zk服務節點；在應用程序端部署Qconf客戶端服務后，應用程序調用相應的Qconf擴展接口解析zk服務節點，得到消息隊列集群成員；

所述應用程序訪問模塊需要傳入的參數：消息隊列的IP和端口；解析服務節點模塊執行結束后，得到某個消息隊列的IP和端口，應用程序根據所述消息隊列IP和端口，和所述消息隊列建立連接，應用程序可以發送讀寫請求，消息隊列處理這些讀寫請求。