[發明專利]一種業務調度方法、設備和存儲介質

在審

• 申請號: 201811340426.6
• 申請日: 2018-11-12
• 公開（公告）號: CN111176799A
• 公開（公告）日: 2020-05-19
• 發明（設計）人: 繆紅保
• 申請（專利權）人: 中興通訊股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京華夏泰和知識產權代理有限公司 11662
• 代理人: 孟德棟

1.一種業務調度方法，其特征在于，在調度系統側執行，包括：

在啟動系統時，為已經注冊的工作實體JOB對應創建調度任務；其中，所述JOB為業務實體根據JOB模板封裝所述業務實體的業務邏輯得到的；

接收用于發送給所述JOB的消息；

通過所述JOB對應的調度任務，將所述消息派發給所述JOB，以便所述JOB對所述消息執行邏輯處理。

2.根據權利要求1所述的方法，其特征在于，所述為已經注冊的JOB對應創建調度任務，包括：

掃描JOB注冊表中各JOB的注冊信息；

根據JOB注冊表中各JOB的注冊信息，確定歸屬關系相同的JOB；

創建調度任務，并將所述調度任務與所述歸屬關系相同的JOB進行綁定。

3.根據權利要求1所述的方法，其特征在于，通過所述JOB對應的調度任務，將所述消息派發給所述JOB，包括：

在消息收發接口接收到消息之后，查詢通信信息與所述消息的接收信息相同的JOB；

確定所述JOB對應的調度任務；

將所述消息發送給所述調度任務，并由所述調度任務將所述消息派發給所述JOB。

4.根據權利要求3所述的方法，其特征在于，

當所述調度任務對應一個JOB時，將所述消息發送給所述調度任務，并由所述調度任務將所述消息派發給所述JOB，包括：

將所述消息發送給所述調度任務的套接字，并由所述調度任務將所述套接字接收的所述消息派發給所述JOB；其中，所述套接字是所述調度任務在初始化時創建的；

當所述調度任務對應多個JOB時，將所述消息發送給所述調度任務，并由所述調度任務將所述消息派發給所述JOB，包括：

將所述消息發送給所述調度任務的套接字，由所述調度任務根據所述消息的接收信息以及所述多個JOB中的每個JOB的通信信息，確定通信信息與所述消息的接收信息相同的JOB，并將所述套接字接收的消息派發給通信信息與所述消息的接收信息相同的JOB。

5.根據權利要求1所述的方法，其特征在于，通過所述JOB對應的調度任務，將所述消息派發給所述JOB，包括：

使所述調度任務根據所述JOB的狀態，確定所述JOB是否正在等待消息；

如果是，則保存所述調度任務的上下文信息，跳轉到所述JOB的上下文，并將所述消息派發給所述JOB；

如果否，則將所述消息緩存到所述調度任務的任務消息隊列中，繼續確定所述JOB是否正在等待消息；

在所述JOB完成對派發的所述消息的邏輯處理之后，根據保存的所述調度任務的上下文信息，跳轉回所述調度任務的上下文。

6.根據權利要求5所述的方法，其特征在于，根據所述JOB的狀態，確定所述JOB是否正在等待消息，包括：

如果所述JOB的狀態為阻塞狀態，則確定所述JOB正在等待消息；

如果所述JOB的狀態為運行狀態，則確定所述JOB正在處理消息；

如果所述JOB的狀態為同步阻塞狀態，則確定所述JOB正在等待消息；

其中，在同步阻塞狀態下，所述JOB正在等待的消息為所述JOB已經發出的同步消息所對應的應答消息。

7.根據權利要求1所述的方法，其特征在于，所述方法還包括：

如果所述調度任務對應多個JOB，則使所述調度任務在接收到所述多個JOB中的其中一個JOB發送給另一個JOB的消息之后，將所述消息存儲到所述另一個JOB對應的待處理消息隊列中，以使所述另一個JOB從所述待處理消息隊列中獲取所述消息。

8.一種業務調度方法，其特征在于，在業務實體側執行，包括：

獲取JOB模板；

根據所述JOB模板，將所述業務實體的業務邏輯封裝成JOB；

注冊所述JOB，以便調度系統為所述JOB對應創建調度任務；

在工作狀態下，如果接收到所述JOB對應的調度任務發送的消息，則對所述消息執行邏輯處理。