[發(fā)明專利]數(shù)據(jù)傳輸方法、裝置、電子設(shè)備及存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011003844.3
• 申請日: 2020-09-22
• 公開（公告）號: CN112134951A
• 公開（公告）日: 2020-12-25
• 發(fā)明（設(shè)計）人: 曹如海;李強;張煒;宣月波
• 申請（專利權(quán)）人: 睿視(蘇州)視頻科技有限公司;蘇州科達科技股份有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 蘇州謹(jǐn)和知識產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙) 32295
• 代理人: 葉棟

1.一種數(shù)據(jù)傳輸方法，其特征在于，包括：

提供本地開放的資源類型，所述資源類型與資源來源對應(yīng)；

接收對至少一個目標(biāo)資源類型的資源注冊請求，所述資源注冊請求與資源接收口對應(yīng)；

基于所述資源注冊請求，確定所述目標(biāo)資源類型對應(yīng)的目標(biāo)資源來源；

從所述目標(biāo)資源來源中提取出實時數(shù)據(jù)；

向至少一個所述資源接收口推送所述實時數(shù)據(jù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述向至少一個所述資源接收口推送所述實時數(shù)據(jù)，包括：

基于所述資源注冊請求，確定所述至少一個資源接收口的狀態(tài)信息，所述狀態(tài)信息包括正常、重試、異常以及恢復(fù)中的一種；

根據(jù)所述至少一個資源接收口的狀態(tài)信息，向至少一個所述資源接收口推送所述實時數(shù)據(jù)。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述根據(jù)至少一個所述資源接收口的狀態(tài)信息，向至少一個所述資源接收口推送所述實時數(shù)據(jù)，包括：

收集資源接收口的狀態(tài)信息為正常狀態(tài)的資源接收口；

利用至少一個線程將所述實時數(shù)據(jù)并行推送給正常狀態(tài)的資源接收口；

判斷預(yù)設(shè)線程的推送是否異常；

當(dāng)所述預(yù)設(shè)線程的推送異常時，停止所述預(yù)設(shè)線程的實時數(shù)據(jù)推送并將所述預(yù)設(shè)線程對應(yīng)的資源接收口的狀態(tài)信息設(shè)置為重試；

基于重試狀態(tài)的資源接收口進行對應(yīng)于重試模式的數(shù)據(jù)推送；

或，

所述根據(jù)至少一個所述資源接收口的狀態(tài)信息，向至少一個所述資源接收口推送所述實時數(shù)據(jù)，包括：

收集資源接收口的狀態(tài)信息為重試狀態(tài)的資源接收口；

停止向所述重試狀態(tài)的資源接收口推送實時數(shù)據(jù)并將所述資源接收口的狀態(tài)信息設(shè)置為重試；

基于重試狀態(tài)的資源接收口進行對應(yīng)于重試模式的數(shù)據(jù)推送。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述基于重試狀態(tài)的資源接收口進行對應(yīng)于重試模式的數(shù)據(jù)推送，包括：

另開線程向所述重試狀態(tài)的資源接收口再次推送當(dāng)前推送失敗的數(shù)據(jù)；

判斷在預(yù)設(shè)條件內(nèi)向所述重試狀態(tài)的資源接收口是否成功推送所述當(dāng)前推送失敗的數(shù)據(jù)；

當(dāng)在預(yù)設(shè)條件內(nèi)向所述重試狀態(tài)的資源接收口成功推送所述當(dāng)前推送失敗的數(shù)據(jù)時，將所述重試狀態(tài)的資源接收口的狀態(tài)信息設(shè)置為恢復(fù)中；

基于所述恢復(fù)中的資源接收口進行對應(yīng)于恢復(fù)中模式的數(shù)據(jù)推送；

或，

當(dāng)在預(yù)設(shè)條件內(nèi)向所述重試狀態(tài)的資源接收口并未成功推送所述當(dāng)前推送失敗的數(shù)據(jù)時，將所述重試狀態(tài)的資源接收口的狀態(tài)設(shè)置為異常；

基于異常狀態(tài)的資源接收口進行對應(yīng)于異常模式的數(shù)據(jù)推送。

5.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述根據(jù)至少一個所述資源接收口的狀態(tài)信息，向至少一個所述資源接收口推送所述實時數(shù)據(jù)，包括：

收集資源接收口的狀態(tài)信息為恢復(fù)中的資源接收口；

基于所述恢復(fù)中的資源接收口進行對應(yīng)于恢復(fù)中模式的數(shù)據(jù)推送。

6.根據(jù)權(quán)利要求4或5所述的方法，其特征在于，所述資源注冊請求中還攜帶有配置信息，所述基于所述恢復(fù)中的資源接收口進行對應(yīng)于恢復(fù)中模式的數(shù)據(jù)推送，包括：

提取所述恢復(fù)中的資源接收口的配置信息；

基于所述配置信息判斷是否需要推送中斷的數(shù)據(jù)；

當(dāng)需要推送中斷的數(shù)據(jù)時，讀取從中斷位置至當(dāng)前位置之間的歷史數(shù)據(jù)；

將所述歷史數(shù)據(jù)推送至所述恢復(fù)中的資源接收口，并在推送過程中判斷是否出現(xiàn)推送失敗；

當(dāng)沒有出現(xiàn)推送失敗時，將所述恢復(fù)中的資源接收口的狀態(tài)信息設(shè)置為正常；

基于正常狀態(tài)的資源接收口進行對應(yīng)于正常模式的數(shù)據(jù)推送。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述基于所述恢復(fù)中的資源接收口進行對應(yīng)于恢復(fù)中模式的數(shù)據(jù)推送，包括：

當(dāng)出現(xiàn)推送失敗時，將所述恢復(fù)中的資源接收口的狀態(tài)信息設(shè)置為異常，基于異常狀態(tài)的資源接收口進行對應(yīng)于異常模式的數(shù)據(jù)推送。