[發明專利]基于配置孿生同步方法、物聯網系統和設備及存儲介質

有效

• 申請號: 202110678715.2
• 申請日: 2021-06-18
• 公開（公告）號: CN113259480B
• 公開（公告）日: 2021-09-24
• 發明（設計）人: 江天捷;劉能;曾富來
• 申請（專利權）人: 合安科技技術有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G16Y10/75
• 代理公司: 深圳君信誠知識產權代理事務所(普通合伙) 44636
• 代理人: 劉偉

1.一種基于配置孿生同步方法，其應用于物聯網，所述物聯網包括云端服務器和可與所述云端服務器通信連接的邊端服務器設備，其特征在于，該方法包括如下步驟：

步驟S1、定義配置孿生處理框架，并將所述配置孿生處理框架設置于所述物聯網中，定義所述配置孿生處理框架具體包括定義配置孿生同步處理器、定義邊緣設備處理器、定義配置孿生注解以及定義配置孿生切面；

其中，所述配置孿生同步處理器用于處理每種需要同步的數據所對應的插件程序，定義所述邊緣設備處理器用于處理根據每種需要同步的數據編寫的并從該數據中提取和計算出的將所述邊端服務器設備同步的插件程序，定義所述配置孿生注解用于處理數據修改后自動觸發所述云端服務器和所述邊端服務器設備同步數據，定義所述配置孿生切面用于在所有需要同步的數據修改時，使得所述云端服務器和所述邊端服務器設備同步數據；

所述步驟S1中：

所述孿生同步處理器包括多個且均定義相同的孿生同步處理器的接口，所述孿生同步處理器的接口包括讀取列表、讀取單個、存儲數據對象以及存儲深度同步標識；

所述邊緣設備處理器包括多個且均定義相同的邊緣設備處理器的接口，所述邊緣設備處理器的接口包括獲取所述邊端服務器設備的數據對象；

所述孿生注解包括多個，在對每種需要同步的數據進行修改的方法上標注與其相對應的一個所述孿生注解，所述孿生注解包括目標編碼的注解、目標主鍵字段的注解以及所述邊緣設備處理器的注解；

所述孿生切面在所有需要同步的數據修改的方法中通過預設的切面算法生效；

所述步驟S1中，所述切面算法具體包括如下步驟：

步驟S11、獲取用于用戶調用系統的調用方法，所述調用方法為所述云端服務器和所述邊端服務器設備共用的方法；

步驟S12、根據獲取的所述調用方法獲取與其相對應的所述配置孿生注解，并判斷所述配置孿生注解是否存在：

若所述配置孿生注解不存在，則將所述孿生切面進行終止處理；

若所述配置孿生注解存在，則獲取所述配置孿生注解并啟動發送所述同步數據；

所述步驟S12中，所述啟動發送所述同步數據具體包括如下步驟：

步驟S121、根據所述目標主鍵字段的注解獲取所述同步數據中的與所述目標主鍵字段相對應的目標主鍵；

步驟S122、判斷觸發所述孿生切面的一端是否為所述云端服務器，若是，則按照所述邊緣設備處理器的注解進行配置所述邊緣設備處理器，所述邊緣設備處理器調用與其對應的所述插件程序，并根據所述插件程序計算出與其對應的所述邊端服務器設備；

步驟S123、根據所述目標編碼的注解中配制所述同步數據的種類中獲取所述配置孿生同步處理器，再調用所獲取的所述配置孿生同步處理器的插件程序中讀取單個的方法，根據該方法和所述同步數據共同按照預設算法生成配置孿生交互格式數據，并將所述配置孿生交互格式數據發送至未觸發所述孿生切面的一端；

其中，所述配置孿生交互格式數據包括目標列表和目標數據列表，所述目標列表為根據存儲先后次序列出同步的所述目標編碼的列表，所述目標數據列表為根據每個所述目標編碼列出同步的數據列表；

步驟S2、定義配置孿生范圍，并將所述配置孿生范圍設置于所述物聯網中，所述配置孿生范圍用于定義每種需要同步的數據的目標編碼、所述配置孿生同步處理器以及同步次序；

步驟S3、所述邊端服務器設備通過所述物聯網與所述云端服務器首次通信連接時，所述邊端服務器設備根據所述配置孿生處理框架將所述云端服務器在所述配置孿生范圍內的所有數據進行同步；

所述步驟S3中，包括如下步驟：

