[發明專利]一種消息分發的方法和裝置

在審

• 申請號: 201610068734.2
• 申請日: 2016-02-01
• 公開（公告）號: CN105677494A
• 公開（公告）日: 2016-06-15
• 發明（設計）人: 許文靖
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;姜勁

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

消息生產者與消息消費者根據消息分發服務地址建立消息傳輸通 道；

所述消息生產者將生產的消息按照預定的時間間隔進行分組，并 按照各消息組的創建順序將所述消息組通過所述消息傳輸通道發送給 所述消息消費者；

所述消息消費者接收所述消息組并讀取所述消息組中的消息，并 按照消息生產的先后順序依次消費所述讀取的消息。

2.根據權利要求1所述的方法，其特征在于，消息生產者與消息 消費者根據消息分發服務地址建立消息傳輸通道的步驟，包括：

所述消息生產者將所述分發服務地址發送到消息傳輸模塊；

所述消息消費者從所述消息傳輸模塊查找到所述分發服務地址， 并根據所述分發服務地址與所述消息生產者建立消息傳輸通道。

3.根據權利要求1所述的方法，其特征在于，所述消息生產者將 生產的消息按照預定的時間間隔進行分組的步驟包括：

根據消息生產的當前時間和所述預定的時間間隔計算時間標識；

根據所述預定的時間間隔內消息生產的先后順序對所述消息進行 排序，并給出對應的序列號；

對所述生產的消息創建新的消息對象，所述新的消息對象包括所 述時間標識、所述序列號和所述消息的內容；

對所述新的消息對象按照預定的時間間隔進行分組。

4.根據權利要求1所述的方法，其特征在于，

將所述消息組通過所述消息傳輸通道發送給所述消息消費者的步 驟包括：

對所述消息組進行壓縮，并創建壓縮消息對象；

將所述壓縮消息對象通過所述消息傳輸通道發送給所述消息消費 者；

以及，

消息消費者接收所述消息組的步驟包括：

消息消費者對接收的所述消息壓縮對象進行解壓縮，得到所述消 息組。

5.根據權利要求1所述的方法，其特征在于，按照消息生產的先 后順序依次消費所述讀取的消息的步驟之前，還包括：

所述消息消費者對所述讀取的消息進行格式校驗，并刪除其中不 完整的消息。

6.一種消息分發的裝置，其特征在于，包括：

消息傳輸模塊，用于消息生產者與消息消費者根據消息分發服務 地址建立消息傳輸通道；

消息發送模塊，用于所述消息生產者將生產的消息按照預定的時 間間隔進行分組，并按照各消息組的創建順序將所述消息組通過所述 消息傳輸通道發送給所述消息消費者；

消息接收模塊，用于所述消息消費者接收所述消息組并讀取所述 消息組中的消息，并按照消息生產的先后順序依次消費所述讀取的消 息。

7.根據權利要求6所述的裝置，其特征在于，所述消息傳輸模塊 還用于：

接收所述消息生產者發送來的所述分發服務地址；

以及所述消息消費者從所述消息傳輸模塊查找所述分發服務地 址，并根據所述分發服務地址與所述消息生產者建立消息傳輸通道。

8.根據權利要求6所述的裝置，其特征在于，所述消息發送模塊 還用于：

根據消息生產的當前時間和所述預定的時間間隔計算時間標識；

根據所述預定的時間間隔內消息生產的先后順序對所述消息進行 排序，并給出對應的序列號；

對所述生產的消息創建新的消息對象，所述新的消息對象包括所 述時間標識、所述序列號和所述消息的內容；

對所述新的消息對象按照預定的時間間隔進行分組。

9.根據權利要求6所述的裝置，其特征在于，

所述消息發送模塊還用于：

對所述消息組進行壓縮，并創建壓縮消息對象；

將所述壓縮消息對象通過所述消息傳輸通道發送給所述消息消費 者；

以及，

所述消息接收模塊還用于：

對接收的所述消息壓縮對象進行解壓縮，得到所述消息組。

10.根據權利要求6所述的裝置，其特征在于，所述消息接收模塊 還用于：

對所述讀取的消息進行格式校驗，并刪除其中不完整的消息。