[發明專利]用于數據傳輸的方法、裝置及計算機可讀存儲介質

有效

• 申請號: 201710353371.1
• 申請日: 2017-05-18
• 公開（公告）號: CN108965355B
• 公開（公告）日: 2021-05-25
• 發明（設計）人: 聶啟忠
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 北京律智知識產權代理有限公司 11438
• 代理人: 闞梓瑄;王衛忠

1.一種用于數據傳輸的方法，其特征在于，所述方法包括：

生產者代理agent從第一進程間消息隊列中讀取生產者寫入的消息數據；

所述生產者agent將所述消息數據發送到redis；

消費者agent從所述redis中讀取消息數據，并將所述消息數據寫入到第二進程間消息隊列，以使消費者從所述第二進程間消息隊列讀取到所述消息數據。

2.如權利要求1所述的方法，其特征在于，所述消息數據包括主題標識；所述生產者agent將所述消息數據發送到redis包括：

所述生產者agent將具有相同主題標識的消息數據發送到對應的redis。

3.如權利要求2所述的方法，其特征在于，redis以列表的數據形式存儲消息數據；

所述生產者agent將具有相同主題標識的消息數據發送到對應的redis，包括：

所述生產者agent將序列化的消息數據發送到與所述消息數據的主題標識對應的redis中。

4.如權利要求1所述的方法，其特征在于，所述方法還包括：

在第一哈希表中記錄已經發送到redis中的消息數據的主題標識、消息標識以及發送所述消息數據的生產者標識三者的對應關系；

所述生產者agent將所述消息數據發送到redis，包括：

所述生產者agent在所述第一哈希表中查找是否存在所述消息數據的主題標識、消息標識以及發送所述消息數據的生產者標識三者的對應關系；

如果是，所述生產者agent丟棄所述消息數據；

如果否，所述生產者agent將所述消息數據發送到redis，并更新所述第一哈希表。

5.如權利要求3所述的方法，其特征在于，所述消費者agent從所述redis中讀取消息數據，包括：

所述消費者agent遍歷redis，查找到與消費者訂閱的消息數據的主題標識對應的redis，從redis中讀取消息數據。

6.如權利要求5所述的方法，其特征在于，所述方法還包括：

在有序集合中記錄消息數據的主題標識、訂閱所述消息數據的主題標識的消費者標識以及所述消費者標識對應的待消費的消息標識；

所述從redis中讀取消息數據，包括：

所述消費者agent根據所述有序集合，從所述列表中讀取消息數據。

7.如權利要求6所述的方法，其特征在于，所述方法還包括：

在第二哈希表中記錄各消費者標識、各消費者已經讀取的消息數據的消息標識、以及各消費者標識上次讀取的消息標識三者的對應關系；

所述消費者agent比較本次讀取的消息數據的消息標識與上次讀取的消息標識是否一致；

如果一致，所述生產者agent丟棄所述消息數據；

如果不一致，所述生產者agent將所述消息數據寫入到第二進程間消息隊列。

8.如權利要求7所述的方法，其特征在于，所述方法還包括：

如果所述消費者agent讀取消息數據超時，所述消費者agent根據所述第二哈希表重新讀取消息數據。

9.一種用于數據傳輸的裝置，其特征在于，所述裝置包括：

讀取模塊，用于從第一進程間消息隊列中讀取生產者發送的消息數據；

發送模塊，用于將所述消息數據發送到redis；

寫入模塊，用于從所述redis中讀取消息數據，并將所述消息數據寫入到第二進程間消息隊列，以使消費者從所述第二進程間消息隊列讀取到所述消息數據。

10.如權利要求9所述的裝置，其特征在于，所述消息數據包括主題標識；所述發送模塊，配置為將具有相同主題標識的消息數據發送到對應的redis。