從ZMQ子隊列獲取特定消息

Question

我有一個使用ZMQ的Python消息傳遞應用程序。每個對象都有一個PUB和一個SUB隊列，並且它們相互連接。在某些特定情況下，我想等待SUB隊列中的特定消息，留下我不感興趣的消息以供日後處理。

現在，我收到所有消息，並將那些我對Python隊列不感興趣的消息排隊，直到找到我正在等待的消息。但他的意思是，在每個處理路由中，我需要首先在Python隊列中檢查舊消息。有沒有更好的辦法？

Answer 1

zmq發佈者不會執行任何排隊......當沒有SUB可用於接收這些消息時，它將刪除消息。

在你的情況下更好的方法是創建一個通用的sub只訂閱某些感興趣的消息。這樣你可以旋轉所有不同的SUB（甚至在一個線程內並使用zmq輪詢器），並且它們將全部處理來自PUB的消息......

這就是PUB/SUB模式主要用於。 Subs僅訂閱感興趣的消息，因此消除了在每個循環中遍歷消息隊列以尋找感興趣的消息的需要。