[發明專利]基于消息隊列的業務處理系統及方法

有效

• 申請號: 201610390637.5
• 申請日: 2016-06-02
• 公開（公告）號: CN107464088B
• 公開（公告）日: 2020-09-29
• 發明（設計）人: 吳梓銘;張海潮
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06Q10/10
• 分類號: G06Q10/10
• 代理公司: 北京律智知識產權代理有限公司 11438
• 代理人: 姜怡;闞梓瑄

1.一種基于消息隊列的業務處理系統，其特征在于，包括：業務環節處理器集合、消息表及消息隊列；其中，

所述業務環節處理器集合包括多個業務環節處理器，各業務環節處理器分別對應接收一種類型的消息，各依次排列的業務環節處理器分別用于按照業務的業務流程順序處理所述業務各業務環節的業務邏輯；當所述多個業務環節處理器的其中之一收到所述消息隊列中對應類型的消息時，處理其對應業務環節的業務邏輯，并當處理完其對應業務環節的業務邏輯時，產生驅動下一個業務環節處理器所需的對應類型的消息，及將所述消息存儲到所述消息表中；

所述消息表用于存儲所述多個業務環節處理器產生的消息，并通過一定時任務將其中未發送過的消息加載到所述消息隊列中；

所述消息隊列用于將從所述消息表收到的消息分發到相應的所述業務環節處理器中，以驅動所述業務環節處理器處理其對應業務環節的業務邏輯。

2.根據權利要求1所述的系統，其特征在于，還包括：消息歷史表，用于存儲定期從所述消息表中遷移的已處理消息。

3.根據權利要求1或2所述的系統，其特征在于，所述消息包括用于唯一標識業務流的業務流ID。

4.根據權利要求1或2所述的系統，其特征在于，所述多個業務環節處理器架構于多個分布式集群服務器中。

5.根據權利要求1或2所述的系統，其特征在于，所述消息表存儲于一數據庫中，所述數據庫還包括：消息過濾器，用于當將所述消息表中的消息加載到所述消息隊列時，過濾掉預設類型的消息。

6.一種基于消息隊列的業務處理方法，應用于基于消息隊列的業務處理系統中，其特征在于，所述系統包括：包括多個業務環節處理器的業務環節處理器集合、消息表及消息隊列；所述業務環節處理器集合包括多個業務環節處理器，各業務環節處理器分別對應接收一種類型的消息，各依次排列的業務環節處理器分別用于按照業務的業務流程順序處理所述業務各業務環節的業務邏輯；所述方法包括：

當所述多個業務環節處理器的其中之一收到所述消息隊列中對應類型的第一消息時，處理其對應業務環節的業務邏輯，并當其處理完對應業務環節的業務邏輯時，產生驅動下一個業務環節處理器所需的對應類型的第二消息，及將所述第二消息存儲到所述消息表中；

通過一第一定時器任務定期掃描所述消息表，以將所述第二消息加載到所述消息隊列中；以及

所述消息隊列將所述第二消息分發到所述下一個業務環節處理器中，以驅動所述下一個業務環節處理器處理對應業務環節的業務邏輯。

7.根據權利要求6所述的方法，其特征在于，所述系統還包括：消息歷史表，所述方法還包括：通過一第二定時器任務定期對所述消息表中的已處理數據進行遷移，并歸檔到所述消息歷史表中。

8.根據權利要求6或7所述的方法，其特征在于，所述消息包括用于唯一標識業務流的業務流ID。

9.根據權利要求6或7所述的方法，其特征在于，所述多個業務環節處理器架構于多個分布式集群服務器中。

10.根據權利要求6或7所述的方法，其特征在于，所述消息表存儲于一數據庫中，所述數據庫還包括：消息過濾器；所述方法還包括：當將所述消息表中的消息加載到所述消息隊列時，所述消息過濾器過濾掉預設類型的消息。

11.一種電子設備，其特征在于，包括：

存儲器；以及

耦合到所屬存儲器的處理器，所述處理器被配置為基于存儲在所述存儲器中的指令，執行如權利要求6-10任一項所述的方法。

12.一種計算機可讀存儲介質，其上存儲有程序，該程序被處理器執行時實現如權利要求6-10任一項所述的方法。