[發(fā)明專利]一種基于分布式環(huán)境的數(shù)據(jù)處理方法和裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202110352535.5
• 申請(qǐng)日: 2021-03-31
• 公開（公告）號(hào): CN112988800B
• 公開（公告）日: 2022-09-27
• 發(fā)明（設(shè)計(jì)）人: 李華宏;邢磊
• 申請(qǐng)（專利權(quán)）人: 建信金融科技有限責(zé)任公司
• 主分類號(hào): G06F16/2453
• 分類號(hào): G06F16/2453;G06F16/23;G06F16/27;G06Q40/04
• 代理公司: 中原信達(dá)知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11219
• 代理人: 王安娜;王志遠(yuǎn)

1.一種基于分布式環(huán)境的數(shù)據(jù)處理方法，其特征在于，包括：

響應(yīng)于日切發(fā)起節(jié)點(diǎn)發(fā)起的日切指令，更新配置中心的營業(yè)日期；

在所述配置中心成功更新營業(yè)日期后，響應(yīng)于所述日切指令，更新一個(gè)或多個(gè)路由節(jié)點(diǎn)的本地內(nèi)存日期，其中，所述本地內(nèi)存日期為存儲(chǔ)在路由節(jié)點(diǎn)的內(nèi)存中的營業(yè)日期；

通過所述一個(gè)或多個(gè)路由節(jié)點(diǎn)接收交易請(qǐng)求，從所述一個(gè)或多個(gè)路由節(jié)點(diǎn)的內(nèi)存中讀取本地內(nèi)存日期，將讀取的本地內(nèi)存日期與接收的交易請(qǐng)求進(jìn)行拼接，并轉(zhuǎn)發(fā)至處理節(jié)點(diǎn)，然后通過所述處理節(jié)點(diǎn)將所述讀取的本地內(nèi)存日期作為當(dāng)前營業(yè)日期，處理所述接收的交易請(qǐng)求。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

根據(jù)所述路由節(jié)點(diǎn)對(duì)應(yīng)的日期有效時(shí)間，判斷所述路由節(jié)點(diǎn)的本地內(nèi)存日期是否失效，其中，所述日期有效時(shí)間為本地內(nèi)存日期的有效時(shí)間；

若是，則從所述配置中心讀取所述營業(yè)日期，并利用所述營業(yè)日期更新所述路由節(jié)點(diǎn)的本地內(nèi)存日期。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述方法還包括：

若到達(dá)所述日切指令對(duì)應(yīng)的重新發(fā)起時(shí)間，重新發(fā)起所述日切指令，其中，所述日切指令對(duì)應(yīng)的重新發(fā)起時(shí)間大于所述日期有效時(shí)間。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，在重新發(fā)起所述日切指令之前，所述方法還包括：

獲取日期更新成功的路由節(jié)點(diǎn)和日期更新失敗的路由節(jié)點(diǎn)；

判斷所述日期更新成功的路由節(jié)點(diǎn)與所述日期更新失敗的路由節(jié)點(diǎn)的節(jié)點(diǎn)數(shù)量比值是否大于預(yù)設(shè)的比值閾值；

若是，則確定所述日切發(fā)起節(jié)點(diǎn)放棄重新發(fā)起所述日切指令；

若否，則確定所述日切發(fā)起節(jié)點(diǎn)重新發(fā)起所述日切指令。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述重新發(fā)起所述日切指令，包括：

通過所述日切發(fā)起節(jié)點(diǎn)向所述日期更新失敗的路由節(jié)點(diǎn)重新發(fā)起所述日切指令，以便于所述日期更新失敗的路由節(jié)點(diǎn)響應(yīng)于所述日切指令進(jìn)行日期更新。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述方法還包括：

若所述路由節(jié)點(diǎn)符合以下選項(xiàng)中至少一項(xiàng)：更新日期失敗的次數(shù)超過預(yù)設(shè)次數(shù)閾值、在預(yù)設(shè)時(shí)間內(nèi)更新日期失敗，則確定所述路由節(jié)點(diǎn)為異常節(jié)點(diǎn)，返回所述異常節(jié)點(diǎn)的運(yùn)維故障處理信息，以及觸發(fā)運(yùn)維告警信息。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述更新日期失敗包括：響應(yīng)于所述日切指令更新日期失敗、從所述配置中心讀取所述營業(yè)日期失敗。

8.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

若存在新啟動(dòng)的路由節(jié)點(diǎn)，則從所述配置中心讀取所述營業(yè)日期，并將所述營業(yè)日期存儲(chǔ)至所述新啟動(dòng)的路由節(jié)點(diǎn)的內(nèi)存中，以便所述新啟動(dòng)的路由節(jié)點(diǎn)按照所述營業(yè)日期處理交易請(qǐng)求。

9.根據(jù)權(quán)利要求1至8任一所述的方法，其特征在于，所述響應(yīng)于所述日切指令，更新一個(gè)或多個(gè)路由節(jié)點(diǎn)的本地內(nèi)存日期，包括：

根據(jù)所述日切指令中的時(shí)間參數(shù)，更新第一路由節(jié)點(diǎn)的本地內(nèi)存日期；

響應(yīng)于所述日切指令，變更第二路由節(jié)點(diǎn)對(duì)應(yīng)的路由狀態(tài)值，然后根據(jù)路由狀態(tài)值，更新所述第二路由節(jié)點(diǎn)的本地內(nèi)存日期。

10.根據(jù)權(quán)利要求9所述的方法，其特征在于，所述響應(yīng)于所述日切指令，變更第二路由節(jié)點(diǎn)對(duì)應(yīng)的路由狀態(tài)值，包括：

響應(yīng)于所述日切指令，將所述第二路由節(jié)點(diǎn)對(duì)應(yīng)的路由狀態(tài)值從0變更為1。

11.根據(jù)權(quán)利要求10所述的方法，其特征在于，所述根據(jù)路由狀態(tài)值，更新所述第二路由節(jié)點(diǎn)的本地內(nèi)存日期，包括：

若監(jiān)測(cè)到所述第二路由節(jié)點(diǎn)對(duì)應(yīng)的路由狀態(tài)值為1，則更新所述第二路由節(jié)點(diǎn)的本地內(nèi)存日期，然后結(jié)合路由狀態(tài)值的失效時(shí)間，將所述第二路由節(jié)點(diǎn)對(duì)應(yīng)的路由狀態(tài)值從1變更為0。