[發(fā)明專利]批處理速率的控制方法和裝置

在審

• 申請?zhí)枺?/td>: 201810306906.4
• 申請日: 2018-04-08
• 公開（公告）號: CN108833296A
• 公開（公告）日: 2018-11-16
• 發(fā)明（設(shè)計(jì)）人: 張岱
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: H04L12/815
• 分類號: H04L12/815;H04L12/819
• 代理公司: 北京博思佳知識(shí)產(chǎn)權(quán)代理有限公司 11415
• 代理人: 林祥

1.一種批處理速率的控制方法，應(yīng)用于令牌管理者，所述方法包括：

根據(jù)限流參數(shù)生成用于預(yù)定周期的若干個(gè)令牌；所述令牌用來指示生產(chǎn)者能夠向消費(fèi)者分發(fā)的任務(wù)數(shù)量上限；

在某個(gè)預(yù)定周期內(nèi)收到生產(chǎn)者的令牌請求后，如果所述預(yù)定周期的令牌尚未發(fā)放完畢，向生產(chǎn)者發(fā)放令牌。

2.根據(jù)權(quán)利要求1所述的方法，所述方法還包括：從配置信息中獲取限流參數(shù)。

3.根據(jù)權(quán)利要求1所述的方法，所述限流參數(shù)包括：在若干個(gè)預(yù)定時(shí)間段的限流參數(shù)，所述預(yù)定時(shí)間段包括至少一個(gè)預(yù)定周期。

4.根據(jù)權(quán)利要求1所述的方法，所述限流參數(shù)包括：每秒查詢率QPS。

5.根據(jù)權(quán)利要求1所述的方法，所述方法還包括：在預(yù)定周期到時(shí)，失效尚未發(fā)放的令牌。

6.一種批處理速率的控制方法，應(yīng)用于生產(chǎn)者，所述方法包括：

向令牌管理者發(fā)送令牌請求；

在收到令牌管理者發(fā)放的令牌后，獲取批處理任務(wù)并分發(fā)給消費(fèi)者，所述獲取或分發(fā)的批處理任務(wù)的數(shù)量不超過所述令牌指示的任務(wù)數(shù)量上限。

7.根據(jù)權(quán)利要求6所述的方法，所述方法還包括：當(dāng)未收到發(fā)放的令牌時(shí)，等待預(yù)定延遲時(shí)間后向令牌管理者發(fā)送令牌請求。

8.根據(jù)權(quán)利要求6所述的方法，所述獲取批處理任務(wù)包括：基于延時(shí)隊(duì)列從數(shù)據(jù)庫中獲取到期的延時(shí)任務(wù)。

9.一種批處理速率的控制裝置，應(yīng)用于令牌管理者，所述裝置包括：

令牌生成單元，用于根據(jù)限流參數(shù)生成用于預(yù)定周期的若干個(gè)令牌；所述令牌用來指示生產(chǎn)者能夠向消費(fèi)者分發(fā)的任務(wù)數(shù)量上限；

令牌發(fā)放單元，用于在某個(gè)預(yù)定周期內(nèi)收到生產(chǎn)者的令牌請求后，如果所述預(yù)定周期的令牌尚未發(fā)放完畢，向生產(chǎn)者發(fā)放令牌。

10.根據(jù)權(quán)利要求9所述的裝置，所述裝置還包括：配置獲取單元，用于從配置信息中獲取限流參數(shù)。

11.根據(jù)權(quán)利要求9所述的裝置，所述限流參數(shù)包括：在若干個(gè)預(yù)定時(shí)間段的限流參數(shù)，所述預(yù)定時(shí)間段包括至少一個(gè)預(yù)定周期。

12.根據(jù)權(quán)利要求9所述的裝置，所述限流參數(shù)包括：每秒查詢率QPS。

13.根據(jù)權(quán)利要求9所述的裝置，所述裝置還包括：令牌失效單元，用于在預(yù)定周期到時(shí)，失效尚未發(fā)放的令牌。

14.一種批處理速率的控制裝置，應(yīng)用于生產(chǎn)者，所述裝置包括：

令牌請求單元，用于向令牌管理者發(fā)送令牌請求；

令牌使用單元，用于在收到令牌管理者發(fā)放的令牌后，獲取批處理任務(wù)并分發(fā)給消費(fèi)者，所述獲取或分發(fā)的批處理任務(wù)的數(shù)量不超過所述令牌指示的任務(wù)數(shù)量上限。

15.根據(jù)權(quán)利要求14所述的裝置，所述裝置還包括：等待重試單元，用于當(dāng)未收到發(fā)放的令牌時(shí)，等待預(yù)定延遲時(shí)間后向令牌管理者發(fā)送令牌請求。

16.根據(jù)權(quán)利要求14所述的裝置，所述令牌使用單元獲取批處理任務(wù)包括：基于延時(shí)隊(duì)列從數(shù)據(jù)庫中獲取到期的延時(shí)任務(wù)。

17.一種計(jì)算機(jī)設(shè)備，包括：存儲(chǔ)器和處理器；所述存儲(chǔ)器上存儲(chǔ)有可由處理器運(yùn)行的計(jì)算機(jī)程序；所述處理器運(yùn)行所述計(jì)算機(jī)程序時(shí)，執(zhí)行如權(quán)利要求1到5任意一項(xiàng)所述的步驟。

18.一種計(jì)算機(jī)設(shè)備，包括：存儲(chǔ)器和處理器；所述存儲(chǔ)器上存儲(chǔ)有可由處理器運(yùn)行的計(jì)算機(jī)程序；所述處理器運(yùn)行所述計(jì)算機(jī)程序時(shí)，執(zhí)行如權(quán)利要求6到8任意一項(xiàng)所述的步驟。