[發(fā)明專利]數(shù)據(jù)分發(fā)方法、服務(wù)器及計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202010062377.5
• 申請(qǐng)日: 2020-01-19
• 公開（公告）號(hào): CN111274052A
• 公開（公告）日: 2020-06-12
• 發(fā)明（設(shè)計(jì)）人: 任練
• 申請(qǐng)（專利權(quán)）人: 中國平安人壽保險(xiǎn)股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;G06F16/2455
• 代理公司: 深圳市沃德知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 44347
• 代理人: 高杰;于志光

1.一種數(shù)據(jù)分發(fā)方法，其特征在于，所述方法包括步驟：

通過定時(shí)任務(wù)調(diào)度平臺(tái)啟動(dòng)數(shù)據(jù)處理任務(wù)；

查詢所述數(shù)據(jù)處理任務(wù)所處理的數(shù)據(jù)對(duì)應(yīng)的所有機(jī)構(gòu)信息；

根據(jù)所述機(jī)構(gòu)信息將所述數(shù)據(jù)處理任務(wù)按機(jī)構(gòu)進(jìn)行劃分，生成多個(gè)子任務(wù)；

將所述多個(gè)子任務(wù)發(fā)送至消息隊(duì)列，從而分發(fā)到不同客戶端進(jìn)行并發(fā)處理；及

接收并記錄各個(gè)客戶端對(duì)所述多個(gè)子任務(wù)的處理結(jié)果。

2.如權(quán)利要求1所述的數(shù)據(jù)分發(fā)方法，其特征在于，該方法還包括步驟：

監(jiān)控所述消息隊(duì)列的處理進(jìn)度，當(dāng)所述消息隊(duì)列中有消息在客戶端的執(zhí)行出現(xiàn)問題時(shí)，針對(duì)出現(xiàn)問題的消息對(duì)應(yīng)的單個(gè)子任務(wù)進(jìn)行實(shí)時(shí)調(diào)整優(yōu)化。

3.如權(quán)利要求2所述的數(shù)據(jù)分發(fā)方法，其特征在于，該方法還包括步驟：

監(jiān)控已注冊(cè)的客戶端數(shù)量，根據(jù)所述客戶端數(shù)量調(diào)整所述消息隊(duì)列的大小。

4.如權(quán)利要求1-3任一項(xiàng)所述的數(shù)據(jù)分發(fā)方法，其特征在于，該方法還包括步驟：

記錄所述消息隊(duì)列中每條消息的消費(fèi)軌跡，作為每個(gè)機(jī)構(gòu)數(shù)據(jù)處理的歷史記錄，以供后續(xù)進(jìn)行回溯或優(yōu)化分析。

5.如權(quán)利要求1所述的數(shù)據(jù)分發(fā)方法，其特征在于，所述根據(jù)所述機(jī)構(gòu)信息將所述數(shù)據(jù)處理任務(wù)按機(jī)構(gòu)進(jìn)行劃分，生成多個(gè)子任務(wù)的步驟包括：

根據(jù)所述機(jī)構(gòu)信息將每個(gè)機(jī)構(gòu)對(duì)應(yīng)的數(shù)據(jù)劃分為一個(gè)子任務(wù)。

6.如權(quán)利要求5所述的數(shù)據(jù)分發(fā)方法，其特征在于，當(dāng)所述數(shù)據(jù)處理任務(wù)對(duì)應(yīng)的機(jī)構(gòu)分為多個(gè)層次時(shí)，按最低層次的機(jī)構(gòu)劃分所述數(shù)據(jù)處理任務(wù)。

7.如權(quán)利要求1所述的數(shù)據(jù)分發(fā)方法，其特征在于，所述將所述多個(gè)子任務(wù)發(fā)送至消息隊(duì)列，從而分發(fā)到不同客戶端進(jìn)行并發(fā)處理的步驟包括：

將各個(gè)子任務(wù)分別作為一個(gè)消息，發(fā)送至所述消息隊(duì)列，供客戶端集群從所述消息隊(duì)列上拉取消息進(jìn)行消費(fèi)，從而處理所述消息對(duì)應(yīng)的子任務(wù)。

8.如權(quán)利要求2所述的數(shù)據(jù)分發(fā)方法，其特征在于，所述當(dāng)所述消息隊(duì)列中有消息在客戶端的執(zhí)行出現(xiàn)問題時(shí)，針對(duì)出現(xiàn)問題的消息對(duì)應(yīng)的單個(gè)子任務(wù)進(jìn)行實(shí)時(shí)調(diào)整優(yōu)化的步驟包括：

重新將出現(xiàn)問題的子任務(wù)發(fā)送至所述消息隊(duì)列，生成新的消息，從而分發(fā)到其他未出現(xiàn)問題的客戶端進(jìn)行處理。

9.一種服務(wù)器，其特征在于，所述服務(wù)器包括存儲(chǔ)器、處理器，所述存儲(chǔ)器上存儲(chǔ)有可在所述處理器上運(yùn)行的數(shù)據(jù)分發(fā)系統(tǒng)，所述數(shù)據(jù)分發(fā)系統(tǒng)被所述處理器執(zhí)行時(shí)實(shí)現(xiàn)如權(quán)利要求1-8中任一項(xiàng)所述的數(shù)據(jù)分發(fā)方法的步驟。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其特征在于，所述計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)存儲(chǔ)有數(shù)據(jù)分發(fā)系統(tǒng)，所述數(shù)據(jù)分發(fā)系統(tǒng)可被至少一個(gè)處理器執(zhí)行，以使所述至少一個(gè)處理器執(zhí)行如權(quán)利要求1-8中任一項(xiàng)所述的數(shù)據(jù)分發(fā)方法的步驟。