[發明專利]基于分布式系統的異步任務控制方法及系統

有效

• 申請號: 201610854007.9
• 申請日: 2016-09-26
• 公開（公告）號: CN107870822B
• 公開（公告）日: 2020-11-24
• 發明（設計）人: 唐雁斌
• 申請（專利權）人: 平安科技（深圳）有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 深圳市沃德知識產權代理事務所(普通合伙) 44347
• 代理人: 高杰;于志光

本發明公開了一種基于分布式系統的異步任務控制方法，包括：異步任務控制系統為對應的分布式系統的異步任務建立異步任務隊列，并對異步任務隊列中的異步任務數量進行監控；若異步任務數量小于預設閾值，則從數據庫系統獲取數據庫鎖，為分布式系統抓取預設數量的異步任務，并放入異步任務隊列中；為抓取的各個異步任務生成對應的任務處理中標識，以防止抓取的各個異步任務被其他異步任務控制系統抓取，并釋放獲取的數據庫鎖，以供各個分布式系統對應的異步任務控制系統進行獲取。本發明還公開了一種基于分布式系統的異步任務控制系統。本發明充分利用了每一分布式系統來進行異步任務處理，有效地提升了整個分布式系統的異步任務處理能力。

技術領域

本發明涉及計算機技術領域，尤其涉及一種基于分布式系統的異步任務控制方法及系統。

背景技術

隨著移動互聯網、云計算、大數據時代的到來，現有的分布式系統的異步任務處理往往只能單線程或指定單臺服務器處理，經常容易出現有的分布式系統超負荷運行，而有的分布式系統處于空閑狀態的情況發生，無法充分利用整個分布式系統的性能來進行異步任務處理，造成任務處理效率低下。

發明內容

本發明的主要目的在于提供一種基于分布式系統的異步任務控制方法及系統，旨在提高分布式系統的異步任務處理能力。

為實現上述目的，本發明提供的一種基于分布式系統的異步任務控制方法，所述方法包括以下步驟：

異步任務控制系統為對應的分布式系統的異步任務建立異步任務隊列，并對所述異步任務隊列中的異步任務數量進行監控；

若所述異步任務隊列中的異步任務數量小于預設閾值，則從數據庫系統獲取數據庫鎖；

若成功從所述數據庫系統獲取到數據庫鎖，則為所述分布式系統抓取預設數量的異步任務，并放入所述異步任務隊列中；

為抓取的各個異步任務生成對應的任務處理中標識，以防止抓取的各個異步任務被其他分布式系統對應的異步任務控制系統抓取，并釋放獲取的數據庫鎖，以供各個分布式系統對應的異步任務控制系統進行獲取。

優選地，所述若成功從所述數據庫系統獲取到數據庫鎖，則為所述分布式系統抓取預設數量的異步任務，并放入所述異步任務隊列中的步驟包括：

若所述異步任務控制系統成功從所述數據庫系統獲取到數據庫鎖，且所述預設閾值與所述異步任務隊列中的異步任務數量的差值數量大于或等于預設固定數量，則為所述分布式系統抓取預設固定數量的異步任務，并放入所述異步任務隊列中，以供所述分布式系統對所述異步任務隊列中的異步任務進行處理。

優選地，所述若成功從所述數據庫系統獲取到數據庫鎖，則為所述分布式系統抓取預設數量的異步任務放入所述異步任務隊列中的步驟包括：

若所述異步任務控制系統成功從所述數據庫系統獲取到數據庫鎖，且所述預設閾值與所述異步任務隊列中的異步任務數量的差值數量小于預設固定數量，則為所述分布式系統抓取所述差值數量的異步任務，并放入所述異步任務隊列中，以供所述分布式系統對所述異步任務隊列中的異步任務進行處理。

優選地，該方法還包括：

若所述異步任務隊列中的異步任務數量大于或等于預設閾值，則所述異步任務控制系統停止從所述數據庫系統獲取數據庫鎖。

此外，為實現上述目的，本發明還提供一種基于分布式系統的異步任務控制系統，所述異步任務控制系統包括：

建立模塊，用于為對應的分布式系統的異步任務建立異步任務隊列，并對所述異步任務隊列中的異步任務數量進行監控；

獲取模塊，用于若所述異步任務隊列中的異步任務數量小于預設閾值，則從數據庫系統獲取數據庫鎖；