[發明專利]消息傳遞系統和方法

在審

• 申請號: 202110228652.0
• 申請日: 2015-01-23
• 公開（公告）號: CN113037823A
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 沙拉德·R·墨菲;汪興朗;拉杰斯瓦里·穆圖潘蒂安
• 申請（專利權）人: 電子灣有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/18;H04L12/24;H04L12/26;H04L12/801;H04L12/851;H04L29/06;H04L29/12
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 陳慧

1.一種生成會話化數據的方法，包括：

接收對所述會話化數據的訂閱請求，

分配鏈接到所述訂閱請求的會話器組，

將分配的會話器組注冊為能夠用于處理事件消息，以及

處理接收到的事件消息以生成所述會話化數據。

2.根據權利要求1所述的方法，其中，所述訂閱請求包括訂戶標識符和一個或多個感興趣的會話。

3.根據權利要求1所述的方法，其中，所述會話器組包括能夠用于服務所述訂閱請求的一個或多個處理引擎。

4.根據權利要求1-3中任一項所述的方法，還包括：

配置鏈接到所述會話器組的相應處理引擎的標識符。

5.根據權利要求4所述的方法，其中，鏈接到相應處理引擎的所述標識符對應于分配給所述會話器組的每個處理引擎的多個哈希值。

6.根據權利要求1所述的方法，還包括：

通過消息傳遞系統將所述事件消息從處理引擎傳輸到基于一致的哈希調度器選擇的消費者設備。

7.根據權利要求6所述的方法，其中，所述處理接收到的事件消息還包括：

所選擇的消費者設備根據鏈接到所述訂閱請求的會話規則數據來處理接收到的事件消息，以生成會話化數據。

8.根據權利要求7所述的方法，其中，所述會話規則數據對應于訂戶所請求的一個或多個屬性。

9.根據權利要求1所述的方法，其中，所述會話化數據是通過對包含特定標識符并且在稱為會話持續時間的時間窗口期間發生的事件消息進行分組處理的數據。

10.根據權利要求6-8中任一項所述的方法，還包括：

消費者設備在接收到所述事件消息時生成和更新會話。

11.根據權利要求6-8中任一項所述的方法，還包括：

消費者設備響應于計時器事件、會話檢查事件和會話恢復事件中的至少一個執行會話生命周期管理。

12.一種用于生成會話化數據的系統，包括：

一個或多個存儲器，其上存儲指令；和

一個或多個處理器，與存儲器耦合并且被配置為執行指令以執行操作，所述操作包括：

接收對所述會話化數據的訂閱請求，

分配鏈接到所述訂閱請求的會話器組，

將分配的會話器組注冊為能夠用于處理事件消息，以及

處理接收到的事件消息以生成所述會話化數據。

13.一種包含指令的設備可讀存儲介質，所述指令在由設備執行時使所述設備執行根據權利要求1-11所述的任一方法。