調整 MQTT 配置的速率

調整 MQTT 配置的速率

我有一個正在嘗試解決的問題,感覺這是一個常見問題,因此大概有一個網路協定形式的通用解決方案。我的知識網路協定有點有限,如果使用不同的協議是我實際需要的解決方案,我無法使用谷歌搜尋找到現有的協議來解決這個問題。

我的配置

使用 MQTT,我有一個生產者向某個主題發布訊息,並且可能有多個消費者訂閱該主題。生產者可以以一定的最大速率生產訊息。每個消費者都希望以該消費者獨有的速率處理訊息。如果消費者接收訊息的速度超過了他們處理的速度,他們可以簡單地丟棄訊息。

我的顧慮

例如,我可能有一個生產者可以以每秒 100 張影像的速度推送影像,但我的 2 位消費者只能分別以每秒 8 張和每秒 5 張的速度消費它們。為了節省網路資源,這裡的最佳發布速率是每秒 8 張圖像。

我的想法

實現這一目標的一種方法是讓生產者和消費者連接到一個共同的「速率協商」服務,其目的是改變發布者向共享主題發送訊息的速率。

問題

我是否應該考慮為此目的使用其他協議,或者我應該考慮其他常見的協議來幫助我解決這個問題並解決我的問題?

相關內容