[發(fā)明專利]一種業(yè)務(wù)服務(wù)系統(tǒng)及方法

有效

• 申請?zhí)枺?/td>: 202011157958.3
• 申請日: 2020-10-26
• 公開（公告）號: CN112333249B
• 公開（公告）日: 2022-07-22
• 發(fā)明（設(shè)計）人: 石超
• 申請（專利權(quán)）人: 新華三大數(shù)據(jù)技術(shù)有限公司
• 主分類號: H04L67/51
• 分類號: H04L67/51;H04L67/1097;H04L67/1095;H04L67/60
• 代理公司: 北京柏杉松知識產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11413
• 代理人: 項京;高鶯然

本發(fā)明實施例提供了一種業(yè)務(wù)服務(wù)系統(tǒng)，涉及網(wǎng)絡(luò)服務(wù)技術(shù)領(lǐng)域。該系統(tǒng)包括：任務(wù)信息存儲設(shè)備、主調(diào)度節(jié)點和從調(diào)度節(jié)點、應(yīng)用協(xié)調(diào)服務(wù)器、任務(wù)消息存儲設(shè)備和多個微服務(wù)執(zhí)行節(jié)點；主調(diào)度節(jié)點從任務(wù)信息存儲設(shè)備中獲取待處理任務(wù)信息并同步到應(yīng)用協(xié)調(diào)服務(wù)器；為每個調(diào)度節(jié)點分配從應(yīng)用協(xié)調(diào)服務(wù)器獲取的待處理任務(wù)信息；將生成的待處理任務(wù)消息存儲至任務(wù)消息存儲設(shè)備；從調(diào)度節(jié)點從任務(wù)信息存儲設(shè)備中獲取待處理任務(wù)信息并同步到應(yīng)用協(xié)調(diào)服務(wù)器；將生成的待處理任務(wù)消息存儲至任務(wù)消息存儲設(shè)備；微服務(wù)執(zhí)行節(jié)點從任務(wù)消息存儲設(shè)備中獲取待處理任務(wù)消息進(jìn)行業(yè)務(wù)處理。與現(xiàn)有技術(shù)相比，應(yīng)用本發(fā)明實施例提供的方案，可以提高業(yè)務(wù)服務(wù)系統(tǒng)的可擴(kuò)展性。

技術(shù)領(lǐng)域

本發(fā)明涉網(wǎng)絡(luò)服務(wù)技術(shù)領(lǐng)域，特別是涉及一種業(yè)務(wù)服務(wù)系統(tǒng)及方法。

背景技術(shù)

目前，采用微服務(wù)架構(gòu)的業(yè)務(wù)服務(wù)系統(tǒng)被廣泛地應(yīng)用到人們的日常生活和工作中。其中，在微服務(wù)架構(gòu)中，可以存在多個子服務(wù)，為用戶提供屬于同一業(yè)務(wù)應(yīng)用的不同類型的服務(wù)，實現(xiàn)用戶所發(fā)出的不同類型的任務(wù)。例如，采用微服務(wù)架構(gòu)的購物服務(wù)系統(tǒng)可以提供下單子服務(wù)、結(jié)算子服務(wù)和退單子服務(wù)等。

例如，如圖1所示，一個采用微服務(wù)架構(gòu)的業(yè)務(wù)應(yīng)用系統(tǒng)可以提供服務(wù)1-3共三種不同類型的子服務(wù)，每種子服務(wù)分別對應(yīng)于一調(diào)度節(jié)點，并且每種子服務(wù)所對應(yīng)的調(diào)度節(jié)點與多個微服務(wù)執(zhí)行節(jié)點通信連接，每個微服務(wù)執(zhí)行節(jié)點用于執(zhí)行屬于該種子服務(wù)的各個待處理任務(wù)。其中，當(dāng)用戶通過客戶端101發(fā)出某種待處理任務(wù)時，該業(yè)務(wù)應(yīng)用系統(tǒng)中的網(wǎng)關(guān)102可以確定該待處理任務(wù)的服務(wù)類型為服務(wù)1，從而可以將該待處理任務(wù)分配服務(wù)1給對應(yīng)的調(diào)度節(jié)點103，進(jìn)而，該調(diào)度節(jié)點便可以將該待處理任務(wù)分配給一用于執(zhí)行該服務(wù)類型所對應(yīng)任務(wù)的微服務(wù)執(zhí)行節(jié)點104，以使該微服務(wù)執(zhí)行節(jié)點104執(zhí)行該待處理任務(wù)。

