[發(fā)明專利]一種適用于證券交易監(jiān)管業(yè)務的分布式調度方法

在審

• 申請?zhí)枺?/td>: 202210875168.1
• 申請日: 2022-07-25
• 公開（公告）號: CN115202844A
• 公開（公告）日: 2022-10-18
• 發(fā)明（設計）人: 邢為之;何賢國;何格;樓曉鴻
• 申請（專利權）人: 上交所技術有限責任公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F11/30;G06Q40/04
• 代理公司: 上海三方專利事務所(普通合伙) 31127
• 代理人: 吳瑋

1.一種適用于證券交易監(jiān)管業(yè)務的分布式調度方法，其特征在于：所述調度方法采用數據時間作為調度觸發(fā)的依據，計算不同業(yè)務數據通道中的數據時間，還設計了通道數據時間過期邏輯和待執(zhí)行算法實施例表，最后采取了分布式集群的運行模式，具體如下：

T1.系統(tǒng)啟動時為每個交易數據通道初始化為一組數據，所述一組數據包括最大入庫時間、最大入庫時間對應的數據時間、查詢到最大入庫時間對應的系統(tǒng)時間和通道的狀態(tài)，其中所述最大入庫時間表示通道的最大入庫時間，初始值為0；最大入庫時間對應的數據時間初始值也為0；查詢到最大入庫時間對應的系統(tǒng)時間初始值為當前系統(tǒng)時間；通道的狀態(tài)中0為無效，1為有效，初始值為1；

T2.系統(tǒng)啟動時初始化全局數據時間T為0；

T3.從寫入數據庫的交易數據中查詢每個通道最大入庫時間和對應的最大數據時間；

T4.比較最大入庫時間與每個通道最大入庫時間是否相等，若不相等，則更新最大入庫時間為每個通道最大入庫時間，更新最大入庫時間對應的數據時間為對應的最大數據時間，更新查詢到最大入庫時間對應的系統(tǒng)時間為當前系統(tǒng)時間；

T5.計算當前系統(tǒng)時間與查詢到最大入庫時間對應的系統(tǒng)時間的時間差，若時間差超過1分鐘則將通道的狀態(tài)更新為0；

T6.選取通道的狀態(tài)不為0的通道，從這些通道中計算臨時數據時間；

T7.若臨時數據時間值大于全局數據時間T值，則更新全局數據時間T值為臨時數據時間。

2.如權利要求1所述的一種適用于證劵交易監(jiān)管業(yè)務的分布式調度方法，其特征在于所述具體方法如下：

S1.調度節(jié)點啟動時創(chuàng)建心跳維護線程，該線程獲取主機的IP以及進程PID，心跳維護線程運行時，循環(huán)將主機IP、進程PID、當前時間戳三個字段寫入數據庫心跳信息表；

S2.調度節(jié)點啟動時創(chuàng)建心跳監(jiān)測線程，該線程循環(huán)從心跳信息表中查詢所有調度節(jié)點實例信息，并判斷每個調度節(jié)點的心跳數據是否超時；

S3.調度節(jié)點啟動時開啟交易日更新輪詢任務，該任務從數據庫查詢當前交易日信息，并將其更新到內存中；

S4.調度節(jié)點啟動時開啟算法運行實例更新輪詢任務，該任務查詢待執(zhí)行算法實例表中當前交易日的算法對應的算法運行實例是否生成，若某個算法的運行實例未生成，則根據算法配置數據生成算法運行實例并寫入待執(zhí)行算法實例表；

S5.系統(tǒng)啟動時創(chuàng)建調度線程用于算法運行實例調度，該線程首先創(chuàng)建線程池用于算法運行實例異步執(zhí)行，后續(xù)執(zhí)行調度線程循環(huán)。

3.如權利要求2所述的一種適用于證券交易監(jiān)管業(yè)務的分布式調度方法，其特征在于所述后續(xù)執(zhí)行調度線程循環(huán)的循環(huán)步驟如下：

E1.查詢算法運行實例執(zhí)行線程池中剩余可用資源，若無剩余可用資源，跳過本次循環(huán)；

E2.查詢當前可執(zhí)行的算法實例。

4.如權利要求3所述的一種適用于證劵交易監(jiān)管業(yè)務的分布式調度方法，其特征在于所述查詢當前可執(zhí)行的算法實例包括

D1.查詢當前業(yè)務時間；

D2.查詢可執(zhí)行的算法實例，根據全局數據時間T在待執(zhí)行算法實例表中查詢可執(zhí)行的算法運行實例；

D3.遍歷查詢到的算法實例，對每個算法實例執(zhí)行以下操作：

D4.算法實例執(zhí)行完成后，將待執(zhí)行算法實例表中該算法實例狀態(tài)更新為成功。