步驟S31、所述邊端服務器設備生成注冊請求并將其發送至所述云端服務器；

步驟S32、所述云端服務器接收所述注冊請求，同步次序獲取所述配置孿生范圍中的所有目標；

步驟S33、所述云端服務器將所有目標逐個提取出同步目標；

步驟S34、所述云端服務器獲取所述同步目標中的所述配置孿生同步處理器，通過調用所述孿生同步處理器的接口中的所述讀取列表的方法，以獲得所述同步目標中所有的同步數據列表，所述同步數據列表為單個數據種類的必須同步的數據列表；

步驟S35、所述云端服務器獲取所述同步目標中的所述目標編碼，并將獲取的所述目標編碼加入至所述目標列表；

步驟S36、所述云端服務器將所述同步數據列表根據所述目標編碼加入至所述目標數據列表；

步驟S37、重復步驟S33至步驟S36，直至所有目標均完成生成所述配置孿生交互格式數據；

步驟S38、所述云端服務器將所述配置孿生交互格式數據發送至所述邊端服務器設備；

步驟S39、所述邊端服務器設備接收所述配置孿生交互格式數據；

步驟S310、所述邊端服務器設備在所述配置孿生交互格式數據的所述目標列表中提取所述同步目標中的所述目標編碼；

步驟S311、所述邊端服務器設備在所述配置孿生交互格式數據的所述目標數據列表中提取所有的所述同步數據列表；

步驟S312、所述邊端服務器設備在預置的所述配置孿生范圍的數據中獲取所述目標編碼相對應的所述同步目標；

步驟S313、所述邊端服務器設備獲取所述同步目標的孿生同步處理器，根據獲取的所述同步目標的孿生同步處理器進行配置所述邊端服務器設備的孿生同步處理器；

步驟S314、所述邊端服務器設備在提取的所述同步數據列表中逐個提取同步數據；

步驟S315、所述邊端服務器設備調用所述孿生同步處理器的插件程序中存儲的非深度同步的數據，并將該數據存儲于所述同步數據；

步驟S316、重復步驟S314至步驟S315，直至所有的所述同步數據列表完成處理；

步驟S317、重復步驟S310至步驟S316，直至所有的所述目標列表完成處理；

步驟S4、所述邊端服務器設備與所述云端服務器已通信連接，所述邊端服務器設備或所述云端服務器的數據發生變更時，所述邊端服務器設備或所述云端服務器觸發配置孿生切面，并將變更的數據同步至所述云端服務器或所述邊端服務器設備；

所述步驟S4中，包括如下步驟：

步驟S41、所述邊端服務器設備或所述云端服務器觸發配置孿生切面，進入所述步驟S11至所述步驟S12；

步驟S42、所述云端服務器或所述邊端服務器設備接收所述配置孿生交互格式數據；

步驟S43、所述云端服務器或所述邊端服務器設備在所述配置孿生交互格式數據的所述目標列表中提取目標編碼；

步驟S44、所述云端服務器或所述邊端服務器設備在所述配置孿生交互格式數據的所述目標數據列表中提取所有的所述同步數據列表；

步驟S45、所述云端服務器或所述邊端服務器設備在預置的所述配置孿生范圍的數據中獲取所述目標編碼相對應的所述同步目標；

步驟S46、所述云端服務器或所述邊端服務器設備獲取所述同步目標的孿生同步處理器，根據獲取的所述孿生同步處理器進行配置所述云端服務器或所述邊端服務器設備的孿生同步處理器；

步驟S47、所述云端服務器或所述邊端服務器設備在提取的所述同步數據列表中逐個提取同步數據；

步驟S48、所述云端服務器或所述邊端服務器設備調用所述孿生同步處理器的插件程序中存儲的深度同步的數據，并將該數據存儲于所述同步數據；

所述步驟S48包括如下步驟：

步驟S481、判斷深度同步時校驗數據的屬性數據是否存在，若是，則進入步驟S49，若否，則所述云端服務器或所述邊端服務器設備生成請求指定目標對象的請求指令，并將所述請求指令發送至所述邊端服務器設備或所述云端服務器；

步驟S482、所述邊端服務器設備或所述云端服務器接收所述請求指令，并進入所述步驟S43；

步驟S49、重復步驟S47至步驟S48，直至所有的所述同步數據列表完成處理；

步驟S410、重復步驟S43至步驟S49，直至所有的所述目標列表完成處理。