[發明專利]定時業務消息生成方法、裝置、電子設備及存儲介質

在審

• 申請號: 202011118640.4
• 申請日: 2020-10-19
• 公開（公告）號: CN112256451A
• 公開（公告）日: 2021-01-22
• 發明（設計）人: 魯悅;陳超;畢申華;張哲偉;儲節節;劉磊
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/48
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 郝傳鑫;賈允

1.一種定時業務消息生成方法，其特征在于，包括：

響應于定時任務觸發指令，讀取配置文件；所述配置文件包括至少一個定時任務配置，所述定時任務配置包括消息處理邏輯標識和關聯業務參數；

在所述至少一個定時任務配置中存在與當前時間節點相匹配的目標定時任務配置時，根據所述目標定時任務配置生成中間隊列消息，將所述中間隊列消息存儲至消息隊列；

確定多個消息處理節點中的目標消息處理節點，由所述目標消息處理節點從所述消息隊列中獲取所述中間隊列消息，每個所述消息處理節點包括預置的多個消息處理邏輯；

從所述多個消息處理邏輯中確定目標消息處理邏輯，所述目標消息處理邏輯與所述中間隊列消息中的所述消息處理邏輯標識相匹配；

調用所述目標消息處理邏輯，由所述目標消息處理邏輯根據所述關聯業務參數生成待推送的定時業務消息。

2.根據權利要求1所述的定時業務消息生成方法，其特征在于，所述方法還包括：

響應于針對定時任務的配置操作，獲取配置參數；所述配置參數包括執行時間、消息處理邏輯標識和關聯業務參數；

以所述執行時間為鍵數據，與所述執行時間相對應的消息處理邏輯標識和關聯業務參數為值數據，生成所述配置文件中的所述定時任務配置。

3.根據權利要求1所述的定時業務消息生成方法，其特征在于，所述方法還包括：

獲取新增消息處理邏輯；

從所述多個消息處理節點中選取第一數量個消息處理節點作為待升級消息處理節點，所述多個消息處理節點中除所述待升級消息處理節點之外的消息處理節點作為剩余消息處理節點；

根據所述新增消息處理邏輯對所述第一數量個待升級消息處理節點進行升級；

在所述第一數量個待升級消息處理節點的升級狀態為升級完成時，將所述剩余消息處理節點作為所述多個消息處理節點，執行所述從所述多個消息處理節點中選取第一數量個消息處理節點作為待升級消息處理節點進行升級的步驟，直至不存在所述剩余消息處理節點。

4.根據權利要求3所述的定時業務消息生成方法，其特征在于，所述確定多個消息處理節點中的目標消息處理節點包括：

確定已完成升級的升級消息處理節點；

將所述升級消息處理節點和所述剩余消息處理節點作為候選消息處理節點；

從所述候選消息處理節點中選取所述目標消息處理節點。

5.根據權利要求4所述的定時業務消息生成方法，其特征在于，在將所述升級消息處理節點和所述剩余消息處理節點作為候選消息處理節點之前，所述方法還包括：

判斷所述中間隊列消息中的消息處理邏輯標識是否為新增消息處理邏輯標識；

在判斷的結果為否時，執行所述將所述升級消息處理節點和所述剩余消息處理節點作為候選消息處理節點的步驟；

在判斷的結果為是時，將所述升級消息處理節點作為所述候選消息處理節點。

6.根據權利要求1所述的定時業務消息生成方法，其特征在于，所述方法還包括：

監測所述消息隊列中所包含的中間隊列消息的消息數量；

在所述消息數量超過第一預設閾值時，確定所述消息數量與所述多個消息處理節點的節點數量之間的第一數量差值；

根據所述第一數量差值確定待增加的消息處理節點的待增節點數量；

根據所述待增節點數量增加所述多個消息處理節點的節點數量。

7.根據權利要求6所述的定時業務消息生成方法，其特征在于，所述方法還包括：

在所述消息數量小于第二預設閾值時，確定所述消息數量與所述多個消息處理節點的節點數量之間的第二數量差值；

根據所述第二數量差值確定待減少的消息處理節點的待減節點數量；

根據所述待減節點數量減少所述多個消息處理節點的節點數量。