[發明專利]一種數據傳輸方法

在審

• 申請號: 201710023479.4
• 申請日: 2017-01-13
• 公開（公告）號: CN107070976A
• 公開（公告）日: 2017-08-18
• 發明（設計）人: 吳秋莉;尹立群;呂澤承;張煒;鄔蓉蓉
• 申請（專利權）人: 廣西電網有限責任公司電力科學研究院
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 南寧東智知識產權代理事務所(特殊普通合伙)45117
• 代理人: 戴燕桃,巢雄輝

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

獲取來自上游節點的輸出數據流；

根據數據流名將所述輸出數據流進行持久化備份；

根據所述輸出數據流和下游節點的訂閱關系，將所述輸出數據流發送到與所述下游節點一一對應的共享內存隊列上；

發送所述共享內存隊列內的數據流。

2.根據權利要求1所述的數據傳輸方法，其特征在于，

與所述下游節點一一對應的所述共享內存隊列是以所述下游節點命名的。

3.根據權利要求1所述的數據傳輸方法，其特征在于，還包括：

設置過期時長；

記錄對所述輸出數據流進行持久化備份的開始時間；

獲取當前時間；

若當前時間與開始時間之間的時間差大于或等于所述過期時長，則刪除所述輸出數據流。

4.根據權利要求1所述的數據傳輸方法，其特征在于，獲取來自上游節點的輸出數據流包括：

監聽指定端口，并將所述指定端口加入到epoll句柄中；

當接收到來自上游節點的輸出數據流名時，以閱讀標志打開有名管道；

將所述有名管道的文件描述符加入到epoll循環中；

從所述有名管道中循環讀取來自上游節點的輸出數據流。

5.根據權利要求1所述的數據傳輸方法，其特征在于，根據數據流名將所述輸出數據流進行持久化備份包括：

所述共享內存隊列中的數據項以key-value形式儲存。

6.根據權利要求5所述的數據傳輸方法，其特征在于，所述key值是數據項的時間戳。

7.根據權利要求1所述的數據傳輸方法，其特征在于，發送所述共享內存隊列內的所有數據流包括：

將下游節點名封裝成任務放入任務隊列中；

取出所述任務隊列中的下游節點名，從相應的共享內存隊列中取出數據；

根據Zookeeper中所述下游節點的配置發送數據。

8.根據權利要求7所述的數據傳輸方法，其特征在于，所述根據Zookeeper中所述下游節點的配置發送數據包括：

獲取所述下游節點的流量設置；

基于所述流量設置，發送數據。