[發明專利]一種用于消息分配、消費的方法及裝置，用于消息處理的系統

有效

• 申請號: 201410107984.3
• 申請日: 2014-03-21
• 公開（公告）號: CN104935622B
• 公開（公告）日: 2019-03-15
• 發明（設計）人: 徐松;杜濤;岑英嵐
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京清源匯知識產權代理事務所(特殊普通合伙) 11644
• 代理人: 馮德魁

1.一種用于消息分配的方法，其特征在于包括：

獲取滿足消息消費活躍度閾值的消息消費者列表；所述滿足消息消費活躍度閾值的消息消費者，指當前活躍度值與歷史最大活躍度的比值大于或等于所述消息消費者活躍度閾值的消息消費者；所述當前活躍度值為表征消息消費者當前服務能力值的單機耗時、是否消費成功和單機每秒事務處理量中的至少一種及其權重的加權平均數；

對于滿足消息消費活躍度閾值的消息消費者，依據活躍度由高到低的順序依次向消息消費者分配消息隊列中的消息。

2.根據權利要求1所述的用于消息分配的方法，其特征在于，所述獲取滿足消息消費活躍度閾值的消息消費者列表包括：

接收消息消費者發送的該消費者的當前活躍度值；

計算該當前活躍度值與歷史最大活躍度的比值；

將所述比值大于或等于所述消息消費者活躍度閾值的消息消費者作為滿足消息消費活躍度閾值的消息消費者。

3.根據權利要求2所述的用于消息分配的方法，其特征在于，所述當前活躍度值為表征消息消費者當前服務能力值的單機耗時、是否消費成功和單機每秒事務處理量中的至少一種及其權重的加權平均數。

4.根據權利要求1所述的用于消息分配的方法，其特征在于，所述獲取滿足消息消費活躍度閾值的消息消費者列表包括：

接收消息消費者發送的表征消息消費者當前服務能力值的單機耗時、是否消費成功和單機每秒事務處理量中的至少一種以及相應的權重；

計算所述當前服務能力值及其權重的加權平均數，并將該加權平均數作為該消息消費者的當前活躍度值；

計算所述當前活躍度值與該消息消費者歷史最大活躍度值的比值；

將所述比值大于或等于所述消息消費者活躍度閾值的消息消費者作為滿足消息消費活躍度閾值的消息消費者。

5.根據權利要求2或4所述的用于消息分配的方法，其特征在于：所述消息消費者活躍度閾值通過所有注冊在線的消費者的當前活躍度的平均值與其總和的比值獲得。

6.根據權利要求1所述的用于消息分配的方法，其特征在于，所述對于滿足消息消費活躍度閾值的消息消費者，依據活躍度由高到低的順序依次向消息消費者分配消息隊列中的消息包括：

對于滿足消息消費活躍度閾值的消費者，按照活躍度由高到低的順序將消息消費者分為不同的組，每一分組中包括至少兩個消息消費者；

按照活躍度由高至低的順序，依次向每一分組的消費者分配待消費消息；

對于每一分組中的消費者，按照機會均等原則向消息消費者分配待消費消息。

7.根據權利要求6所述的用于消息分配的方法，其特征在于，所述對于每一分組中的消費者，按照機會均等原則向消息消費者分配待消費消息具體包括：

獲取分組中每一消息消費者的消費者ID及在分組中消費者數目；

對所述消費者ID執行hash取模運算；

向滿足hash取模運算結果的消費者分配待消費消息。

8.根據權利要求7所述的用于消息分配的方法，其特征在于，所述取模運算具體為hash按余取模運算。

9.根據權利要求6所述的用于消息分配的方法，其特征在于，所述對于每一分組中的消費者，按照機會均等原則向消息消費者分配待消費消息具體是指：依據先進先出原則的原則，將消息隊列中的消息按照接收機會均等原則向消息消費者分配待消費消息。

10.一種用于消息分配的裝置，其特征在于包括：

獲取單元，用于獲取滿足消息消費活躍度閾值的消息消費者列表；所述滿足消息消費活躍度閾值的消息消費者，指當前活躍度值與歷史最大活躍度的比值大于或等于所述消息消費者活躍度閾值的消息消費者；所述當前活躍度值為表征消息消費者當前服務能力值的單機耗時、是否消費成功和單機每秒事務處理量中的至少一種及其權重的加權平均數；

分配單元，用于對于滿足消息消費活躍度閾值的消息消費者，依據活躍度由高到低的順序依次向消息消費者分配消息隊列中的消息。