[發明專利]一種基于簡單二進制編碼的消息中間件系統和方法

有效

• 申請號: 201711268860.3
• 申請日: 2017-12-05
• 公開（公告）號: CN108306852B
• 公開（公告）日: 2020-12-04
• 發明（設計）人: 張飛;余峰;張備戰;張海榮
• 申請（專利權）人: 上海金融期貨信息技術有限公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L12/801;G06F9/54;G06Q40/04
• 代理公司: 上海專利商標事務所有限公司 31100
• 代理人: 施浩

1.一種基于簡單二進制編碼的消息中間件系統，其特征在于，包括發布端系統和訂閱端系統，其中：

發布端系統包括：

應用層數據編碼單元，對業務數據進行簡單二進制編碼處理，轉換成對應的應用層數據域；

發布端業務處理單元，將一個或多個相同類型的應用層數據域進行統一打包封裝，根據業務類型在數據包前通過簡單二進制編碼添加業務層協議頭以生成數據包；

發布端主題分發單元，根據從上層接收到的數據包中的主題字段，將該數據包追加到一個或多個主題流中；

發布端發布訂閱控制協議單元，管理主題消息的發布，通過發布訂閱管理協議處理訂閱申請信息和取消申請信息，通過和訂閱端發布訂閱控制協議單元的交互來檢測各個訂閱者的生命周期以完成對訂閱者列表的動態維護；

發布端網絡層協議單元；

訂閱端系統包括：

訂閱端網絡層協議單元；

訂閱端發布訂閱控制協議單元，和發布端發布訂閱控制協議單元進行交互以檢測各個訂閱者的生命周期，其中發布端發布訂閱控制協議單元和訂閱端發布訂閱控制協議單元通過心跳控制協議維護發布者與訂閱者之間的鏈接信息，通過訂閱者周期性的向發布端發送心跳信息，實現發布端對各訂閱者的生命周期的動態監測；

訂閱端主題分發單元，根據下層傳遞來的數據包中的主題字段，將數據包路由到不同的訂閱端業務處理單元；

訂閱端業務處理單元，接收數據包并完成對其中各應用層數據域的解析。

2.根據權利要求1所述的基于簡單二進制編碼的消息中間件系統，其特征在于，發布端業務處理單元生成的數據包的結構由業務層協議頭和各個應用層數據域組成，其中業務層協議頭包括數據包類型字段、業務類型字段、數據包長度字段、主題字段。

3.根據權利要求1所述的基于簡單二進制編碼的消息中間件系統，其特征在于，發布端發布訂閱控制協議單元和訂閱端發布訂閱控制協議單元具備重傳機制。

4.根據權利要求1所述的基于簡單二進制編碼的消息中間件系統，其特征在于，發布端發布訂閱控制協議單元和訂閱端發布訂閱控制協議單元具備流速控制機制。

5.一種基于簡單二進制編碼的消息中間件方法，其特征在于，包括發布端的發布流程和訂閱端的訂閱流程；

發布端的發布流程包括：

發布端的應用層對業務數據進行簡單二進制編碼處理，其中每個不同類型的業務數據轉換成對應的應用層數據域；

發布端的業務處理單元在接收到應用層的數據后，將一個或多個相同類型的應用層數據域進行統一打包封裝，根據業務類型在數據包前通過簡單二進制編碼添加業務層協議頭以生成數據包；

發布端的主題分發單元根據從業務處理單元接收到的數據包中的主題字段，將該數據包追加到內存中維護著的對應的一個或多個主題流中；以及

發布端的數據發布線程在本地維護一個訂閱列表，當訂閱列表為空時數據發布線程處于休眠狀態，當接收到某個訂閱者的訂閱請求時數據發布線程被激活并進行數據發布；

訂閱端的訂閱流程包括：

訂閱端的訂閱線程維護一個或多個訂閱流，不同的訂閱流對應不同的訂閱主題，訂閱線程從網絡上接收指定主題的數據包，然后存入相對應的訂閱流中；

訂閱端檢測自己所感興趣的訂閱流中是否有數據更新，當發現有數據更新時從訂閱流中讀取數據包并將其交給訂閱端的主題分發單元，其中在發布端與訂閱端均設置發布訂閱控制協議，發布訂閱控制協議進一步包括心跳控制協議和發布訂閱管理協議，其中心跳控制協議用于對訂閱列表中的訂閱者進行心跳檢測，發布訂閱管理協議用于維護訂閱者列表；

訂閱端的主題分發單元在收到數據包后根據業務類型將數據包傳遞給對應的業務處理單元；以及

訂閱端的業務處理單元完成對不同業務數據類型的解析與響應。

6.根據權利要求5所述的基于簡單二進制編碼的消息中間件方法，其特征在于，發布端的業務處理單元生成的數據包的結構由業務層協議頭和各個應用層數據域組成，其中業務層協議頭包括數據包類型字段、業務類型字段、數據包長度字段、主題字段。