[發明專利]一種消息的批量調度方法及系統

無效

• 申請號: 201210193670.0
• 申請日: 2012-06-13
• 公開（公告）號: CN102739781A
• 公開（公告）日: 2012-10-17
• 發明（設計）人: 胡加明;劉曉東
• 申請（專利權）人: 蘇州闊地網絡科技有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/18
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種消息的批量調度方法，其特征在于，包括以下步驟：

服務器接收網絡會議中客戶端發送的消息，根據接收的所述消息攜帶的類型信息判斷所述消息的類型，并根據所述消息所屬的類型將所述消息放入對應的消息接收隊列；

所述服務器的消息調度器調度所述消息接收隊列中的消息至所述服務器的解析器；

所述解析器解析處理所述消息，并根據所述消息所屬的企業，將所述消息放入對應企業的消息隊列；

所述服務器的批量調度器根據時間調度策略將不同企業的消息隊列中的消息分別調度至對應的業務邏輯控制器，

其中，所述服務器根據調控策略動態調控所述批量調度器的數目。

2.根據權利要求1所述的方法，其特征在于，于所述客戶端向所述服務器發送所述消息之前，所述客戶端通過查詢企業用戶信息表確定當前發送所述消息的企業用戶所屬的類別，并根據所述企業用戶的類別確定所述企業用戶發送的消息格式。

3.根據權利要求2所述的方法，其特征在于，若所述服務器存儲所述企業用戶信息表，則所述客戶端發送查詢信息至所述服務器，所述服務器根據所述查詢信息查詢所述企業用戶信息表，并將查詢得到的企業用戶的類別信息返回至所述客戶端。

4.根據權利要求1所述的方法，其特征在于，所述時間調度策略為：預設不同企業對應的消息隊列的優先級以及預設調度時長，在每個調度周期時長內，根據消息隊列從高至低的優先級順序進行調度，且每個消息隊列的調度時長為預設調度時長。

5.根據權利要求1所述的方法，其特征在于，所述時間調度策略為：預設不同企業對應的消息隊列的優先級、預設調度時長以及可借用時長，在每個調度周期時長內，根據消息隊列從高至低的優先級順序進行調度，若優先級較高的消息隊列中的消息在對應的預設調度時長內未調度完畢，則借用下一優先級的消息隊列的可借用時長繼續調度。

6.根據權利要求1所述的方法，其特征在于，所述時間調度策略為：預設不同企業對應的消息隊列的優先級以及預設調度時長，在每個調度周期時長內，根據消息隊列從高至低的優先級順序進行調度，若優先級較高的消息隊列中的消息調度所需的時長小于對應的預設調度時長，則所述多余時長分配給下一優先級的消息隊列。

7.根據權利要求1所述的方法，其特征在于，所述調控策略為：設定消息最長調度時間以及消息最短調度時間，若當前數目的所述批量調度器無法在所述消息最長調度時間內調度所述消息隊列中的消息時，增加所述批量調度器的數目，若當前數目的所述批量調度器能夠在所述消息最短調度時間內調度所述消息隊列中的消息時，減少所述批量調度器的數目。

8.根據權利要求1所述的方法，其特征在于，所述調控策略為：若所述消息隊列中未被調度的消息總數大于預設時間內當前數目的批量調度器所能調度的消息總數，則獲取所述消息隊列中未被調度的消息總數與預設時間內當前數目的批量調度器所能調度的消息總數的差值，并計算所述差值與所述消息隊列中未被調度的消息總數的比值，若所述比值小于或等于預設值，則增加所述批量調度器的數目，若所述消息隊列中未被調度的消息總數小于預設時間內當前數目的批量調度器所能調度的消息總數，則減少所述批量調度器的數目。

9.根據權利要求1所述的方法，其特征在于，所述調控策略為：設定所述批量調度器的最大調度消息數目，若當前數目的所述批量調度器以最大調度消息數目進行消息調度時無法調度所述消息隊列中的所有消息，增加所述批量調度器的數目，若當前數目的所述批量調度器能夠以最大調度消息數目調度所述消息隊列中的消息，則減少所述批量調度器的數目。

10.一種消息的批量調度系統，其特征在于，包括客戶端及服務器，所述服務器包括接收器、消息調度器、解析器、批量調度器、控制器以及業務邏輯控制器，所述客戶端連接所述服務器，所述接收器連接所述消息調度器，所述消息調度器連接所述解析器，所述解析器連接所述批量調度器，所述批量調度器連接所述業務邏輯控制器，所述控制器連接所述批量調度器及所述解析器，

其中，所述接收器，用于接收網絡會議中所述客戶端發送的消息，根據接收的所述消息攜帶的類型信息判斷所述消息的類型，并根據所述消息所屬的類型將所述消息放入對應的消息接收隊列，

所述消息調度器，用于調度所述消息接收隊列中的消息至所述解析器，

所述解析器，用于解析處理所述消息，并根據所述消息所屬的企業，將所述消息放入對應企業的消息隊列，

所述批量調度器，用于根據時間調度策略將不同企業的消息隊列中的消息分別調度至對應的所述業務邏輯控制器，

所述控制器，用于根據調控策略動態調控所述批量調度器的數目。