[發明專利]一種流量控制的方法及相關裝置

有效

• 申請號: 201810349910.9
• 申請日: 2018-04-18
• 公開（公告）號: CN110391991B
• 公開（公告）日: 2022-04-29
• 發明（設計）人: 許金川;譚嘉杰
• 申請（專利權）人: 華為技術有限公司
• 主分類號: H04L47/10
• 分類號: H04L47/10
• 代理公司: 北京東方億思知識產權代理有限責任公司 11258
• 代理人: 彭瓊

本申請公開了一種流量控制的方法及相關裝置。當服務端接收到客戶端發送的發布報文時，服務端查詢客戶端的流控窗口的窗口值，并比較窗口值和預設的窗口門限；當窗口值等于窗口門限時，拒絕接收發布報文；當窗口值大于窗口門限時，將窗口值遞減預設值，并處理發布報文。在客戶端需要向服務端發送發布報文時，客戶端查詢客戶端的流控窗口的窗口值，并比較窗口值和預設的窗口門限；當窗口值等于窗口門限時，暫停向服務端發送發布報文；當窗口值大于窗口門限時，將窗口值遞減預設值，并向服務端發送發布報文。本申請能夠避免客戶端和服務端之間傳輸消息時，客戶端發送消息的速度太快，導致服務端無法及時處理客戶端發送的消息，無法正常通信的問題。

技術領域

本申請涉及通信技術領域，尤其涉及一種流量控制的方法及相關裝置。

背景技術

消息隊列遙測傳輸(Message Queue Telemetry Transport，MQTT)協議是一個客戶端-服務端架構的發布/訂閱模式的消息傳輸協議，具有輕巧、開放、簡單、規范、易于實現等特點。MQTT協議可以應用到很多場景，如機器與機器的通信，以及物聯網環境(Internetof Things，IoT)等等。

MQTT協議運行在傳輸控制協議(Transmission Control Protocol，TCP)/網絡協議(Internet Protocol，IP)、或其它提供了有序、可靠、雙向連接的網絡連接上。但是目前MQTT協議并沒有流量控制(流控)的機制，這就使得客戶端和服務端之間傳輸消息時，如果發送方發送消息的速度太快，則會導致接收方在接收消息過程中因處理能力限制、消息擁塞等原因而無法及時處理發送方發送的消息從而使客戶端和服務端之間無法進行正常通信。

發明內容

本申請提供了一種流量控制的方法及相關裝置，能夠避免客戶端和服務端之間傳輸消息時，如果發送方發送消息的速度太快，導致接收方無法及時處理發送方發送的消息，使客戶端和服務端之間無法進行正常通信的問題。

第一方面，本申請提供了一種流量控制的方法。當服務端接收到客戶端發送的發布報文時，所述服務端查詢所述客戶端的流控窗口的窗口值。所述服務端比較所述窗口值和預設的窗口門限。當所述窗口值等于所述窗口門限時，所述服務端拒絕接收所述發布報文。當所述窗口值大于所述窗口門限時，所述服務端將所述窗口值遞減預設值，并處理所述發布報文。

本申請實施例中，服務端存儲客戶端的流控窗口的窗口值，服務端通過客戶端的流控窗口的窗口值可以控制接收客戶端發送的發布報文，實現對客戶端的流量控制。從而可以避免因客戶端發送報文的速度太快或數量太多導致服務端無法及時處理，使客戶端和服務端之間無法進行正常通信的問題。

結合第一方面，在第一方面的第一種可能的實施方式中，還包括：所述服務端接收所述客戶端發送的連接請求報文，所述連接請求報文包括所述客戶端的流控窗口的第一初始值和所述客戶端的流控窗口的第一恢復周期，所述第一恢復周期表示所述客戶端的流控窗口恢復為所述第一初始值的周期；當所述第一初始值和所述第一恢復周期滿足預設條件時，所述服務端存儲所述第一初始值和所述第一恢復周期，并向所述客戶端發送第一連接確認報文，其中，所述第一連接確認報文包括所述第一初始值和所述第一恢復周期，所述第一連接確認報文表示所述客戶端的流控窗口的初始值為所述第一初始值，以及所述客戶端的流控窗口的恢復周期為所述第一恢復周期；當所述第一初始值和所述第一恢復周期不滿足所述預設條件，所述服務端確定所述客戶端的流控窗口的第二初始值和所述客戶端的流控窗口的第二恢復周期；所述服務端存儲所述第二初始值和所述第二恢復周期；所述服務端向所述客戶端發送第二連接確認報文，其中，所述第二連接確認報文包括所述第二初始值和所述第二恢復周期，所述第二連接確認報文表示所述客戶端的流控窗口的初始值為所述第二初始值，以及所述客戶端的流控窗口的恢復周期為所述第二恢復周期。

結合第一方面的第一種可能的實施方式，在第一方面的第二種可能的實施方式中，在所述服務端向所述客戶端發送第一連接確認報文之后，所述方法還包括：所述服務端根據所述第一恢復周期將所述客戶端的流控窗口的值設置為所述第一初始值。