[發明專利]復雜任務流程邏輯的動態切割方法、節點及存儲介質

在審

• 申請號: 202010147094.0
• 申請日: 2020-03-05
• 公開（公告）號: CN111414251A
• 公開（公告）日: 2020-07-14
• 發明（設計）人: 姚宏宇
• 申請（專利權）人: 北京友友天宇系統技術有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48
• 代理公司: 北京臻之知識產權代理有限公司 11629
• 代理人: 趙福梅

本發明公開了一種復雜任務流程邏輯的動態切割方法、節點及計算機可讀存儲介質，所述方法應用于子網內的其中一個節點，包括：與所述子網內的其他節點進行選舉，獲得第一選舉結果；當所述第一選舉結果選舉為自身為主節點時，確定自身為主節點；根據指定任務確定多個拆分任務，發送對應所述拆分任務的任務處理指令至所述子網內的其他節點；接收來所述所述子網內的其他節點的任務處理結果；將所述任務處理結果進行合并，獲得對應所述指定任務的目標結果。應用本發明實施例提供的方法，能夠實現數據處理的高可靠、高可用和彈性擴展。

技術領域

本發明涉及數據處理技術領域，尤其涉及一種復雜任務流程邏輯的動態切割方法、節點及計算機可讀存儲介質。

背景技術

為了提供精密位置服務，將當前全球衛星導航系統(the Global NavigationSatellite System，GNSS)的架構分為三層：數據接入與分發管理、GNSS數據處理、用戶按需定制服務。其中，基準站用于實現數據接入，隨著基準站的不斷建設和大量流動站的接入，可以獲得更多的基準站數據，通過算法的調整可以計算出更精密的位置信息。

一般情況下，GNSS在任務計算時，根據各節點的計算能力，將基站網劃分為多個子網，用以提高計算性能。在單個子網內，經常會涉及到大規模的復雜任務運算，如矩陣運算，需要對數據處理任務進行分布式合理的集群管理以保障任務處理的高可用性。

發明內容

本發明實施例提供了一種復雜任務流程邏輯的動態切割方法、節點及計算機可讀存儲介質，能夠實現數據處理計算任務的高可用性。

本發明一方面提供一種復雜任務流程邏輯的動態切割方法，所述方法應用于子網內的其中一個節點，包括：與所述子網內的其他節點進行選舉，獲得第一選舉結果；當所述第一選舉結果選舉為自身為主節點時，確定自身為主節點；根據指定任務確定多個拆分任務，發送對應所述拆分任務的任務處理指令至所述子網內的其他節點；接收來所述所述子網內的其他節點的任務處理結果；將所述任務處理結果進行合并，獲得對應所述指定任務的目標結果。

在一可實施方式中，所述方法還包括：當所述第一選舉結果選舉為所述子網內的其他節點中任一個為主節點時，確定自身為從節點；接收來自所述主節點的任務處理指令，所述任務處理指令用于指示處理拆分任務；對所述拆分任務進行處理，獲得任務處理結果；將所述任務處理結果發送至所述主節點。

在一可實施方式中，當確定自身為從節點時，所述方法還包括：檢測所述主節點是否正常運行，獲得檢測結果；當所述檢測結果為所述主節點無法正常運行時，接收所述指定任務；與所述子網內的其他節點重新進行選舉，獲得第二選舉結果；基于所述第二選舉結果重新對所述指定任務進行處理。

在一可實施方式中，所述對所述拆分任務進行處理，獲得任務處理結果，包括：同步來自主節點的任務數據，所述任務數據對應所述拆分任務；其中，所述任務數據來自LMDB數據庫；基于所述任務數據對所述拆分任務進行計算處理，獲得對應所述任務數據的任務處理結果。

在一可實施方式中，在所述通過與所述子網內的其他節點進行選舉，獲得第一選舉結果之前，所述方法還包括：與所述子網內的其他節點分別接收所述指定任務。

本發明另一方面提供一種節點，所述節點為子網內的其中一個節點，包括：選舉模塊，用于與所述子網內的其他節點進行選舉，獲得第一選舉結果；確定模塊，用于當所述第一選舉結果選舉為自身為主節點時，確定自身為主節點；發送模塊，用于根據指定任務確定多個拆分任務，發送對應所述拆分任務的任務處理指令至所述子網內的其他節點；接收模塊，用于接收來所述所述子網內的其他節點的任務處理結果；合并模塊，用于將所述任務處理結果進行合并，獲得對應所述指定任務的目標結果。