[發明專利]一種數據擺渡方法、系統、終端設備及可讀存儲介質

有效

• 申請號: 202010433420.4
• 申請日: 2020-05-20
• 公開（公告）號: CN111541720B
• 公開（公告）日: 2022-08-09
• 發明（設計）人: 陳彬;陸貴濤
• 申請（專利權）人: 浩云科技股份有限公司
• 主分類號: H04L9/40
• 分類號: H04L9/40;H04L69/163;H04L67/566;H04L67/568;H04L67/145;H04L49/90
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 郭浩輝;麥小嬋

1.一種數據擺渡方法，其特征在于，包括：

數據擺渡設備接入模塊對數據擺渡設備接入對象進行初始化后，啟動TCP連接保活線程，以使所述數據擺渡設備接入對象以預設的時間間隔發送/接收心跳包，并按預設的條件檢測到心跳包發送/接收發生異常時，斷開所述TCP連接保活線程并重新進行連接；

所述數據擺渡設備接入模塊對所述數據擺渡設備接入對象進行初始化后，啟動數據包緩存處理線程，以使所述數據擺渡設備接入對象將發送/接收的數據進行數據包緩存；

MQ隊列訂閱模塊在收到MQ消息時，將該MQ消息添加到發送隊列緩存模塊，以使所述發送隊列緩存模塊發出提示事件至數據擺渡發送模塊，繼而所述數據擺渡發送模塊獲取所述MQ消息并通過所述數據擺渡設備接入模塊發送至對端；

所述數據擺渡設備接入模塊在接收到對端的MQ消息時，發出提示事件至數據擺渡接收模塊，以使所述數據擺渡接收模塊將所述對端的MQ消息添加到接收隊列緩存模塊，繼而MQ隊列發布模塊從所述接收隊列緩存模塊獲取到所述對端的MQ消息后進行MQ消息發布。

2.根據權利要求1所述的數據擺渡方法，其特征在于，所述數據擺渡設備接入模塊對所述數據擺渡設備接入對象進行初始化后，啟動數據包緩存處理線程，以使所述數據擺渡設備接入對象將發送/接收的數據進行數據包緩存，具體包括：

所述數據擺渡設備接入模塊對所述數據擺渡設備接入對象進行初始化后，啟動數據包緩存處理線程，以使所述數據擺渡設備接入對象將發送/接收的數據進行數據包緩存；

當所述數據擺渡設備接入對象接收到對端的數據接收成功應答后，將該數據從數據包緩存中移除；

當所述數據擺渡設備接入對象將數據發送至對端并在預設的時間內未收到應答時，對該數據進行重新發送，并在重發次數達到預設的閾值時將該數據從所述數據包緩存中移除，同時，發出數據超時未發送提醒事件。

3.根據權利要求1所述的數據擺渡方法，其特征在于，所述MQ隊列訂閱模塊在收到MQ消息時，將該MQ消息添加到發送隊列緩存模塊，以使所述發送隊列緩存模塊發出提示事件至數據擺渡發送模塊，繼而所述數據擺渡發送模塊獲取所述MQ消息并通過所述數據擺渡設備接入模塊發送至對端，具體包括：

數據擺渡發送模塊訂閱發送隊列緩存模塊變更事件，發送隊列緩存模塊初始化發送隊列，并保存發送隊列最后修改時間；

MQ隊列訂閱模塊在收到MQ消息時，將該MQ消息添加到發送隊列緩存模塊，并修改最后修改時間為當前時間；

發送隊列緩存模塊輪詢判斷發送隊列最后修改時間與自身保存的時間是否不同，若是則判斷自身的發送隊列已發生變化，繼而發出提示事件至數據擺渡發送模塊；

所述數據擺渡發送模塊從所述發送隊列緩存模塊獲取所述MQ消息并通過所述數據擺渡設備接入模塊發送至對端。

4.根據權利要求1所述的數據擺渡方法，其特征在于，所述數據擺渡設備接入模塊在接收到對端的MQ消息時，發出提示事件至數據擺渡接收模塊，以使所述數據擺渡接收模塊將所述對端的MQ消息添加到接收隊列緩存模塊，繼而MQ隊列發布模塊從所述接收隊列緩存模塊獲取到所述對端的MQ消息后進行MQ消息發布，具體包括：

MQ隊列發布模塊訂閱接收隊列緩存模塊變更事件，接收隊列緩存模塊初始化接收隊列，并保存接收隊列最后修改時間；

所述數據擺渡設備接入模塊在接收到對端的MQ消息時，發出提示事件至數據擺渡接收模塊；

所述數據擺渡接收模塊將所述對端的MQ消息添加到接收隊列緩存模塊，并修改最后修改時間為當前時間；

接收隊列緩存模塊輪詢判斷接收隊列最后修改時間與自身保存的時間是否不同，若是則判斷接收隊列已發生變化，繼而發出提示事件至MQ隊列發布模塊；

所述MQ隊列發布模塊從所述接收隊列緩存模塊獲取到所述對端的MQ消息后進行MQ消息發布。