[發明專利]一種消息處理方法和設備

有效

• 申請號: 201510728149.6
• 申請日: 2015-10-30
• 公開（公告）號: CN106648444B
• 公開（公告）日: 2019-06-28
• 發明（設計）人: 李斌;師敏華
• 申請（專利權）人: 大唐移動通信設備有限公司
• 主分類號: G06F3/06
• 分類號: G06F3/06
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 王瑩

本發明公開了一種消息處理方法和設備，該方法包括：獲取待發送的消息；對所述待發送的各消息進行可靠性評估，并根據可靠性評估結果為待發送的各消息設置標識，生成包含標識與可靠性評估結果的對應關系，以及基于所述對應關系生成資源文件；當需要發送所述消息時，基于所述資源文件與所述消息進行匹配，判斷是否需要進行持久化處理；若判斷結果為否，則對所述消息進行非持久化處理；以此根據匹配結果來執行相應的操作，實現了根據需要來確定對消息是否進行持久化的處理，優化權衡系統開銷和確保消息可靠性兩個方面，使二者達到最優配置。

技術領域

本申請實施例涉及通信技術領域，特別涉及一種消息處理方法。本申請實施例同時還涉及一種消息處理設備。

背景技術

目前消息構造方式有兩種，方式一是對消息進行持久化構造，方式二則是對消息進行非持久化構造。

其中持久化消息為可靠的傳輸模式，在提供者關閉、失敗或者異常的場景下能確保消息不會被丟棄或丟失，會緩存對應的消息；但持久化的構造方式存在資源的浪費，在某中情況下針對特定的不需要緩存或者說可容忍部分消息丟失的情況下，該種模式顯現出資源浪費，效率較低的缺陷；而非持久化構造的方式不能保證消息的可靠性，在訂閱者不活動或者異常場景下即時持有的消息會被丟棄，不能確保可靠性，但是資源占用少，效率相對高。

針對上述兩種情況，現有技術中，在對消息進行處理時，要不就是將所有消息進行持久化處理，要不就對所有消息進行非持久化處理，導致無法很好的適應需要，造成資源的浪費或者導致可靠性不足。

發明內容

針對現有技術中的缺陷，本發明提出了一種消息處理方法，用以根據可靠性要求來選擇對消息的處理方式，滿足了實際的需要，克服現有技術中的缺陷，該包括：

獲取待發送的消息；

對所述待發送的各消息進行可靠性評估，并根據可靠性評估結果為待發送的各消息設置標識，生成包含標識與可靠性評估結果的對應關系，以及基于所述對應關系生成資源文件；

當需要發送所述消息時，基于所述資源文件與所述消息進行匹配，判斷是否需要進行持久化處理；

若判斷結果為是，則對所述消息進行持久化處理；

若判斷結果為否，則對所述消息進行非持久化處理。

優選的，所述標識具體為消息識別信息；

所述根據可靠性評估結果為待發送的各消息設置標識，具體包括：

針對每個待發送的消息，重載所述消息的消息頭字段，并在所述消息中加入消息識別信息，用以標識所述消息。

優選的，所述對應關系中的可靠性評估結果是可以修改的，當對消息的可靠性評估結果變更時，對應的對應關系相應的修改為變更后的可靠性評估結果與標識的對應關系。

優選的，當發送情況異常時，判斷待發送的消息隊列中是否存在進行了持久化處理的消息；

若判斷結果為是，則將所述進行了持久化處理的消息進行緩存，以便發送情況正常時再次進行發送。

本發明還提出了一種消息處理設備，包括：

獲取模塊，用于獲取待發送的消息；

評估模塊，用于對所述待發送的各消息進行可靠性評估，并根據可靠性評估結果為待發送的各消息設置標識，生成包含標識與可靠性評估結果的對應關系，以及基于所述對應關系生成資源文件；

判斷模塊，用于當需要發送所述消息時，基于所述資源文件與所述消息進行匹配，判斷是否需要進行持久化處理；

處理模塊，用于當判斷結果為是時，對所述消息進行持久化處理；以及當判斷結果為否時，對所述消息進行非持久化處理。