0MQ推送/拉取顺序在未连接拉取套接字时中断

Question

我在0MQ (Python->C#)中有一个PUSH/PULL模式，只有一个PUSH套接字和一个PULL套接字。只要两者都连接，无论工作进程处理消息需要多长时间，排队的消息的顺序都会保持不变。

问题是，当worker断开连接一段时间后重新连接时，在此期间排队的所有消息将以任意随机顺序到达，无论它们是如何通过PUSH套接字排队的。这个问题有没有内置的解决方案，或者我应该使用更高级的模式？

我在PULL端添加了代码：

using (var receiver = new PullSocket())
            {
                receiver.Bind("tcp://localhost:5557");

                while (true)
                {
                    var payload = receiver.ReceiveFrameString();

                    log.Debug($"Payload: {payload}");
                }
            }

Answer 1

我很确定0mq的PUSH/PULL不能保证发货的顺序。

也许你可以使用REQ/REP (或者REQ/ROUTER或者类似的模式)来代替--当你需要同步的时候，REQ/REP非常有用。在我看来，您可以创建一个进程内PUSH/PULL队列，从中提取消息并将其推入REQ套接字。