[發(fā)明專利]一種云原生微服務(wù)流控的方法與服務(wù)端

有效

• 申請(qǐng)?zhí)枺?/td>: 202210004285.0
• 申請(qǐng)日: 2022-01-05
• 公開（公告）號(hào): CN114443162B
• 公開（公告）日: 2023-05-23
• 發(fā)明（設(shè)計(jì)）人: 劉德建;李勤;蘭成建;陳宏
• 申請(qǐng)（專利權(quán)）人: 福建天泉教育科技有限公司
• 主分類號(hào): G06F9/445
• 分類號(hào): G06F9/445;G06F9/50
• 代理公司: 福州市博深專利事務(wù)所(普通合伙) 35214
• 代理人: 唐燕玲

本發(fā)明公開了一種云原生微服務(wù)流控的方法與服務(wù)端；本發(fā)明通過注冊(cè)中心的watch機(jī)制，當(dāng)監(jiān)聽到注冊(cè)中心注冊(cè)的業(yè)務(wù)實(shí)例數(shù)量發(fā)生變化時(shí)，向各個(gè)業(yè)務(wù)實(shí)例發(fā)送通知；由所述業(yè)務(wù)實(shí)例在收到所述通知后，向配置中心獲取當(dāng)前的TPS數(shù)以及業(yè)務(wù)流量閾值對(duì)應(yīng)的業(yè)務(wù)處理能力；根據(jù)當(dāng)前業(yè)務(wù)實(shí)例個(gè)數(shù)、業(yè)務(wù)處理能力以及TPS數(shù)計(jì)算每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)，并基于每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)更新線程池中的線程數(shù)；在監(jiān)聽到業(yè)務(wù)實(shí)例數(shù)量發(fā)生變化時(shí)，能夠根據(jù)當(dāng)前業(yè)務(wù)實(shí)例個(gè)數(shù)、業(yè)務(wù)處理能力以及TPS數(shù)計(jì)算每個(gè)業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)，通過對(duì)各個(gè)業(yè)務(wù)實(shí)例的線程數(shù)進(jìn)行調(diào)整，對(duì)各個(gè)業(yè)務(wù)實(shí)例的流量進(jìn)行控制，從而實(shí)現(xiàn)對(duì)業(yè)務(wù)流量的自動(dòng)控制。

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

本發(fā)明涉及信息技術(shù)領(lǐng)域，特別涉及一種云原生微服務(wù)流控的方法與服務(wù)端。

背景技術(shù)

在云原生環(huán)境下，所有的產(chǎn)品和組件均依賴云提供的能力快速的構(gòu)建和運(yùn)行。業(yè)務(wù)需要計(jì)算資源的時(shí)候能自動(dòng)的進(jìn)行彈性收縮實(shí)例，在業(yè)務(wù)依賴的組件場(chǎng)景下，組件常定義租戶下的負(fù)載流量大小供業(yè)務(wù)使用。如近期在智慧學(xué)伴導(dǎo)入線下作答業(yè)務(wù)的過程中，由于線下作答的數(shù)據(jù)巨大，測(cè)評(píng)組件對(duì)智慧學(xué)伴進(jìn)行限制每秒5000個(gè)用戶作答能力以保障組件服務(wù)的正常。通常情況下，我們通過定義每個(gè)實(shí)例的流量進(jìn)行訪問限制，然而這種實(shí)現(xiàn)方式，每次擴(kuò)容均需調(diào)整并發(fā)配置，同時(shí)由于被依賴組件的響應(yīng)能力不同，無法準(zhǔn)確的控制業(yè)務(wù)的訪問量，實(shí)現(xiàn)流量控制。

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

本發(fā)明所要解決的技術(shù)問題是：提供一種云原生微服務(wù)流控的方法與服務(wù)端，能夠?qū)崿F(xiàn)對(duì)業(yè)務(wù)流量的自動(dòng)控制。

為了解決上述技術(shù)問題，本發(fā)明采用的技術(shù)方案為：

一種云原生微服務(wù)流控的方法，包括步驟：

S1、通過注冊(cè)中心的watch機(jī)制，當(dāng)監(jiān)聽到注冊(cè)中心注冊(cè)的業(yè)務(wù)實(shí)例數(shù)量發(fā)生變化時(shí)，向各個(gè)業(yè)務(wù)實(shí)例發(fā)送通知；

S2、由所述業(yè)務(wù)實(shí)例在收到所述通知后，向配置中心獲取當(dāng)前的TPS數(shù)以及業(yè)務(wù)流量閾值對(duì)應(yīng)的業(yè)務(wù)處理能力；

S3、根據(jù)當(dāng)前業(yè)務(wù)實(shí)例個(gè)數(shù)、所述業(yè)務(wù)處理能力以及所述TPS數(shù)計(jì)算每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)，并基于每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)更新線程池中的線程數(shù)。

為了解決上述技術(shù)問題，本發(fā)明采用的另一種技術(shù)方案為：

一種云原生微服務(wù)流控的服務(wù)端，包括處理器、存儲(chǔ)器以及存儲(chǔ)在所述存儲(chǔ)器中并可在所述處理器上運(yùn)行的計(jì)算機(jī)程序，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)以下步驟：

S1、通過注冊(cè)中心的watch機(jī)制，當(dāng)監(jiān)聽到注冊(cè)中心注冊(cè)的業(yè)務(wù)實(shí)例數(shù)量發(fā)生變化時(shí)，向各個(gè)業(yè)務(wù)實(shí)例發(fā)送通知；

S2、由所述業(yè)務(wù)實(shí)例在收到所述通知后，向配置中心獲取當(dāng)前的TPS數(shù)以及業(yè)務(wù)流量閾值對(duì)應(yīng)的業(yè)務(wù)處理能力；

S3、根據(jù)當(dāng)前業(yè)務(wù)實(shí)例個(gè)數(shù)、所述業(yè)務(wù)處理能力以及所述TPS數(shù)計(jì)算每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)，并基于每個(gè)所述業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)更新線程池中的線程數(shù)。

本發(fā)明的有益效果在于：本發(fā)明的一種云原生微服務(wù)流控的方法與服務(wù)端，在監(jiān)聽到業(yè)務(wù)實(shí)例數(shù)量發(fā)生變化時(shí)，能夠根據(jù)當(dāng)前業(yè)務(wù)實(shí)例個(gè)數(shù)、業(yè)務(wù)處理能力以及TPS數(shù)計(jì)算每個(gè)業(yè)務(wù)實(shí)例應(yīng)當(dāng)分配的線程數(shù)，通過對(duì)各個(gè)業(yè)務(wù)實(shí)例的線程數(shù)進(jìn)行調(diào)整，對(duì)各個(gè)業(yè)務(wù)實(shí)例的流量進(jìn)行控制，從而實(shí)現(xiàn)對(duì)業(yè)務(wù)流量的自動(dòng)控制。

附圖說明

圖1為本發(fā)明實(shí)施例的一種云原生微服務(wù)流控的方法的流程圖；

圖2為本發(fā)明實(shí)施例的一種云原生微服務(wù)流控的服務(wù)端的結(jié)構(gòu)圖；

圖3為本發(fā)明實(shí)施例的一種云原生微服務(wù)流控的方法的業(yè)務(wù)流程處理示意圖；

標(biāo)號(hào)說明：

1、一種云原生微服務(wù)流控的服務(wù)器；2、處理器；3、存儲(chǔ)器。