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

有效

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

1.一種用于云存儲系統的消息處理方法，其特征在于，包括：

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

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

在所述當接收到消息時，確定接收的消息的類型及所述類型相對應的消息隊列之前，還包括：確定所有可接收消息，并確定每個可接收消息的類型；將所有可接收消息的類型進行整合，得到類型集合；對所述類型集合中每個類型均對應創建一相對應的消息隊列，并根據所述類型集合中各類型的重要程序為每個消息隊列設置一默認優先級。

2.根據權利要求1所述的消息處理方法，其特征在于，所述根據所述類型集合中各類型的重要程序為每個消息隊列設置一默認優先級后還包括：

判斷是否存在默認優先級相同的消息隊列；

若存在，則將所有默認優先級相同的消息隊列合并為一消息隊列，進行合并后得到的消息隊列的默認優先級與進行合并前各默認優先級相同的消息隊列的默認優先級相同。

3.根據權利要求1所述的消息處理方法，其特征在于，

所述將所述接收的消息添加至所述消息隊列中為：將所述接收的消息添加至所述消息隊列的隊尾；

所述從所述選定隊列中調用消息為：每次調用位于所述選定隊列隊頭的消息。

4.根據權利要求1所述的消息處理方法，其特征在于，所述在所有消息隊列中選取實際優先級最高的消息隊列，得到選定隊列包括：

確定所有消息隊列的實際優先級，并在所有消息隊列中確定實際優先級最高的消息隊列；

判斷所述實際優先級最高的消息隊列的數目是否大于1個；

若否，則選取所述實際優先級最高的消息隊列，得到選定隊列；

若是，則在所有所述實際優先級最高的消息隊列中選取默認優先級最高的消息隊列，得到選定隊列。

5.根據權利要求1所述的消息處理方法，其特征在于，還包括：

為每個消息隊列分別創建一記錄數據結構，每個記錄數據結構均包括optState字段、cPriority字段和pru字段；

其中，所述optState字段用于記錄調用消息時消息隊列是否被選取，所述cPriority字段用于記錄消息隊列的實際優先級，所述pru字段用于記錄消息隊列的首地址。

6.一種用于云存儲系統的消息處理裝置，其特征在于，包括：消息寫入模塊和消息調用模塊；其中，

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

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

還包括：隊列創建模塊，用于確定所有可接收消息，并確定每個可接收消息的類型，將所有可接收消息的類型進行整合，得到類型集合，對所述類型集合中每個類型均對應創建一相對應的消息隊列，并根據所述類型集合中各類型的重要程序為每個消息隊列設置一默認優先級。