[發(fā)明專(zhuān)利]請(qǐng)求處理/狀態(tài)碼查詢(xún)方法及裝置、下/上游節(jié)點(diǎn)、介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201710963183.0
• 申請(qǐng)日: 2017-10-16
• 公開(kāi)（公告）號(hào): CN107861825A
• 公開(kāi)（公告）日: 2018-03-30
• 發(fā)明（設(shè)計(jì)）人: 洪騰
• 申請(qǐng)（專(zhuān)利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類(lèi)號(hào): G06F11/07
• 分類(lèi)號(hào): G06F11/07
• 代理公司: 中科專(zhuān)利商標(biāo)代理有限責(zé)任公司11021
• 代理人: 張遠(yuǎn)

1.一種請(qǐng)求處理方法，在包含上游節(jié)點(diǎn)和下游節(jié)點(diǎn)的系統(tǒng)中在下游節(jié)點(diǎn)處執(zhí)行，該請(qǐng)求處理方法包括如下操作：

從所述上游節(jié)點(diǎn)接收請(qǐng)求；

執(zhí)行接收的所述請(qǐng)求，并生成請(qǐng)求狀態(tài)記錄，所述請(qǐng)求狀態(tài)記錄包括是否成功的標(biāo)識(shí)，所述標(biāo)識(shí)表示所述請(qǐng)求執(zhí)行成功或者失敗；

在根據(jù)所述請(qǐng)求狀態(tài)記錄中的所述標(biāo)識(shí)而確認(rèn)為所述請(qǐng)求失敗的情況下，將該失敗請(qǐng)求插入到用于記錄失敗的請(qǐng)求的失敗重試隊(duì)列；和

對(duì)插入到所述失敗重試隊(duì)列中的失敗請(qǐng)求進(jìn)行重試。

2.根據(jù)權(quán)利要求1所述的請(qǐng)求處理方法，其中，

每一個(gè)所述請(qǐng)求被分配有一個(gè)在所述系統(tǒng)中唯一標(biāo)識(shí)該請(qǐng)求的全局請(qǐng)求標(biāo)識(shí)碼即全局請(qǐng)求ID，

在所述請(qǐng)求狀態(tài)記錄中還包括所述全局請(qǐng)求ID和狀態(tài)碼，

所述狀態(tài)碼用于跟蹤每個(gè)所述請(qǐng)求執(zhí)行到哪一層的所述下游節(jié)點(diǎn)。

3.根據(jù)權(quán)利要求2所述的請(qǐng)求處理方法，其中，

所述全局請(qǐng)求ID是通用唯一識(shí)別碼即UUID或數(shù)據(jù)庫(kù)自增ID。

4.根據(jù)權(quán)利要求1或2所述的請(qǐng)求處理方法，其中，

在生成所述請(qǐng)求狀態(tài)記錄時(shí)，采用分庫(kù)分表方式將所述請(qǐng)求狀態(tài)記錄寫(xiě)到數(shù)據(jù)庫(kù)。

5.根據(jù)權(quán)利要求1所述的請(qǐng)求處理方法，其中，

進(jìn)行重試包括：對(duì)所述失敗重試隊(duì)列進(jìn)行輪詢(xún)，以對(duì)請(qǐng)求進(jìn)行重試。

6.根據(jù)權(quán)利要求1所述的請(qǐng)求處理方法，其中，

在重試給定次數(shù)后仍不能成功的情況下，放棄重試。

7.一種下游節(jié)點(diǎn)，是包含上游節(jié)點(diǎn)和下游節(jié)點(diǎn)的系統(tǒng)中的下游節(jié)點(diǎn)，包括：

請(qǐng)求接收模塊，用于從所述上游節(jié)點(diǎn)接收請(qǐng)求；

