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

在審

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

本說明書一種批處理速率的控制方法，應(yīng)用于令牌管理者，所述方法包括：根據(jù)限流參數(shù)生成用于預(yù)定周期的若干個令牌；所述令牌用來指示生產(chǎn)者能夠向消費者分發(fā)的任務(wù)數(shù)量上限；在某個預(yù)定周期內(nèi)收到生產(chǎn)者的令牌請求后，如果所述預(yù)定周期的令牌尚未發(fā)放完畢，向生產(chǎn)者發(fā)放令牌。

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

本說明書涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，尤其涉及一種批處理速率的控制方法和裝置。

背景技術(shù)

借助于互聯(lián)網(wǎng)和物流的飛速發(fā)展，企業(yè)能夠跨越空間的限制，向越來越多的用戶提供商品和服務(wù)。伴隨著經(jīng)營活動產(chǎn)生了巨量的數(shù)據(jù)，企業(yè)也經(jīng)常需要對這些數(shù)據(jù)進行批量處理。基于并發(fā)技術(shù)的應(yīng)用，對數(shù)據(jù)的批處理能夠達到很高的處理速率。

但是在一些應(yīng)用場景中，需要對批處理的速率進行控制。例如，某企業(yè)在月初要為每個用戶生成上個月度的情況匯總并短信通知每個用戶，由于短信發(fā)送接口的吞吐量遠遠小于單位時間內(nèi)情況匯總的生成量，過高頻率的調(diào)用短信發(fā)送接口往往導(dǎo)致該接口阻塞，使短信發(fā)送速度更慢。如果想要在充分利用系統(tǒng)資源的同時避免過度利用導(dǎo)致的擁堵，就要精準(zhǔn)的控制批處理的速率。

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

有鑒于此，本說明書提供一種批處理速率的控制方法，應(yīng)用于令牌管理者，所述方法包括：

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

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

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

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

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

本說明書還提供了一種批處理速率的控制裝置，應(yīng)用于令牌管理者，所述裝置包括：

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

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

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

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

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

本說明書提供的一種計算機設(shè)備，包括：存儲器和處理器；所述存儲器上存儲有可由處理器運行的計算機程序；所述處理器運行所述計算機程序時，執(zhí)行上述應(yīng)用于令牌管理者的批處理速率的控制方法所述的步驟。

本說明書提供的一種計算機設(shè)備，包括：存儲器和處理器；所述存儲器上存儲有可由處理器運行的計算機程序；所述處理器運行所述計算機程序時，執(zhí)行上述應(yīng)用于生產(chǎn)者的批處理速率的控制方法所述的步驟。

本說明書提供的一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，所述計算機程序被處理器運行時，執(zhí)行上述應(yīng)用于令牌管理者的批處理速率的控制方法所述的步驟。

本說明書還提供了一種計算機可讀存儲介質(zhì)，其上存儲有計算機程序，所述計算機程序被處理器運行時，執(zhí)行上述應(yīng)用于生產(chǎn)者的批處理速率的控制方法所述的步驟。