[發(fā)明專利]一種用于云存儲系統(tǒng)的消息處理方法和裝置

有效

• 申請?zhí)枺?/td>: 201610082605.9
• 申請日: 2016-02-05
• 公開（公告）號: CN105763608B
• 公開（公告）日: 2019-03-15
• 發(fā)明（設(shè)計(jì)）人: 侯山鵬
• 申請（專利權(quán)）人: 浪潮（北京）電子信息產(chǎn)業(yè)有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 羅滿

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

當(dāng)接收到消息時，確定接收的消息的類型及所述類型相對應(yīng)的消息隊(duì)列，其中，每個消息隊(duì)列均具有默認(rèn)優(yōu)先級和實(shí)際優(yōu)先級，判斷所述消息隊(duì)列是否為空，若不為空，則將所述接收的消息添加至所述消息隊(duì)列中，若為空，則將該接收的消息添加至所述消息隊(duì)列中，并將所述消息隊(duì)列的默認(rèn)優(yōu)先級作為所述消息隊(duì)列的實(shí)際優(yōu)先級；

當(dāng)調(diào)用消息時，在所有消息隊(duì)列中選取實(shí)際優(yōu)先級最高的消息隊(duì)列，得到選定隊(duì)列，從所述選定隊(duì)列中調(diào)用消息，當(dāng)在所述選定隊(duì)列中調(diào)用的消息的數(shù)目大于預(yù)設(shè)閾值時，更新所述選定隊(duì)列的實(shí)際優(yōu)先級，直至所述選定隊(duì)列的實(shí)際優(yōu)先級小于預(yù)設(shè)優(yōu)先級，重新在所有消息隊(duì)列中選取優(yōu)先級最高的消息隊(duì)列；

在所述當(dāng)接收到消息時，確定接收的消息的類型及所述類型相對應(yīng)的消息隊(duì)列之前，還包括：確定所有可接收消息，并確定每個可接收消息的類型；將所有可接收消息的類型進(jìn)行整合，得到類型集合；對所述類型集合中每個類型均對應(yīng)創(chuàng)建一相對應(yīng)的消息隊(duì)列，并根據(jù)所述類型集合中各類型的重要程序?yàn)槊總€消息隊(duì)列設(shè)置一默認(rèn)優(yōu)先級。

2.根據(jù)權(quán)利要求1所述的消息處理方法，其特征在于，所述根據(jù)所述類型集合中各類型的重要程序?yàn)槊總€消息隊(duì)列設(shè)置一默認(rèn)優(yōu)先級后還包括：

判斷是否存在默認(rèn)優(yōu)先級相同的消息隊(duì)列；

若存在，則將所有默認(rèn)優(yōu)先級相同的消息隊(duì)列合并為一消息隊(duì)列，進(jìn)行合并后得到的消息隊(duì)列的默認(rèn)優(yōu)先級與進(jìn)行合并前各默認(rèn)優(yōu)先級相同的消息隊(duì)列的默認(rèn)優(yōu)先級相同。

3.根據(jù)權(quán)利要求1所述的消息處理方法，其特征在于，

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

所述從所述選定隊(duì)列中調(diào)用消息為：每次調(diào)用位于所述選定隊(duì)列隊(duì)頭的消息。

4.根據(jù)權(quán)利要求1所述的消息處理方法，其特征在于，所述在所有消息隊(duì)列中選取實(shí)際優(yōu)先級最高的消息隊(duì)列，得到選定隊(duì)列包括：

確定所有消息隊(duì)列的實(shí)際優(yōu)先級，并在所有消息隊(duì)列中確定實(shí)際優(yōu)先級最高的消息隊(duì)列；

判斷所述實(shí)際優(yōu)先級最高的消息隊(duì)列的數(shù)目是否大于1個；

若否，則選取所述實(shí)際優(yōu)先級最高的消息隊(duì)列，得到選定隊(duì)列；

若是，則在所有所述實(shí)際優(yōu)先級最高的消息隊(duì)列中選取默認(rèn)優(yōu)先級最高的消息隊(duì)列，得到選定隊(duì)列。

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

為每個消息隊(duì)列分別創(chuàng)建一記錄數(shù)據(jù)結(jié)構(gòu)，每個記錄數(shù)據(jù)結(jié)構(gòu)均包括optState字段、cPriority字段和pru字段；

其中，所述optState字段用于記錄調(diào)用消息時消息隊(duì)列是否被選取，所述cPriority字段用于記錄消息隊(duì)列的實(shí)際優(yōu)先級，所述pru字段用于記錄消息隊(duì)列的首地址。

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

所述消息寫入模塊，用于當(dāng)接收到消息時，確定接收的消息的類型及所述類型相對應(yīng)的消息隊(duì)列，其中，每個消息隊(duì)列均具有默認(rèn)優(yōu)先級和實(shí)際優(yōu)先級，判斷所述消息隊(duì)列是否為空，若不為空，則將所述接收的消息添加至所述消息隊(duì)列中，若為空，則將該接收的消息添加至所述消息隊(duì)列中，并將所述消息隊(duì)列的默認(rèn)優(yōu)先級作為所述消息隊(duì)列的實(shí)際優(yōu)先級；

所述消息調(diào)用模塊，用于當(dāng)調(diào)用消息時，在所有消息隊(duì)列中選取實(shí)際優(yōu)先級最高的消息隊(duì)列，得到選定隊(duì)列，從所述選定隊(duì)列中調(diào)用消息，當(dāng)在所述選定隊(duì)列中調(diào)用的消息的數(shù)目大于預(yù)設(shè)閾值時，更新所述選定隊(duì)列的實(shí)際優(yōu)先級，直至所述選定隊(duì)列的實(shí)際優(yōu)先級小于預(yù)設(shè)優(yōu)先級，重新在所有消息隊(duì)列中選取優(yōu)先級最高的消息隊(duì)列；

還包括：隊(duì)列創(chuàng)建模塊，用于確定所有可接收消息，并確定每個可接收消息的類型，將所有可接收消息的類型進(jìn)行整合，得到類型集合，對所述類型集合中每個類型均對應(yīng)創(chuàng)建一相對應(yīng)的消息隊(duì)列，并根據(jù)所述類型集合中各類型的重要程序?yàn)槊總€消息隊(duì)列設(shè)置一默認(rèn)優(yōu)先級。