[發(fā)明專利]用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺及方法

有效

• 申請?zhí)枺?/td>: 202210925105.2
• 申請日: 2022-08-03
• 公開（公告）號: CN115277836B
• 公開（公告）日: 2023-05-30
• 發(fā)明（設(shè)計）人: 王昆;姜海洋;陳啟均
• 申請（專利權(quán)）人: 四川長虹新網(wǎng)科技有限責(zé)任公司
• 主分類號: H04L67/55
• 分類號: H04L67/55;H04L67/1004;H04L67/12;H04L67/146;G08G1/14;G08G1/042
• 代理公司: 成都虹橋?qū)＠聞?wù)所(普通合伙) 51124
• 代理人: 陳春光

1.用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺，其特征在于，包括：

地磁設(shè)備管理模塊，用于接收地磁設(shè)備發(fā)送的地磁數(shù)據(jù)，根據(jù)所述地磁數(shù)據(jù)生成對應(yīng)的數(shù)據(jù)推送任務(wù)并將其發(fā)送至地磁數(shù)據(jù)推送模塊，所述數(shù)據(jù)推送任務(wù)中至少包括待推送的地磁數(shù)據(jù)及其對應(yīng)業(yè)務(wù)平臺ID，以及該數(shù)據(jù)推送任務(wù)的鎖競爭標志和完成標志；

地磁數(shù)據(jù)推送模塊，包括任務(wù)管理模塊以及配置有對應(yīng)時間窗口的多個推送服務(wù)器，所述任務(wù)管理模塊用于接收數(shù)據(jù)推送任務(wù)；所述推送服務(wù)器用于在對應(yīng)的時間窗口內(nèi)，根據(jù)所述鎖競爭標志和完成標志查詢數(shù)據(jù)推送任務(wù)，針對查詢到的數(shù)據(jù)推送任務(wù)，修改其鎖競爭標志進行鎖定，并根據(jù)所述業(yè)務(wù)平臺ID將其中的地磁數(shù)據(jù)推送至對應(yīng)的業(yè)務(wù)平臺；

所述多個推送服務(wù)器被劃分至多個推送任務(wù)組，每個推送任務(wù)組配置有至少兩個推送服務(wù)器；

所述任務(wù)管理模塊還用于確定各推送服務(wù)器的負載狀態(tài)，根據(jù)所述負載狀態(tài)將數(shù)據(jù)推送任務(wù)均衡分配至各推送任務(wù)組，并在各數(shù)據(jù)推送任務(wù)中添加對應(yīng)推送任務(wù)組的編號；

所述推送服務(wù)器還用于在對應(yīng)的時間窗口內(nèi)，根據(jù)所述鎖競爭標志和完成標志以及對應(yīng)推送任務(wù)組的編號查詢對應(yīng)推送任務(wù)組的數(shù)據(jù)推送任務(wù)。

2.如權(quán)利要求1所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺，其特征在于，每個推送任務(wù)組配置有第一推送服務(wù)器和第二推送服務(wù)器，所述第一推送服務(wù)器對應(yīng)的時間窗口為：每分鐘的第0秒開始啟動任務(wù)，并且每隔2秒循環(huán)執(zhí)行一次，所述第二推送服務(wù)器對應(yīng)的時間窗口為：每分鐘的第1秒開始啟動任務(wù)，并且每隔2秒循環(huán)執(zhí)行一次。

3.如權(quán)利要求1所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺，其特征在于，所述推送服務(wù)器具體用于查詢鎖競爭標志和完成標志均為0的數(shù)據(jù)推送任務(wù)，所述鎖競爭標志為0表示對應(yīng)的數(shù)據(jù)推送任務(wù)未被推送服務(wù)器鎖定，所述完成標志為0表示對應(yīng)的數(shù)據(jù)推送任務(wù)未完成。

4.如權(quán)利要求1所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺，其特征在于，所述數(shù)據(jù)推送任務(wù)中還包括完成任務(wù)的推送服務(wù)器ID、任務(wù)完成時間和反饋信息；