請(qǐng)求狀態(tài)記錄生成模塊，用于執(zhí)行接收的所述請(qǐng)求，并生成請(qǐng)求狀態(tài)記錄，所述請(qǐng)求狀態(tài)記錄包括是否成功的標(biāo)識(shí)，其中所述標(biāo)識(shí)表示所述請(qǐng)求執(zhí)行成功或者失敗；

失敗請(qǐng)求插入模塊，用于在根據(jù)所述請(qǐng)求狀態(tài)記錄中的所述標(biāo)識(shí)而確認(rèn)為所述請(qǐng)求失敗的情況下，將該失敗請(qǐng)求插入到用于記錄失敗的請(qǐng)求的失敗重試隊(duì)列；和

重試模塊，用于對(duì)插入到所述失敗重試隊(duì)列中的失敗請(qǐng)求進(jìn)行重試。

8.一種狀態(tài)碼查詢(xún)方法，在包含上游節(jié)點(diǎn)和下游節(jié)點(diǎn)的系統(tǒng)中在上游節(jié)點(diǎn)處執(zhí)行，該方法包括如下操作：

向所述下游節(jié)點(diǎn)發(fā)出請(qǐng)求，對(duì)每一個(gè)所述請(qǐng)求分配一個(gè)在所述系統(tǒng)中唯一標(biāo)識(shí)該請(qǐng)求的全局請(qǐng)求ID；

根據(jù)所述全局請(qǐng)求ID查詢(xún)所述狀態(tài)碼，所述全局請(qǐng)求ID和所述狀態(tài)碼包含于在所述下游節(jié)點(diǎn)處生成的請(qǐng)求狀態(tài)記錄中，所述狀態(tài)碼用于跟蹤每個(gè)所述請(qǐng)求執(zhí)行到哪一層的所述下游節(jié)點(diǎn)。

9.一種上游節(jié)點(diǎn)，是包含上游節(jié)點(diǎn)和下游節(jié)點(diǎn)的系統(tǒng)中的上游節(jié)點(diǎn)，包括：

請(qǐng)求發(fā)送模塊，用于向所述下游節(jié)點(diǎn)發(fā)出請(qǐng)求，對(duì)每一個(gè)所述請(qǐng)求分配一個(gè)在所述系統(tǒng)中唯一標(biāo)識(shí)該請(qǐng)求的全局請(qǐng)求ID；

狀態(tài)碼查詢(xún)模塊，根據(jù)所述全局請(qǐng)求ID來(lái)查詢(xún)狀態(tài)碼，所述全局請(qǐng)求ID和所述狀態(tài)碼包含于在所述下游節(jié)點(diǎn)處生成的請(qǐng)求狀態(tài)記錄中，所述狀態(tài)碼用于跟蹤每個(gè)所述請(qǐng)求執(zhí)行到哪一層的所述下游節(jié)點(diǎn)。

10.一種計(jì)算機(jī)可讀介質(zhì)，其上存儲(chǔ)有可執(zhí)行指令，該指令被處理器執(zhí)行時(shí)根據(jù)權(quán)利要求1-6和8中任一項(xiàng)所述的方法。

11.一種請(qǐng)求處理裝置，包括：

一個(gè)或多個(gè)處理器；

存儲(chǔ)裝置，用于存儲(chǔ)一個(gè)或多個(gè)程序，

其中，當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行時(shí)，使得所述一個(gè)或多個(gè)處理器執(zhí)行權(quán)利要求1～6中任一項(xiàng)所述的請(qǐng)求處理方法。

12.一種狀態(tài)碼查詢(xún)裝置，包括：

一個(gè)或多個(gè)處理器；

存儲(chǔ)裝置，用于存儲(chǔ)一個(gè)或多個(gè)程序，

其中，當(dāng)所述一個(gè)或多個(gè)程序被所述一個(gè)或多個(gè)處理器執(zhí)行時(shí)，使得所述一個(gè)或多個(gè)處理器執(zhí)行權(quán)利要求8所述的狀態(tài)碼查詢(xún)方法。