[發明專利]調度系統的消息隊列處理方法

有效

• 申請號: 201510289360.2
• 申請日: 2015-05-28
• 公開（公告）號: CN104951373B
• 公開（公告）日: 2018-11-27
• 發明（設計）人: 張鵬;魏義登;倪繼建;高創;郭順利
• 申請（專利權）人: 浙江元亨通信技術股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 浙江永鼎律師事務所 33233
• 代理人: 陸永強

本發明涉及一種調度系統的消息隊列處理方法。它解決了現有調度系統的消息處理不當等問題。包括下述步驟：接收由調度系統的接入終端發送的消息，消息均帶有第一標簽和第二標簽，其中第一標簽表征消息類型且不同的第一標簽的優先級不同，第二標簽表征該類型消息中本消息的優先級，第一標簽的優先級高于第二標簽的優先級；根據第一標簽和第二標簽將消息根據優先權依次排列從而形成消息隊列；消息處理模塊從消息隊列從中獲取消息進行處理。優點在于：多個客戶端進行自動化操作時明顯提升了系統的響應速度，減少了系統資源，大呼的情況提升了系統的穩定性，實現調度系統使用場景的即時響應。

技術領域

本發明屬于通訊技術領域，尤其是涉及一種調度系統的消息隊列處理方法。

背景技術

在調度業務系統中，消息隊列是在消息的傳輸過程中保存消息的容器，消息隊列的主要目的是提供路由并保證消息的傳遞，所有節點間通過消息進行通信，消息隊列的調度策略對整個集群的運行有至關重要的作用。傳統的調度業務系統中調度操作消息、調度響應消息和模塊響應消息根據時間先后關系加入消息隊列，消息處理模塊從消息隊列從中獲取消息進行處理，該種方式消息隊列的調度策略設計不合理，對于兩個不同處理級別但是同時發出的消息無法做到對于高優先級消息進行快速的響應，且收到一個低優先級消息，馬上收到一個高優先級消息，兩個消息是對相同的成員進行操作，現有調度系統會先處理低優先級消息，收到高優先級消息，覆蓋之前的操作，其中就存在原先的低優先級消息沒有處理的必要，且處理高優先級消息的覆蓋操作之前需要做低優先級消息的回退操作，大大增加了系統的復雜性，且消息分配到待處理消息比較多的消息處理任務中或優先級比較低的消息處理任務中，那么就可能導致及時消息堵死在待處理消息比較多的消息處理任務中或優先級較低的消息處理任務中，進而導致及時消息超時或處理不及時，及時消息得不到迅速處理，最終導致整個調度業務系統的運行效率受到影響。

為了解決現有技術存在的問題，人們進行了長期的探索，提出了各式各樣的解決方案。例如，中國專利文獻公開了一種及時消息及時處理的方法及裝置申請號：200910087065.3]，該方法包括:將待處理的消息劃分為及時消息和非及時消息,并分別將及時消息和非及時消息對應地插入到消息處理任務的消息隊列中；判斷消息處理任務中是否含有待處理的及時消息,當含有待處理的及時消息時,則提高該消息處理任務的優先級；該消息處理任務再按照提高后的優先級對待處理的及時消息進行處理。相應地,本發明提供一種及時消息及時處理的裝置,包括:消息隊列創建模塊、調度任務模塊和消息處理任務模塊。

上述方案在一定程度上解決了現有消息隊列中消息無法及時處理的問題，但是該方案依然存在著：處理過程繁瑣，響應速度低，系統資源高的問題。

發明內容

本發明的目的是針對上述問題，提供一種結構簡單合理，穩定性好的調度系統的消息隊列處理方法。

為達到上述目的，本發明采用了下列技術方案：本調度系統的消息隊列處理方法，其特征在于，本方法包括下述步驟：

A、接收消息：接收由調度系統的接入終端發送的消息，所述的消息均帶有第一標簽和第二標簽，其中第一標簽表征消息類型且不同的第一標簽的優先級不同，第二標簽表征該類型消息中本消息的優先級，所述的第一標簽的優先級高于第二標簽的優先級；

B、形成消息隊列：根據第一標簽和第二標簽將消息根據優先權依次排列從而形成消息隊列；

C、消息調用：消息處理模塊從消息隊列從中獲取消息進行處理。

本方法能實現調度系統使用場景的即時響應，對于兩個不同處理級別但是同時發出的消息能實現對于高優先級消息進行快速的響應，提升了系統的響應速度，減少了系統資源，提升了系統的穩定性。