然而，當(dāng)前針對采用微服務(wù)架構(gòu)的業(yè)務(wù)應(yīng)用系統(tǒng)中的各個待處理任務(wù)的調(diào)度方案中，調(diào)度節(jié)點在接收到待處理任務(wù)時，會直接選取執(zhí)行節(jié)點，并將該待處理任務(wù)分配給所選取的微服務(wù)執(zhí)行節(jié)點，也就是說，在當(dāng)前的相關(guān)技術(shù)中，調(diào)度節(jié)點與微服務(wù)執(zhí)行節(jié)點耦合在一起，從而，實現(xiàn)二者之間的直接的通信連接。由于調(diào)度節(jié)點與微服務(wù)執(zhí)行節(jié)點耦合在一起，導(dǎo)致上述業(yè)務(wù)服務(wù)系統(tǒng)的可擴(kuò)展性較差。

發(fā)明內(nèi)容

本發(fā)明實施例的目的在于提供一種業(yè)務(wù)服務(wù)系統(tǒng)及方法，以實現(xiàn)對調(diào)度系統(tǒng)和微服務(wù)執(zhí)行節(jié)點的解耦，提高業(yè)務(wù)服務(wù)系統(tǒng)的可擴(kuò)展性。具體技術(shù)方案如下：

第一方面，本發(fā)明實施例提供了一種業(yè)務(wù)服務(wù)系統(tǒng)，所述系統(tǒng)包括：任務(wù)信息存儲設(shè)備、多個調(diào)度節(jié)點、應(yīng)用協(xié)調(diào)服務(wù)器、任務(wù)消息存儲設(shè)備和多個微服務(wù)執(zhí)行節(jié)點；其中一個調(diào)度節(jié)點被配置為主調(diào)度節(jié)點，其他調(diào)度節(jié)點被配置為從調(diào)度節(jié)點；

所述任務(wù)信息存儲設(shè)備，用于存儲客戶端請求的任務(wù)的任務(wù)信息；

所述主調(diào)度節(jié)點，用于從所述任務(wù)信息存儲設(shè)備中獲取待處理任務(wù)信息，并將從所述任務(wù)信息存儲設(shè)備中所獲取到的待處理任務(wù)信息同步到所述應(yīng)用協(xié)調(diào)服務(wù)器；從所述應(yīng)用協(xié)調(diào)服務(wù)器獲取各個調(diào)度節(jié)點所同步的待處理任務(wù)信息，按照預(yù)設(shè)分配規(guī)則，為每個調(diào)度節(jié)點分配從所述應(yīng)用協(xié)調(diào)服務(wù)器所獲取到的待處理任務(wù)信息；并對分配給自身的待處理任務(wù)信息生成對應(yīng)的待處理任務(wù)消息，存儲至所述任務(wù)消息存儲設(shè)備；

所述從調(diào)度節(jié)點，用于從所述任務(wù)信息存儲設(shè)備中獲取待處理任務(wù)信息，并將所獲取到的待處理任務(wù)信息同步到所述應(yīng)用協(xié)調(diào)服務(wù)器；獲得所述主調(diào)度節(jié)點分配的待處理任務(wù)信息；并對分配給自身的待處理任務(wù)信息生成對應(yīng)的待處理任務(wù)消息，存儲至所述任務(wù)消息存儲設(shè)備；

所述微服務(wù)執(zhí)行節(jié)點，用于從所述任務(wù)消息存儲設(shè)備中獲取預(yù)設(shè)的自身要處理的待處理任務(wù)消息進(jìn)行業(yè)務(wù)處理。

可選的，一種具體實現(xiàn)方式中，所述應(yīng)用協(xié)調(diào)服務(wù)器還用于：

接收每個調(diào)度節(jié)點發(fā)送的注冊信息，并基于所接收到的注冊信息生成關(guān)于所述多個調(diào)度節(jié)點的節(jié)點樹；其中，所述節(jié)點樹用于指示所述多個調(diào)度節(jié)點中各個正常運行的調(diào)度節(jié)點；