[發明專利]一種用于云存儲系統的消息處理方法和裝置

有效

• 申請號: 201610082605.9
• 申請日: 2016-02-05
• 公開（公告）號: CN105763608B
• 公開（公告）日: 2019-03-15
• 發明（設計）人: 侯山鵬
• 申請（專利權）人: 浪潮（北京）電子信息產業有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 羅滿

本發明提供一種用于云存儲系統的消息處理方法和裝置，其中方法包括：當接收到消息時，確定接收的消息的類型及該類型對應的消息隊列，若該消息隊列不為空，則將該接收的消息添加至該消息隊列中，若該消息隊列為空，則還將該消息隊列的實際優先級恢復默認值，當調用消息時，選取實際優先級最高的消息隊列，得到選定隊列，從該選定隊列中調用消息，當在該選定隊列中調用的消息的數目大于預設閾值時，更新該選定隊列的實際優先級，直至該選定隊列的實際優先級小于預設優先級，重新選取優先級最高的消息隊列。具有較高的消息添加效率，降低了消息隊列長度過長問題的可能，保證優先級較高的消息先被調用的同時，還可避免優先級較低的消息被積壓。

技術領域

本發明涉及信息處理技術領域，特別是涉及一種用于云存儲系統的消息處理方法和裝置。

背景技術

云存儲系統是應對大數據量高響應、吞吐量的要求而發展的。近半個世紀以來，計算機和互聯網的應用得到了普及和廣泛和發展。數據也在較大級數的增長。人們對于存儲空間的要求也越來越高。云存儲系統應用而生，并且得到了快速的發展。云存儲系統作為計算機的延生服務，通過諸多的技術將很多的服務器組織起來，協調工作，統一向外提供服務。

云存儲系統節點間、節點與管理節點、元數據結點間均通過消息來通信，目前，通常通過在各消息實體中添加優先級字段來緩解云存儲系統發送壓力過大的問題。在各消息實體中添加優先級字段后，當接收到消息時，將會將各消息按照優先級的高低順序依次進行排列在消息隊列中，將具有較高優先級的消息放在離隊列出口端較近的位置，將具有較低優先級的消息放在離隊列出口端較遠的位置，當調壓消息時，消息隊列也會對具有較高優先級的消息較先進行發送，而對優先級較低的消息較后進行發送。

由于消息隊列中的消息按照各消息的優先級進行排列，后接收的消息將根據其優先級不斷地插入到消息隊列中，因此，在當集群壓力較大時，將可能導致大量優先級較高的消息不斷插入消息隊列更靠近出口端的一方，而致使位于消息隊列后方的部分優先級較低的消息長時間不被處理的情況發生；同時，由于消息隊列中的消息按照各消息的優先級進行排列，每次接收到消息后，均需要根據其優先級和消息隊列中各消息的優先級后才可確定該消息在隊列中的位置，將消息插入消息隊列的操作較為復雜度，需要花費大量時間來計算各消息插入消息隊列的位置，影響添加消息的效率；另外，由于接收的所有消息均添加至一消息隊列中進行分發處理，也可能出現消息隊列長度過長的問題。

發明內容

有鑒于此，本發明實施例提供一種用于云存儲系統的消息處理方法和裝置，以解決現有技術中位于消息隊列后方的部分優先級較低的消息長時間不被處理，將消息插入消息隊列的操作較為復雜度，需要花費大量時間來計算各消息插入消息隊列的位置，影響添加消息的速率，另外，可能出現消息隊列長度過長的問題。

為實現上述目的，本發明實施例提供如下技術方案：

一種用于云存儲系統的消息處理方法，包括：

當接收到消息時，確定接收的消息的類型及所述類型相對應的消息隊列，其中，每個消息隊列均具有默認優先級和實際優先級，判斷所述消息隊列是否為空，若不為空，則將所述接收的消息添加至所述消息隊列中，若為空，則將該接收的消息添加至所述消息隊列中，并將所述消息隊列的默認優先級作為所述消息隊列的實際優先級；

當調用消息時，在所有消息隊列中選取實際優先級最高的消息隊列，得到選定隊列，從所述選定隊列中調用消息，當在所述選定隊列中調用的消息的數目大于預設閾值時，更新所述選定隊列的實際優先級，直至所述選定隊列的實際優先級小于預設優先級，重新在所有消息隊列中選取優先級最高的消息隊列。

其中，所述當接收到消息時，確定接收的消息的類型及所述類型相對應的消息隊列前過還包括：

確定所有可接收消息，并確定每個可接收消息的類型；

將所有可接收消息的類型進行整合，得到類型集合；