[發明專利]基于RabbitMQ和ActiveMQ的動態隊列轉發方法、系統及存儲介質

有效

• 申請號: 202010552307.8
• 申請日: 2020-06-17
• 公開（公告）號: CN111770029B
• 公開（公告）日: 2022-06-03
• 發明（設計）人: 徐祖峰;丁小果;孫浩
• 申請（專利權）人: 江蘇泰治科技股份有限公司
• 主分類號: H04L47/50
• 分類號: H04L47/50;H04L47/125;H04L67/10
• 代理公司: 南京蘇高專利商標事務所(普通合伙) 32204
• 代理人: 王恒靜

本發明公開了一種基于RabbitMQ和ActiveMQ的動態隊列轉發方法，包括創建階段、配置階段和運行階段，本發明實現運行時隊列動態創建，同時支持數千條隊列，每秒萬條的RabbitMQ至ActiveMQ消息的來回傳輸，通過中間層，MQ之間的轉發，緩解消息積壓，支持千萬級的消息積壓而不宕機，緩解機臺ActiveMQ的壓力；(2)本發明通過中間層轉發，為大數據單獨開辟一個RabbitMQ集群，既解決了大數據采集數據的需求，又把大數據可能導致平臺宕機的風險降到了0可以解決任何底層技術難題；目前工業領域機臺通信大量使用ActiveMQ，使用本發明所述的方案可以有效緩解機臺宕機次數，滿足各種機臺通信需求，可以用很低的成本實現現有機臺通信系統的升級，提升生產效率。

技術領域

本發明涉及隊列轉發技術領域，具體涉及一種基于RabbitMQ和ActiveMQ的動態隊列轉發方法。

背景技術

通常，在互聯網環境中，業務可以具有不同的尺寸和傳輸速度。在這樣的互聯網環境中，使用隊列管理器和調度技術來疏導各個業務流和有效地管理業務。

在互聯網環境中，不同種類的內容越來越多，特別的，工業領域機臺通信出現大量的數據。因此，網絡上的數據擁塞逐漸增加。由于網絡上有越來越多的數據擁塞，服務器發送的數據可能不能被正常地轉發到客戶端，并且一些數據可能在路徑中丟失。目前解決擁塞的方式就是對消息及時的轉發，具體采用Apache-camel路由協議，對ActiveMQ 引入一個中間件，配置一個XML，可以直接實現ActiveMQ到RabbitMQ的路由，來回傳送消息。

但該方案存在一定的問題，包括：

1、Apache-camel現在已經不維護，因為ActiveMQ本身社區就很不活躍，導致填坑成本高昂。

2、Apache-camel的路由都是寫死的，工業互聯網領域機臺變更平凡，要求隊列動態創建，不能每次都重啟消息隊列，使得這個方案幾乎不可行。

3、建設中的大數據平臺要想同時消費機器采集數據存在風險，大數據平臺隨時都會停止消費，容易產生消息積壓，導致宕機。

發明內容

發明目的：為了克服現有技術的不足，本發明提供一種基于RabbitMQ和ActiveMQ的動態隊列轉發方法，該方法可以解決大量數據來回傳輸出現積壓以及機臺容易宕機的問題，本發明還提供一種基于RabbitMQ和ActiveMQ的動態隊列轉發系統。

技術方案：本發明的一方面，提供基于RabbitMQ和ActiveMQ的動態隊列轉發方法，包括創建階段、配置階段和運行階段；

所述創建階段包括創建虛擬化的RabbitMQ消息隊列集群、各個廠部對應的ActiveMQ消息隊列集群以及mqcenter消息轉發中心；

所述配置階段包括：所述mqcenter消息轉發中心初始化RabbitMQ消息隊列集群，配置RabbitMQ消息隊列集群中的節點負載均衡連接工廠，配置ActiveMQ消息隊列集群的多連接，增加緩存機制，配置消息連接工廠發送確認，返回確認；

所述運行階段包括：啟動mqcenter消息轉發中心，廠部生產者發送消息給ActiveMQ 消息隊列集群，mqcenter消息轉發中心接收到ActiveMQ消息隊列集群的消息，轉發給 RabbitMQ消息隊列集群，消費者集群消費RabbitMQ消息隊列集群傳來的消息；消費者集群消費完畢后，通過其他的數據隊列反饋消息給RabbitMQ消息隊列集群，mqcenter 消息轉發中心消費消費者發送過來的消息，根據消息的不同交換機轉發給不同廠部的ActiveMQ消息隊列集群。

進一步的，包括：