[發明專利]一種處理分布式事務的方法和裝置

有效

• 申請號: 201210198935.6
• 申請日: 2012-06-14
• 公開（公告）號: CN103514028A
• 公開（公告）日: 2014-01-15
• 發明（設計）人: 李春雷
• 申請（專利權）人: 北京新媒傳信科技有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46
• 代理公司: 北京市隆安律師事務所 11323
• 代理人: 權鮮枝

1.一種處理分布式事務的方法，其特征在于，所述方法包括：

事務管理器依據應用啟動事務；

事務協調器將事務拆分為多個任務，將各個事務的同類型的任務分配給同一個任務處理器，并依據任務執行順序向相應任務處理器發送執行指示；

任務處理器對于接收到的執行指示對應的任務，依據執行時間將同類型的任務合并，通過資源適配器調用資源執行合并的任務，并將執行結果反饋給事務協調器；

事務協調器依據反饋的執行結果，通知事務管理器結束事務，或調用任務處理器回滾已經執行的任務，并在回滾完成后通知事務管理器結束事務。

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

所述依據反饋的執行結果，通知事務管理器結束事務，或調用任務處理器回滾已經執行的任務具體包括：

對于每個事務，在所述事務的所有任務的執行結果都為成功時，通知事務管理器結束所述事務，在所述事務的任何一個任務的執行結果為失敗時，調用任務處理器回滾該事務已經執行的任務。

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

在所述事務協調器調用任務處理器回滾已經執行的任務后還包括：

任務處理器接收到事務協調器發送的回滾指示后，根據回滾時間將待回滾的同類型任務進行合并，通過資源適配器對合并的任務進行回滾。

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

所述依據執行時間將同類型的任務合并具體包括：

將執行時間在預設時長內的同類型任務進行合并。

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

所述依據執行時間將同類型的任務合并具體包括：

將執行時間在預設時長內、數量在預設數值內的同類型任務進行合并。

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

所述將執行時間在預設時長內、數量在預設數值內的同類型任務進行合并，通過資源適配器調用資源執行合并的任務具體包括：

當經過時間到達預設時長或待處理的同類型任務的數量到達預設數值時，將待處理的同類型任務進行合并，通過資源適配器調用資源執行合并的任務。

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

所述依據任務執行順序向任務處理器發送執行指示具體包括：

當執行順序在先的任務完成后，向跟在所述完成的任務之后執行的任務所在的任務處理器發送處理該之后執行的任務的執行指示。

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

所述將執行結果反饋給事務協調器具體包括：

對于合并處理中合并的每個任務，將合并后處理的結果作為所述任務對應的事務的所述任務的執行結果反饋給事務協調器。

9.一種處理分布式事務的裝置，其特征在于，所述裝置包括：事務管理器、事務協調器、多個任務處理器、資源適配器；

所述事務管理器，用于依據應用啟動事務；

所述事務協調器，用于將事務拆分為多個任務，將各個事務的同類型的任務分配給同一個任務處理器，依據任務執行順序向相應的任務處理器發送執行指示；還用于依據任務處理器反饋的執行結果，通知事務管理器結束事務或調用任務處理器回滾已經執行的任務，并在回滾完成后通知所述事務管理器結束事務；

所述任務處理器，用于對于接收到的執行指示對應的任務，依據執行時間將同類型的任務合并，通過資源適配器調用資源執行合并的任務，并將執行結果反饋給事務協調器；

所述資源適配器，用于調用資源。

10.根據權利要求9所述的裝置，其特征在于，

所述事務協調器在依據反饋的執行結果，通知事務管理器結束事務或調用任務處理器回滾已經執行的任務時具體用于對于每個事務，在所述事務的所有任務的執行結果都為成功時，通知事務管理器結束所述事務，在所述事務的任何一個任務的執行結果為失敗時，調用任務處理器回滾該事務已經執行的任務。