[發明專利]一種信息發布訂閱平臺及方法和信息發布訂閱系統

有效

• 申請號: 201610024444.8
• 申請日: 2016-01-14
• 公開（公告）號: CN105610959B
• 公開（公告）日: 2019-02-19
• 發明（設計）人: 張權;劉鵬;趙俊海;張云峰
• 申請（專利權）人: 中電長城網際系統應用有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京天昊聯合知識產權代理有限公司 11112
• 代理人: 羅瑞芝;易衛

本發明提供一種信息發布訂閱平臺及方法和信息發布訂閱系統。該信息發布訂閱平臺包括信息訂閱單元和信息發布單元，信息訂閱單元用于接受下級平臺的信息訂閱，還用于向上級平臺訂閱信息；信息發布單元用于向下級平臺發布信息，還用于接收上級平臺發布的信息；信息訂閱單元與信息發布單元連接，且信息訂閱單元與信息發布單元之間能進行信息傳遞。該信息發布訂閱平臺實現了信息在相互之間具有發布訂閱關系的兩級平臺之間的直接傳輸，從而實現了信息發布訂閱的多級嵌套模式，進而提高了信息的發布訂閱效率，繼而提高了信息的傳輸效率。該信息發布訂閱平臺無需額外編程即可實現信息發布訂閱的多級嵌套，從而節約了該信息發布訂閱平臺的軟件成本。

技術領域

本發明涉及網絡信息傳輸技術領域，具體地，涉及一種信息發布訂閱平臺及方法和信息發布訂閱系統。

背景技術

目前，在網絡信息傳輸領域，通常通過發布訂閱機制進行網絡信息的傳輸，如通過發布訂閱機制在多級信息傳輸平臺之間進行基于各種主題的信息傳輸。

Kafka是一種分布式發布訂閱消息系統。Kafka提供了一種通用的發布訂閱服務，如圖1所示。其具體工作流程如下：

1.當訂閱平臺8或訂閱終端啟動訂閱時，向Kafka信息平臺9去訂閱基于某個主題的信息；

2.當發布平臺10有了基于某個主題的更新信息之后，向Kafka信息平臺9進行發布；發布平臺10為一個或多個；

3.然后，Kafka信息平臺9再將更新信息分發給一個或多個訂閱平臺8或訂閱終端。

Kafka所提供的發布訂閱服務存在以下不足：1)kafka僅是基本的發布訂閱，不支持多級嵌套的發布訂閱；即所有的訂閱平臺或訂閱終端都只能直接向Kafka信息平臺訂閱信息，所有的發布平臺也都只能向Kafka信息平臺發布信息，然后由Kafka信息平臺將信息發布給各個訂閱平臺或訂閱終端。要實現多級嵌套的發布訂閱，需要在kafka系統中編寫專門的程序來支持這一點。2)Kafka不支持基于版本的發布訂閱，即kafka可以將基于特定主題的信息更新發布給一個或多個訂閱平臺或訂閱終端，但是由于它只保留特定天數的數據信息，當一個新的訂閱平臺或訂閱終端接入的時候，可能其需要的數據信息已經被kafka刪掉。因為Kafka不支持基于版本的發布訂閱，所以無法保證新接入的訂閱平臺或訂閱終端獲取到完整的信息。

發明內容

本發明針對現有技術中存在的上述技術問題，提供一種信息發布訂閱平臺及方法和信息發布訂閱系統。該信息發布訂閱平臺實現了信息在相互之間具有發布訂閱關系的兩級平臺之間的直接傳輸，從而實現了信息發布訂閱的多級嵌套模式，進而提高了信息的發布訂閱效率，繼而提高了信息的傳輸效率。

本發明提供一種信息發布訂閱平臺，包括信息訂閱單元和信息發布單元，所述信息訂閱單元用于接受下級平臺的信息訂閱，還用于向上級平臺訂閱信息；

所述信息發布單元用于向所述下級平臺發布信息，還用于接收所述上級平臺發布的信息；

所述信息訂閱單元與所述信息發布單元連接，且所述信息訂閱單元與所述信息發布單元之間能進行信息傳遞。

優選地，還包括存儲單元，所述存儲單元與所述信息訂閱單元和所述信息發布單元連接，用于存儲所述下級平臺訂閱的信息和所述上級平臺發布的信息；

所述下級平臺訂閱的信息和所述上級平臺發布的信息均為帶有版本的主題信息。

優選地，所述信息訂閱單元包括訂閱模塊，用于接受所述下級平臺的信息訂閱，還用于向所述上級平臺訂閱信息；

所述信息發布單元包括發布模塊，用于向所述下級平臺發布信息，還用于接收所述上級平臺發布的信息；

所述訂閱模塊和所述發布模塊連接，所述訂閱模塊還用于將向所述上級平臺訂閱的信息發送給所述發布模塊。