[發明專利]數據采集方法、裝置、計算機設備及計算機可讀存儲介質

有效

• 申請號: 201911146802.2
• 申請日: 2019-11-21
• 公開（公告）號: CN111104233B
• 公開（公告）日: 2023-09-26
• 發明（設計）人: 孫朝和;申志彬;李如先
• 申請（專利權）人: 深圳前海環融聯易信息科技服務有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/25;G06F16/18
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 李翔宇

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

獲取外部數據源的數據，并將所述數據存入內存中；

判斷數據接收方所對應的目標系統是否滿足預設存活條件，所述目標系統指數據采集系統中包含的接收所采集的數據的預設組成部分，所述目標系統存活指所述目標系統處于正常接收數據的狀態；

若所述目標系統滿足所述預設存活條件，從所述內存中讀取所述數據，并將所述數據轉發至所述目標系統，以實現所述數據采集；

若所述目標系統不滿足所述預設存活條件，從所述內存中讀取所述數據，并將所述數據轉發至預設存儲器進行暫存，待后續所述目標系統可用時，將所述數據轉發至所述目標系統，以實現所述數據采集；

所述判斷數據接收方所對應的目標系統是否滿足預設存活條件的步驟包括：

按照預設周期，通過心跳方式與數據接收方所對應的目標系統進行確認以判斷所述目標系統是否存活；

若根據心跳反饋判斷與所述目標系統連接不正常，判定所述目標系統未存活；

若判定所述目標系統未存活，且與所述目標系統進行確認的次數超過預設次數，判定所述目標系統不滿足所述預設存活條件；

其中，所述通過心跳方式與數據接收方所對應的目標系統進行確認以判斷所述目標系統是否存活，包括：

向所述目標系統發送自定義數據包，并接收所述目標系統的心跳反饋。

2.根據權利要求1所述數據采集方法，其特征在于，所述從所述內存中讀取所述數據，并將所述數據轉發至預設存儲器進行暫存的步驟之后，還包括：

按照所述預設周期繼續判斷所述目標系統是否滿足所述預設存活條件；

若所述目標系統滿足所述預設存活條件，從所述預設存儲器中讀取所述數據，并將所述數據發送至所述目標系統，且啟動將所述內存中包含的數據繼續追加至所述預設存儲器中。

3.根據權利要求2所述數據采集方法，其特征在于，所述從所述預設存儲器中讀取所述數據，并將所述數據發送至所述目標系統，且啟動將所述內存中包含的數據繼續追加至所述預設存儲器中的步驟之后，還包括：

判斷所述預設存儲器中包含的數據發送至所述目標系統是否發送完畢；

若所述預設存儲器中包含的所述數據發送至所述目標系統發送完畢，將從所述預設存儲器中讀取數據切換至從所述內存中讀取數據，并將從所述內存中讀取的所述數據轉發至所述目標系統。

4.根據權利要求2所述數據采集方法，其特征在于，所述將所述數據發送至所述目標系統的步驟包括：

通過零拷貝方式將所述數據發送至所述目標系統。

5.一種數據采集裝置，其特征在于，包括：

獲取單元，用于獲取外部數據源的數據，并將所述數據存入內存中；

第一判斷單元，用于判斷數據接收方所對應的目標系統是否滿足預設存活條件，所述目標系統指數據采集系統中包含的接收所采集的數據的預設組成部分，所述目標系統存活指所述目標系統處于正常接收數據的狀態；

第一轉發單元，用于若所述目標系統滿足所述預設存活條件，從所述內存中讀取所述數據，并將所述數據轉發至所述目標系統，以實現所述數據采集；

暫存單元，用于若所述目標系統不滿足所述預設存活條件，從所述內存中讀取所述數據，并將所述數據轉發至預設存儲器進行暫存，待后續所述目標系統可用時，將所述數據轉發至所述目標系統，以實現所述數據采集；

所述第一判斷單元包括：

判斷子單元，用于按照預設周期，通過心跳方式與數據接收方所對應的目標系統進行確認以判斷所述目標系統是否存活；

第一判定子單元，用于若根據心跳反饋判斷與所述目標系統連接不正常，判定所述目標系統未存活；

第二判定子單元，用于若判定所述目標系統未存活，且與所述目標系統進行確認的次數超過預設次數，判定所述目標系統不滿足所述預設存活條件；

其中，所述通過心跳方式與數據接收方所對應的目標系統進行確認以判斷所述目標系統是否存活，包括：

向所述目標系統發送自定義數據包，并接收所述目標系統的心跳反饋。