[發(fā)明專利]一種接口的流量整形方法、裝置、存儲介質及電子設備

在審

• 申請?zhí)枺?/td>: 202011387037.6
• 申請日: 2020-12-01
• 公開（公告）號: CN112583733A
• 公開（公告）日: 2021-03-30
• 發(fā)明（設計）人: 楊猛;錢新剛;黃波
• 申請（專利權）人: 北京三快在線科技有限公司
• 主分類號: H04L12/815
• 分類號: H04L12/815;H04L29/06;H04L29/08
• 代理公司: 北京曼威知識產權代理有限公司 11709
• 代理人: 方志煒

本說明書公開了一種接口的流量整形方法、裝置、存儲介質及電子設備。針對分布式系統(tǒng)中的每個子系統(tǒng)，該子系統(tǒng)在通過接口接收調用請求時，可確定調用請求對應的調用標識，以確定調用請求對應的調用模式。然后根據(jù)預設的調用模式和事務執(zhí)行模式的對應關系，確定事務執(zhí)行模式，當該事務執(zhí)行模式為吞吐量優(yōu)先模式時，根據(jù)預設的等待策略，緩存調用請求，直至已緩存的各調用請求滿足預設條件時，將已緩存的各調用請求進行整合，并進行批量處理。可以根據(jù)不同的調用模式，區(qū)分需要響應優(yōu)先處理的調用請求和需要吞吐量優(yōu)先處理的調用請求，并進行處理，在合理利用分布式系統(tǒng)的系統(tǒng)資源的同時還可以提高系統(tǒng)中的各子系統(tǒng)協(xié)作處理業(yè)務的效率。

技術領域

本說明書涉及互聯(lián)網(wǎng)領域，尤其涉及一種接口的流量整形方法、裝置、存儲介質及電子設備。

背景技術

目前，分布式系統(tǒng)通過設置不同的子系統(tǒng)，由不同子系統(tǒng)協(xié)作執(zhí)行業(yè)務，來減少設備性能瓶頸帶來的問題，提高系統(tǒng)工作效率。由于分布式系統(tǒng)中的不同子系統(tǒng)分別負責處理不同的事務，因此為了協(xié)作執(zhí)行任務，不同子系統(tǒng)間需要通過接口發(fā)送攜帶任務信息的調用請求以及響應該調用請求。此外，當外部系統(tǒng)需要調用分布式系統(tǒng)的一些功能時，也需要通過該分布式系統(tǒng)的接口與該分布式系統(tǒng)進行交互。

在現(xiàn)有技術中，分布式系統(tǒng)的各子系統(tǒng)間會預先約定各接口的接口規(guī)范，并通過遠程調用協(xié)議(Remote Procedure Call Protocol，RPC)進行交互。服務端會按照約定的接口規(guī)范，定義各接口可供誰調用以及各接口可通過執(zhí)行函數(shù)所能實現(xiàn)的功能，并把各接口發(fā)布到網(wǎng)絡中。

由于分布式系統(tǒng)處理的業(yè)務繁多，其中存在用戶發(fā)起的業(yè)務，也有系統(tǒng)根據(jù)業(yè)務邏輯的需求自行執(zhí)行的業(yè)務，例如，定時對賬、數(shù)據(jù)統(tǒng)計等等，因此系統(tǒng)在一定時間內需要處理的調用請求既包含用戶發(fā)起的業(yè)務的調用請求，也包含系統(tǒng)發(fā)起的業(yè)務的調用請求。通常來說，系統(tǒng)發(fā)起的業(yè)務屬于批量處理業(yè)務，會長時間占用子系統(tǒng)的資源，導致子系統(tǒng)處理業(yè)務的時間變長，遇到業(yè)務高峰時候還可能導致業(yè)務失敗，使得整體效率比較低。

發(fā)明內容

本說明書提供一種接口的流量整形方法、裝置、存儲介質及電子設備，以部分的解決現(xiàn)有技術存在的上述問題。

本說明書采用下述技術方案：

本說明書提供了一種接口的流量整形方法，針對分布式系統(tǒng)中的每個子系統(tǒng)，該子系統(tǒng)對外提供的每個業(yè)務功能對應一個接口，子系統(tǒng)通過接口接收調用請求，所述調用請求攜帶有入口標識，所述方法具體包括：

針對每個子系統(tǒng)，該子系統(tǒng)通過接口接收調用請求，確定所述調用請求對應的調用標識，根據(jù)所述調用標識，確定所述調用請求對應的調用模式，其中，所述調用模式包括用戶調用以及定時調用；

根據(jù)預設的調用模式和事務執(zhí)行模式的對應關系，確定所述調用模式對應的事務執(zhí)行模式，其中，所述事務執(zhí)行模式包括響應優(yōu)先模式和吞吐量優(yōu)先模式；

當所述事務執(zhí)行模式為響應優(yōu)先模式時，根據(jù)所述調用請求，執(zhí)行事務；

當所述事務執(zhí)行模式為吞吐量優(yōu)先模式時，根據(jù)預設的等待策略，緩存所述調用請求，直至已緩存的各調用請求滿足預設條件時，將已緩存的各調用請求進行整合，并進行批量處理。

可選地，根據(jù)預設的調用模式和事務執(zhí)行模式的對應關系，確定所述調用模式對應的事務執(zhí)行模式，具體包括：

當所述調用請求對應的調用模式為用戶調用時，確定所述調用模式對應的事務執(zhí)行模式為響應優(yōu)先模式；

當所述調用請求對應的調用模式為定時調用時，確定所述調用模式對應的事務執(zhí)行模式為吞吐量優(yōu)先模式。

可選地，所述調用模式還包括系統(tǒng)間調用；

根據(jù)預設的調用模式和事務執(zhí)行模式的對應關系，確定所述調用模式對應的事務執(zhí)行模式之前，所述方法還包括：