[發明專利]一種處理實時消息的方法和系統

有效

• 申請號: 201711084607.2
• 申請日: 2017-11-07
• 公開（公告）號: CN110019671B
• 公開（公告）日: 2022-04-12
• 發明（設計）人: 路德棋
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/33
• 分類號: G06F16/33;G06F16/953;H04L67/568
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;楊曉偉

1.一種處理實時消息的方法，其特征在于，包括：

接收一個或多個主鍵相同的實時消息；

對所述實時消息進行組裝以得到一個或多個更新操作對象，將所有的所述更新操作對象添加到接口中進行緩存；

發起對搜索系統的訪問，然后在本次訪問中向所述搜索系統發送所有的所述更新操作對象；

其中，所述對所述實時消息進行組裝以得到一個或多個更新操作對象，包括：對所述實時消息進行格式變換后得到消息體對象，根據所述消息體對象和所述實時消息中的指標組裝成Script對象，所述Script對象即為更新操作對象。

2.根據權利要求1所述的方法，其特征在于，所述對所述實時消息進行組裝以得到一個或多個更新操作對象的步驟之前，還包括：接收系統消息；

所述對所述實時消息進行組裝以得到一個或多個更新操作對象的步驟之后以及所述發起對搜索系統的訪問的步驟之前還包括：確認接收到的消息為所述系統消息，或者確認接收到的消息不是所述系統消息且所述更新操作對象的數量大于等于設定閾值。

3.根據權利要求2所述的方法，其特征在于，所述在本次訪問中向所述搜索系統發送所有的所述更新操作對象的步驟之后，還包括：根據發送頻次和預設的頻次取值區間動態調整所述閾值。

4.根據權利要求3所述的方法，其特征在于，所述根據發送頻次和預設的頻次取值區間動態調整所述閾值，包括：

當所述發送頻次大于所述頻次取值區間的最大值時，按照預設增量增加所述閾值；

當所述發送頻次小于所述頻次取值區間的最小值時，按照預設減量減少所述閾值；

當所述發送頻次在所述頻次取值區間內時，所述閾值保持不變。

5.根據權利要求1至4的任一項所述的方法，其特征在于，采用Storm執行所述處理實時消息的步驟，所述搜索系統為Elasticsearch。

6.一種處理實時消息的系統，其特征在于，包括：

第一接收模塊，用于接收一個或多個主鍵相同的實時消息；

組裝模塊，用于對所述實時消息進行組裝以得到一個或多個更新操作對象，將所有的所述更新操作對象添加到接口中進行緩存；其中，所述對所述實時消息進行組裝以得到一個或多個更新操作對象，包括：對所述實時消息進行格式變換后得到消息體對象，根據所述消息體對象和所述實時消息中的指標組裝成Script對象，所述Script對象即為更新操作對象；

發送模塊，用于發起對搜索系統的訪問，然后在本次訪問中向所述搜索系統發送所有的所述更新操作對象。

7.根據權利要求6所述的系統，其特征在于，所述系統還包括：第二接收模塊和確認模塊，所述第二接收模塊，用于接收系統消息；所述確認模塊，用于確認接收到的消息為所述系統消息，或者確認接收到的消息不是所述系統消息且所述更新操作對象的數量大于等于設定閾值。

8.根據權利要求7所述的系統，其特征在于，所述系統還包括：動態調整模塊，用于根據發送頻次和預設的頻次取值區間動態調整所述閾值。

9.根據權利要求8所述的系統，其特征在于，所述動態調整模塊，還用于：

當所述發送頻次大于所述頻次取值區間的最大值時，按照預設增量增加所述閾值；

當所述發送頻次小于所述頻次取值區間的最小值時，按照預設減量減少所述閾值；

當所述發送頻次在所述頻次取值區間內時，所述閾值保持不變。

10.一種電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-5中任一所述的方法。

11.一種計算機可讀介質，其上存儲有計算機程序，其特征在于，所述程序被處理器執行時實現如權利要求1-5中任一所述的方法。