[發明專利]一種基于大數據的消息訂閱方法和裝置

在審

• 申請號: 202110058535.4
• 申請日: 2021-01-16
• 公開（公告）號: CN112732463A
• 公開（公告）日: 2021-04-30
• 發明（設計）人: 劉錚;展影影
• 申請（專利權）人: 劉錚
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/50
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種基于大數據的消息訂閱方法，其特征在于，包括如下步驟：

獲取消息訂閱端發送的消息訂閱請求，所述消息訂閱請求包括消息訂閱端信息以及要求訂閱的消息的消息名稱信息；

對所述消息訂閱端信息進行驗證，以獲取所述消息訂閱端是否是有效消息訂閱端的驗證結果；

若所述驗證結果為所述消息訂閱端是有效消息訂閱端，則根據所述消息名稱信息，獲取與所述要求訂閱的消息相對應的消息中間件集合，所述消息中間件集合包括至少兩個消息中間件；

根據所述消息中間件集合，獲取所述消息中間件集合中符合預設條件的消息中間件；

根據獲取到的消息中間件，與所述消息訂閱端進行消息訂閱。

2.根據權利要求1所述的基于大數據的消息訂閱方法，其特征在于，所述消息訂閱端信息為所述消息訂閱端的IP地址；

所述對所述消息訂閱端信息進行驗證，以獲取所述消息訂閱端是否是有效消息訂閱端的驗證結果具體為：

將所述消息訂閱端的IP地址輸入至預設的有效IP地址數據庫中，若所述消息訂閱端的IP地址屬于所述有效IP地址數據庫中的其中一個有效IP地址，則所述驗證結果為所述消息訂閱端是有效消息訂閱端；若所述消息訂閱端的IP地址不屬于所述有效IP地址數據庫中的任意一個有效IP地址，則所述驗證結果為所述消息訂閱端不是有效消息訂閱端；其中，所述有效IP地址數據庫包括至少兩個有效IP地址。

3.根據權利要求1所述的基于大數據的消息訂閱方法，其特征在于，根據所述消息名稱信息，獲取與所述要求訂閱的消息相對應的消息中間件集合具體為：

根據所述消息名稱信息，以及預設的消息名稱與消息屬性的對應關系，獲取與所述消息名稱信息相對應的消息屬性；

根據得到的消息屬性，獲取與所述得到的消息屬性相對應的消息中間件集合。

4.根據權利要求1所述的基于大數據的消息訂閱方法，其特征在于，所述根據所述消息中間件集合，獲取所述消息中間件集合中符合預設條件的消息中間件具體為：

根據所述消息中間件集合，獲取所述消息中間件集合中負載滿足預設條件的消息中間件。

5.根據權利要求4所述的基于大數據的消息訂閱方法，其特征在于，所述根據所述消息中間件集合，獲取所述消息中間件集合中負載滿足預設條件的消息中間件具體為：

根據所述消息中間件集合，獲取所述消息中間件集合中各消息中間件的地址信息；

根據各消息中間件的地址信息，建立各消息中間件與所述消息訂閱端的通信連接；

計算各消息中間件的負載，獲取各負載中符合第一預設條件的負載，并獲取與符合所述第一預設條件的負載相對應的消息中間件。

6.根據權利要求5所述的基于大數據的消息訂閱方法，其特征在于，所述基于大數據的消息訂閱方法還包括如下步驟：

若檢測到所述獲取到的消息中間件存在異常，則根據獲取到的所述消息中間件集合中除所述獲取到的消息中間件之外的各其他消息中間件；

獲取所述各其他消息中間件的地址信息；

根據所述各其他消息中間件的地址信息，建立所述各其他消息中間件與所述消息訂閱端的通信連接；

計算所述各其他消息中間件的負載，獲取所述各其他消息中間件的負載中符合第二預設條件的負載，并獲取與符合所述第二預設條件的負載相對應的其他消息中間件；

根據獲取到的其他消息中間件，與所述消息訂閱端繼續進行消息訂閱。

7.一種基于大數據的消息訂閱裝置，包括存儲器、處理器以及存儲在所述存儲器中并可在所述處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1-6任一項所述的基于大數據的消息訂閱方法的步驟。