[發明專利]消息隊列的擁塞控制方法和裝置

有效

• 申請號: 201510770687.1
• 申請日: 2015-11-12
• 公開（公告）號: CN106708607B
• 公開（公告）日: 2020-12-22
• 發明（設計）人: 戴瀟桐
• 申請（專利權）人: 創新先進技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京國昊天誠知識產權代理有限公司 11315
• 代理人: 黃熊;李永強

1.一種消息隊列的擁塞控制方法，其特征在于，包括：

判斷用于接收待發送消息的目標消息隊列是否發生擁塞，所述目標消息隊列位于包括若干具有優先級的消息隊列的隊列系統內，所述待發送消息具有優先級，所述待發送消息和目標消息隊列的優先級相同；

在所述目標消息隊列發生擁塞時，在所述隊列系統內確定一個比所述目標消息隊列的優先級低的消息隊列，將所述待發送消息存至所述比目標消息隊列的優先級低的消息隊列；

在所述目標消息隊列未發生擁塞時，將所述待發送消息存至所述目標消息隊列，其中，

在判斷出所述目標消息隊列發生擁塞后，所述方法還包括：判斷所述目標消息隊列的優先級是否為最低級別；在所述目標消息隊列的優先級不是最低級別時，執行所述在所述隊列系統內確定一個比所述目標消息隊列的優先級低的消息隊列的步驟；在所述目標消息隊列的優先級是最低級別時，丟棄所述待發送消息或將所述目標消息隊列內消息存入硬盤。

2.如權利要求1所述的方法，其特征在于，所述判斷用于接收待發送消息的目標消息隊列是否發生擁塞，具體包括：

判斷用于接收待發送消息的目標消息隊列的長度是大于預設上限值、小于預設下限值還是在預設上限值和預設下限值之間；

則在所述目標消息隊列發生擁塞時，在所述隊列系統內確定一個比所述目標消息隊列的優先級低的消息隊列，具體包括：

在所述目標消息隊列的長度大于預設上限值，或，在所述目標消息隊列的長度在預設上限值和預設下限值之間并以預設概率確定所述目標消息隊列發生擁塞時，在所述隊列系統內確定一個比所述目標消息隊列的優先級低的消息隊列。

3.如權利要求1所述的方法，其特征在于，所述判斷用于接收待發送消息的目標消息隊列是否發生擁塞，具體包括：

判斷用于接收待發送消息的目標消息隊列的長度是大于預設上限值、小于預設下限值還是在預設上限值和預設下限值之間；

則在所述目標消息隊列未發生擁塞時，將所述待發送消息存至所述目標消息隊列，具體包括：

在所述目標消息隊列的長度在預設上限值和預設下限值之間并以預設概率確定所述目標消息隊列未發生擁塞時，或，在所述目標消息隊列的長度小于預設下限值時，將所述待發送消息存至所述目標消息隊列。

4.如權利要求2或3所述的方法，其特征在于，所述預設下限值和預設上限值根據用于接收待發送消息的目標消息隊列的優先級確定，所述預設概率根據用于接收待發送消息的目標消息隊列的長度與預設上限值的差值確定。

5.如權利要求1所述的方法，其特征在于，所述在所述隊列系統內確定一個比所述目標消息隊列的優先級低的消息隊列之后，所述方法還包括：

將所述目標消息隊列更新為所述比目標消息隊列的優先級低的消息隊列，并返回所述判斷用于接收待發送消息的目標消息隊列是否發生擁塞的步驟。

6.如權利要求1所述的方法，其特征在于，所述將所述待發送消息存至所述隊列系統內比所述目標消息隊列的優先級低的消息隊列，具體包括：

將所述待發送消息存至所述隊列系統內僅比目標消息隊列的優先級低一級的消息隊列。

7.如權利要求1所述的方法，其特征在于，所述將所述待發送消息存至所述隊列系統內比所述目標消息隊列的優先級低的消息隊列，具體包括：

將所述待發送消息存至所述隊列系統內比目標消息隊列的優先級低的、且隊列長度最短的消息隊列。

8.如權利要求1所述的方法，其特征在于，所述隊列系統內消息隊列的發送帶寬被配置為與該消息隊列的優先級正相關。