只能部分訪問發佈到ZeroMQ隊列的消息

Question

我有一個大型Python庫，各種進程通過使用ZeroMQ的隊列交換信息。我正在AWS EC2 Ubuntu實例上運行這些進程。

具體而言，我有一個過程ProcessPub即不斷運行在InstanceA和每天一次它產生的3個消息集是那些獲得發佈到3個不同的隊列Q1，Q2，和Q3突發。我還有另一個ProcessSubProcessSub兩個副本，它們在InstanceA上運行，另一個InstanceB訂閱這3個隊列，處理傳入的消息並將結果（包括所攝入的消息）轉儲到磁盤上的本地文件中。下面是我觀察：

1. ProcessSub的兩個InstanceA和InstanceB運行得到每一個突發發佈到Q1和Q2
2. ProcessSub上InstanceA運行會從每一個所有消息突發發佈到Q3除了所有消息第一個和最後一個消息
3. ProcessSub在InstanceB上運行獲取NONE消息發佈到Q3

換言之，Q1並Q2似乎是在兩個InstanceA和InstanceB完美可見的，而Q3似乎是在消息獲取所產生的實例（InstanceA）和InstanceB完全看不見部分可見。

我訂閱ProcessSub的3個隊列的方式是一樣的。

我如何知道爲什麼我無法訪問Q3消息？

更新：在ProcessPub，我的，對於Q3準備消息的代碼的塊，然後將它們發佈到Q3，然後用不與Q2Q1相同。作爲實驗，我通過將發佈到Q3的塊放在發佈到Q2和Q1塊之前的塊之後進行了修改。在此更改之後，所有3個隊列在InstanceB上可見。因此，在每一次活動中，我都會將所有消息發佈到所有3個隊列中。但是，我發現了另一個問題。在InstanceA上運行的ProcessSub將所有從Q中捕獲的消息重定向到磁盤上的本地文件。所以每當出現爆發時，數據就會以大塊的形式添加到這些文件中。我注意到來自每個隊列的每個突發的第一條消息在本地文件中丟失。我懷疑這與緩衝磁盤上的文件有什麼關係，因爲它是每個爆發的第一個消息，而不是最後一個。順便說一句，在InstanceB第一條消息被捕獲罰款。所以還是有一些問題（或問題）。

Answer 1

在評論中你說「我覺得單獨的套接字」。我認爲這可能是你的問題的原因。根據ZeroMQ documentation，你應該只能爲每個ZMQ實例打開1個套接字，而不是每個PUB/SUB隊列1個套接字。