[發明專利]一種任務調度處理方法及系統

有效

• 申請號: 201310738706.3
• 申請日: 2013-12-26
• 公開（公告）號: CN103679392B
• 公開（公告）日: 2018-01-09
• 發明（設計）人: 周雪松;項毅
• 申請（專利權）人: 拉卡拉支付股份有限公司
• 主分類號: G06Q10/06
• 分類號: G06Q10/06;G06F9/48
• 代理公司: 北京新知遠方知識產權代理事務所(普通合伙)11397
• 代理人: 馬軍芳

技術領域

本發明涉及集群業務處理技術領域，尤其涉及一種任務調度處理方法及系統。

背景技術

隨著企業級管理系統用戶數量的不斷增大，為滿足管理系統的并發量，一般各個公司會采用硬件或軟件集群的方式來部署系統。然而集群并不是線程安全的，集群系統并發時會產生諸如系統定時任務處理、關鍵數據重復等問題。雖然目前部分問題可通過各種“鎖”的機制解決，但這種機制并不能完全解決上述問題。

對于收單業務系統來說，收單業務中包含各種各樣的單據號信息，比如交易流水號、商戶號、終端號以及其他各類流程數據單號。這些單號都有嚴格的編碼規則，并且在各自的領域中是唯一標識，一旦出現重復情況將對收單業務管理系統產生巨大的影響。

發明內容

本發明為解決上述問題，提出了一種任務調度處理方法及系統，通過將傳統的任務執行過程拆分成兩部分，解決系統集群部署產生的并發問題。

在一個方面，本發明提供了一種任務調度處理方法，包括以下步驟：

從消息中間件接收申請任務消息，申請任務消息包括主題名稱；

當判斷申請任務消息滿足預置的過濾條件時，在數據庫中查詢該任務的執行狀態；如果當前沒有應用程序正在執行該任務，則指定目標應用程序執行該任務，發布以該主題名稱為主題的任務執行消息到消息中間件。

在一個方面，本發明還提供了一種任務調度處理方法，包括以下步驟：

對數據庫中的定時任務的任務規則進行解析，得到該定時任務，該定時任務包括主題名稱、執行時間和執行對象；

當到達該執行時間時，從執行對象中指定應用程序作為目標應用程序，向消息中間件發布任務執行消息，該任務執行消息包括主題名稱和目標應用程序。

在另一個方面，本發明提供了一種任務調度處理系統，包括：

消息接收器，用于從消息中間件接收申請任務消息，申請任務消息包括主題名稱；

消息過濾器，用于根據預置的過濾條件過濾申請任務消息；

運算器，用于當申請任務消息通過消息過濾器時，在數據庫中查詢該任務的執行狀態，如果當前沒有應用程序正在執行該任務，則指定目標應用程序執行該任務；

消息發布器，用于發布以該主題名稱為主題的任務執行消息到消息中間件上。

在另一方面，本發明還提供了一種任務調度處理系統，包括：

規則解析器，用于對數據庫中的定時任務的任務規則進行解析，得到定時任務，該定時任務包括主題名稱、執行時間和執行對象；

運算器，用于當到達執行時間時，從執行對象中指定應用程序作為目標應用程序；

消息發布器，用于向消息中間件發布任務執行消息，該任務執行消息包括所述主題名稱以及所述目標應用程序。

本發明采用JMS機制的發布者/訂閱者模式，通過將各個單號任務生成與單號任務實際執行兩個步驟分開處理，經任務調度以后再確定實際執行任務的應用程序。采用本發明的技術方案可以避免在集群系統并發操作時產生數據重復的問題。

附圖說明

下面將參照附圖描述本發明的具體實施例，其中：

圖1示出了本發明實施例的任務調度處理方法的方法流程圖；

圖2示出了本發明另一實施例的任務調度處理方法的方法流程圖；

圖3示出了本發明實施例的任務調度處理系統的結構示意圖；

圖4示出了本發明另一實施例的任務調度處理系統的結構示意圖；

圖5示出了傳統商戶號生成任務的處理流程；

圖6示出了本發明實施例商戶號生成任務的處理流程。

具體實施方式

為了使本發明的技術方案及優點更加清楚明白，以下結合附圖對本發明的示例性實施例進行進一步詳細的說明，顯然，所描述的實施例僅是本發明的一部分實施例，而不是所有實施例的窮舉。

為了解決系統集群部署時產生的并發問題，本發明實施例提出了一種任務分配調度處理方法及系統，是基于Java消息服務(JMS，Java Message Service)機制進行任務調度的處理。

其中，Java消息服務(JMS，Java Message Service)是一個Java平臺中關于面向消息中間件的應用程序編程接口(API，Application Programming Interface)，它使得分布式系統的信息通信松散連接，發送信息的客戶端只需要負責發送信息，接收信息的客戶端只需要接收信息，兩個客戶端之間沒有必要同時可用。