[發明專利]消息處理方法及系統、消息目的端設備與分布式消息系統

有效

• 申請號: 201310687237.7
• 申請日: 2013-12-13
• 公開（公告）號: CN104092717A
• 公開（公告）日: 2014-10-08
• 發明（設計）人: 董宇
• 申請（專利權）人: 深圳市騰訊計算機系統有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 江崇玉

1.一種消息處理方法，其特征在于，所述方法包括：

消息源端設備為待發送的消息組生成消息標識，每個消息組包括多條消息，所述消息標識用以唯一標識所述消息組；

所述消息源端設備向消息代理端設備發送所述消息標識和所述消息組；

所述消息代理端設備接收并存儲所述消息源端設備發送的所述消息標識和所述消息組；

當所述消息源端設備確定需要再次發送所述消息組時，從已生成的消息標識中獲取所述消息組的消息標識；

所述消息源端設備向所述消息代理端設備發送所述消息標識和所述消息組；

當所述消息代理端設備根據已接收到的消息標識，確定再次接收到所述消息標識對應的消息組時，對本次接收到的所述消息組進行去重處理。

2.根據權利要求1所述的方法，其特征在于，當所述消息代理端設備根據已接收到的消息標識，確定再次接收到所述消息標識對應的消息組時，對本次接收到的所述消息組進行去重處理，包括：

當所述消息代理端設備根據已接收到的消息標識，確定再次接收到所述消息標識對應的消息組時，丟棄本次接收的所述消息標識和所述消息組。

3.根據權利要求1或2所述的方法，其特征在于，所述消息代理端設備接收并存儲所述消息源端設備發送的所述消息標識和所述消息組，包括：

所述消息代理端設備接收所述消息源端設備發送的所述消息標識和所述消息組，并在本地存儲所述消息組，在外部存儲器中存儲所述消息標識，同時并在所述外部存儲器中記錄存儲所述消息標識的時刻。

4.根據權利要求3所述方法，其特征在于，所述方法還包括：

所述消息代理端設備刪除所述外部存儲器中存儲時間超出存儲周期的所述消息標識。

5.一種消息處理方法，其特征在于，所述方法包括：

從外部存儲器中獲取當前待處理的消息的位置；

根據所述當前待處理的消息的位置，調用應用程序接口從消息代理端設備中獲取所述當前待處理的消息；所述應用程序接口提供所述當前待處理的消息的位置；

根據所述當前待處理的消息進行業務計算，得到計算結果；并確定下一條待處理的消息的位置；

將所述計算結果和所述下一條待處理的消息的位置以同一事務存儲在所述外部存儲器中。

6.一種消息處理系統，其特征在于，所述系統包括：消息源端設備和消息代理端設備；

所述消息源端設備，用于為待發送的消息組生成消息標識，每個消息組包括多條消息，所述消息標識用以唯一標識所述消息組；并向消息代理端設備發送所述消息標識和所述消息組；

所述消息代理端設備，用于接收并存儲所述消息源端設備發送的所述消息標識和所述消息組；

所述消息源端設備，還用于當確定需要再次發送所述消息組時，從已生成的消息標識中獲取所述消息組的消息標識；并向所述消息代理端設備發送所述消息標識和所述消息組；所述消息代理端設備，還用于當根據已接收到的消息標識，確定再次接收到所述消息標識對應的消息組時，對本次接收到的所述消息組進行去重處理。

7.根據權利要求6所述的系統，其特征在于，所述消息代理端設備，具體用于當根據已接收到的消息標識，確定再次接收到所述消息標識對應的消息組時，丟棄本次接收的所述消息標識和所述消息組。

8.根據權利要求6或7所述的系統，其特征在于，所述消息代理端設備，具體用于接收所述消息源端設備發送的所述消息標識和所述消息組，并在本地存儲所述消息組，在外部存儲器中存儲所述消息標識，同時并在所述外部存儲器中記錄存儲所述消息標識的時刻。

9.根據權利要求8所述系統，其特征在于，所述消息代理端設備，還用于刪除所述外部存儲器中存儲時間超出存儲周期的所述消息標識。

10.一種消息目的端設備，其特征在于，所述設備包括：

獲取模塊，用于從外部存儲器中獲取當前待處理的消息的位置；

所述獲取模塊，還用于根據所述當前待處理的消息的位置，調用應用程序接口從消息代理端設備中獲取所述當前待處理的消息；所述應用程序接口提供所述當前待處理的消息的位置；

計算模塊，用于根據所述當前待處理的消息進行業務計算，得到計算結果；并確定下一條待處理的消息的位置；

存儲模塊，用于將所述計算結果和所述下一條待處理的消息的位置以同一事務存儲在所述外部存儲器中。

11.一種分布式消息系統，其特征在于，所述分布式消息系統包括消息處理系統和消息目的端設備；所述消息處理系統包括消息源端設備和消息代理端設備；所述消息處理系統中的所述消息代理端設備分別與所述消息目的端設備和所述消息處理系統中的所述消息源端設備進行通訊；

所述消息處理系統采用如上權利要求6-9任一所述的消息處理系統；

和/或所述消息目的端設備采用如上權利要求10所述的消息目的端設備。