[發明專利]一種數據處理方法及裝置、資訊處理系統

有效

• 申請號: 201610664982.3
• 申請日: 2016-08-12
• 公開（公告）號: CN106874334B
• 公開（公告）日: 2021-07-09
• 發明（設計）人: 韓濤;袁自誠
• 申請（專利權）人: 創新先進技術有限公司
• 主分類號: G06F16/00
• 分類號: G06F16/00
• 代理公司: 北京安信方達知識產權代理有限公司 11262
• 代理人: 解婷婷;龍洪

本申請公開了一種數據處理方法及裝置、資訊處理系統，所述數據處理方法，應用于集群，所述集群包括多個節點，包括：接收數據處理請求，所述數據處理請求中包括待處理的第一數據對象；將所述第一數據對象存儲到所述集群的數據庫中，生成任務消息，所述任務消息中攜帶有與所述第一數據對象相關聯的任務標識；向所述集群中的多個節點發布所述任務消息，以便所述節點根據所述任務標識從所述數據庫中提取所述第一數據對象進行處理。本文不僅實現了數據的異步處理，而且避免了新起線程池和線程隊列的使用，降低了復雜度，提升了處理效率，也優化清晰了數據處理流程，且能夠充分利用集群中的閑置節點資源，避免資源浪費。

技術領域

本申請涉及網絡技術領域，尤指一種數據處理方法及裝置、資訊處理系統。

背景技術

網絡中，資訊處理系統之間業務數據的實時交互傳遞一般采用異步交互方式。

相關技術中，資訊處理系統與外部系統異步交互的過程是，當前節點的應用系統層接收業務請求，將請求處理的業務數據投入到當前節點上操作系統層已有的線程池或操作系統層新起的線程上，由操作系統層的線程池或新起的線程對業務數據進行處理，雖然實現了異步處理，但需要管理線程池的資源和運行調度，或對主線程外的新線程進行管理，系統復雜度高，處理效率低，且不能有效利用資訊處理系統中的其他節點資源，發生問題時還需要人工排查，系統維護成本也比較高。

綜上，在實現本申請的過程中，發明人發現，對于業務處理的異步交互中系統復雜度高、不能有效利用其他節點資源以及系統維護成本高的問題，目前還沒有好的解決方案。

發明內容

為了解決上述技術問題，本申請提供了一種數據處理方法及裝置、資訊處理系統。

一方面，本申請提供了一種數據處理方法，應用于集群，所述集群包括多個節點，包括：

接收數據處理請求，所述數據處理請求中包括待處理的第一數據對象；

將所述第一數據對象存儲到所述集群的數據庫中，生成任務消息，所述任務消息中攜帶有與所述第一數據對象相關聯的任務標識；

向所述集群中的多個節點發布所述任務消息，以便所述節點根據所述任務標識從所述數據庫中提取所述第一數據對象進行處理。

其中，在將所述第一數據對象存儲到所述集群的數據庫中之前，還包括：

為所述第一數據對象設置第一狀態標識，所述第一狀態標識用于標識所述第一數據對象為待處理的狀態；

在所述節點根據所述任務標識從所述數據庫中提取所述第一數據對象之后，還包括：

為所述第一數據對象設置第二狀態標識，所述第二狀態標識用于標識所述第一數據對象為處理中的狀態。

其中，在將所述第一數據對象存儲到所述集群的數據庫中，生成任務消息之后，還包括：

發送第一響應消息給所述第一數據對象的請求方，所述第一響應消息用于指示所述第一數據對象已收到。

其中，在接收所述數據處理請求之后，生成任務消息之前，還包括：

驗證所述數據庫中是否已存儲有所述數據處理請求中待處理的第一數據對象；

如果是，則從所述數據庫中查詢所述第一數據對象相關聯的任務標識，根據所述任務標識提取所述第一數據對象，為所述第一數據對象設置第二狀態標識，所述第二狀態標識用于標識所述第一數據對象為處理中的狀態，并對所述第一數據對象進行處理；

如果不是，則創建任務流水，將所述任務流水的任務標識與所述第一數據對象相關聯后存儲到所述集群的數據庫中。

另一方面，本申請還提供了一種數據處理方法，應用于集群，所述集群包括多個節點；包括：