推送服務(wù)器將地磁數(shù)據(jù)推送至業(yè)務(wù)平臺后，所述地磁設(shè)備管理模塊還用于接收業(yè)務(wù)平臺返回的信息，以及在收到返回的信息后更新對應(yīng)數(shù)據(jù)推送任務(wù)中的完成標志、完成任務(wù)的推送服務(wù)器ID、任務(wù)完成時間和反饋信息。

5.用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送方法，其特征在于，應(yīng)用于如權(quán)利要求1至4任一項所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送平臺，包括以下步驟：

地磁設(shè)備管理模塊接收地磁設(shè)備發(fā)送的地磁數(shù)據(jù)，并根據(jù)所述地磁數(shù)據(jù)生成對應(yīng)的數(shù)據(jù)推送任務(wù)并將其發(fā)送至地磁數(shù)據(jù)推送模塊，所述數(shù)據(jù)推送任務(wù)中至少包括待推送的地磁數(shù)據(jù)及其對應(yīng)業(yè)務(wù)平臺ID，以及該數(shù)據(jù)推送任務(wù)的鎖競爭標志和完成標志；

任務(wù)管理模塊接收數(shù)據(jù)推送任務(wù)；推送服務(wù)器在對應(yīng)的時間窗口內(nèi)，根據(jù)所述鎖競爭標志和完成標志查詢數(shù)據(jù)推送任務(wù)，針對查詢到的數(shù)據(jù)推送任務(wù)，修改其鎖競爭標志進行鎖定，并根據(jù)所述業(yè)務(wù)平臺ID將其中的地磁數(shù)據(jù)推送至對應(yīng)的業(yè)務(wù)平臺；

所述多個推送服務(wù)器被劃分至多個推送任務(wù)組，每個推送任務(wù)組配置有至少兩個推送服務(wù)器；

所述任務(wù)管理模塊還用于確定各推送服務(wù)器的負載狀態(tài)，根據(jù)所述負載狀態(tài)將數(shù)據(jù)推送任務(wù)均衡分配至各推送任務(wù)組，并在各數(shù)據(jù)推送任務(wù)中添加對應(yīng)推送任務(wù)組的編號；

所述推送服務(wù)器還用于在對應(yīng)的時間窗口內(nèi)，根據(jù)所述鎖競爭標志和完成標志以及對應(yīng)推送任務(wù)組的編號查詢對應(yīng)推送任務(wù)組的數(shù)據(jù)推送任務(wù)。

6.如權(quán)利要求5所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送方法，其特征在于，每個推送任務(wù)組配置有第一推送服務(wù)器和第二推送服務(wù)器，所述第一推送服務(wù)器對應(yīng)的時間窗口為：每分鐘的第0秒開始啟動任務(wù)，并且每隔2秒循環(huán)執(zhí)行一次，所述第二推送服務(wù)器對應(yīng)的時間窗口為：每分鐘的第1秒開始啟動任務(wù)，并且每隔2秒循環(huán)執(zhí)行一次。

7.如權(quán)利要求5所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送方法，其特征在于，所述推送服務(wù)器具體查詢鎖競爭標志和完成標志均為0的數(shù)據(jù)推送任務(wù)，所述鎖競爭標志為0表示對應(yīng)的數(shù)據(jù)推送任務(wù)未被推送服務(wù)器鎖定，所述完成標志為0表示對應(yīng)的數(shù)據(jù)推送任務(wù)未完成。

8.如權(quán)利要求5所述的用于地磁停車系統(tǒng)的分布式數(shù)據(jù)推送方法，其特征在于，所述數(shù)據(jù)推送任務(wù)中還包括完成任務(wù)的推送服務(wù)器ID、任務(wù)完成時間和反饋信息，該方法還包括：

推送服務(wù)器將地磁數(shù)據(jù)推送至業(yè)務(wù)平臺后，所述地磁設(shè)備管理模塊接收業(yè)務(wù)平臺返回的信息，以及在收到返回的信息后更新對應(yīng)數(shù)據(jù)推送任務(wù)中的完成標志、完成任務(wù)的推送服務(wù)器ID、任務(wù)完成時間和反饋信息。