[發明專利]一種基于時間桶的地鐵綜合監控系統時間序列觸發方法

有效

• 申請號: 201510595939.1
• 申請日: 2015-09-17
• 公開（公告）號: CN105227648B
• 公開（公告）日: 2018-05-18
• 發明（設計）人: 朱超;經玉健;翁元;吳小俊
• 申請（專利權）人: 南京國電南自軌道交通工程有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08
• 代理公司: 南京知識律師事務所 32207
• 代理人: 張蘇沛

1.一種基于時間桶的地鐵綜合監控系統時間序列觸發方法，其特征在于：

第一步：專業子系統通過函數調用與注冊單元建立主從關系，專業子系統即客戶端、模型即服務端；注冊單元據此開辟雙方數據交換空間，分為注冊數據區和消息數據區：注冊數據區存放負責客戶端到服務端的注冊請求，消息數據區存放服務端到客戶端的在各時間節點的即時觸發消息；

第二步：客戶端發送在線注冊請求至模型注冊數據區，注冊信息包含客戶端使用者名稱、起止日期、時間、多個時間節點、執行間隔和循環模式信息；模型的注冊單元接收該請求，并檢測數據邏輯合法性，再將信息轉發給資源管理單元，由其負責分配時間桶資源和加入桶隊列；

第三步：資源管理單元在桶池中為新請求選用專屬時間桶，并為時間桶貼上第二步驟中的注冊信息項標簽；同時將新時間桶加入到檢測隊列尾部，供檢測單元使用；

第四步：全局定時單元定時向檢測單元發送檢測指令；

第五步：檢測單元據檢測指令逐一掃描桶隊列中每一時間桶的狀態及其數據標簽，維護桶內的剩余時間；當某個時間節點到達時，將觸發消息送達消息處理單元，同時繼續向桶注入距下一時間節點的時長；

第六步：消息處理單元根據客戶名稱找到對應消息數據區，寫入觸發通知及包含時間序列索引的附加信息；

第七步：客戶端獲得觸發通知及附加信息，根據自身的邏輯需求執行對應的系統控制命令；

第八步：重復四～七步，直至時間桶到達桶底或客戶端提出解注冊請求，此時時間桶已作廢，空桶釋放回桶池交由資源管理單元處理；

第九步：客戶端通過函數調用向模型注冊數據區發送在線解注冊請求，結束觸發控制，解除二者間的聯系，釋放資源。

2.根據權利要求1所述的基于時間桶的地鐵綜合監控系統時間序列觸發方法，其特征在于，所述注冊單元：

外部系統注冊時調用模型的接口函數ts_CreateClient創建一個注冊客戶端，該函數包含注冊名稱和緩沖大小兩個參數；注冊單元檢查注冊名稱的唯一性，已存在的名稱將被注冊單元拒絕；通過檢查后注冊單元為其開辟指定大小的注冊數據區和消息數據區，其后數據交互即在兩個區域內進行；

外部系統調用模型的接口函數ts_RegisterRequests向注冊單元提交具體的時序控制需求組，其參數為一組包含詳細時序信息的結構體ts_REQINFO組；

完成注冊后，客戶端調用ts_WaitForNotifications阻塞式等待模型消息單元的觸發消息，一旦等待被激活，則處理觸發消息，向各自專業子系統下發控制命令；該阻塞行為具有超時時間設置，當超時動作先行發生時，給等待執行體執行其他必要動作的機會，待完成后重新進入等待狀態；

客戶端根據需要在注冊后的途中暫停或啟用模型的觸發工作以期與自身的工作進度相配合；

當客戶端認為時序控制任務已結束時，調用ts_UnRegisterRequests向注冊單元提交具體的解注冊請求，注冊單元負責銷毀數據區歸還系統資源。

3.根據權利要求2所述的基于時間桶的地鐵綜合監控系統時間序列觸發方法，其特征在于：每個結構體的數據項包括：

客戶名稱：對應時間桶的擁有者；

起始時間：即時間序列觸發的生效開始的日期+時間，早于該時間節點將不會觸發任何消息；對應時間桶刻度為桶頂；其中的時間部分數據用作每日的起始時間限制；

終止時間：即時間序列觸發的生效結束日期+時間，晚于該時間節點將不再觸發任何消息；對應時間桶刻度為桶底；其中的時間部分數據用作每日的終止時間限制；

工作日設定：即時間序列觸發的生效工作日數組；

時間序列數組：一組時間節點數據；

時間序列數組元素個數；

時間單位：模型以定時單元的觸發時間為基礎單位，把時間序列數組中的數值參照此單位做統一計算預處理；

循環次數：時間序列在桶內循環觸發的次數；

備用上下文數據指針：注冊時提供的額外輔助信息，做數據傳遞用，在消息觸發返回客戶端時由客戶端自行解釋使用。

4.根據權利要求1所述的基于時間桶的地鐵綜合監控系統時間序列觸發方法，其特征在于：所述資源管理單元是數據結構時間桶池和時間桶隊列的管理者，其接收注冊單元的注冊需求，分配桶資源，并將任務加入到桶調度隊列。