ZeroMQ 发布/C# 子在订阅者之前启动时不起作用

Question

在运行 ZeroMQ 基本 PUB / SUB C# 示例时，如果我先启动发布服务器，它们对我有用，但如果我先启动订阅服务器，则不会。当我这样做时，订阅者启动，但从未收到任何数据。从我所读到的内容来看，我认为我应该能够以任一顺序启动这些过程。

我正在使用nuget in的ZeroMQ 4.1.0.26软件包。NET 4.6，x64应用程序。这些都是在Windows上运行的。我在同一台机器上运行这两个应用程序。

下面是我正在运行的代码(这是ZeroMQ教程中示例的简化版本)。

订户:

    static void Main(string[] args)
    {
        var endpoint = "tcp://127.0.0.1:5556";

        // Socket to talk to server
        using (var context = new ZContext())
        using (var subscriber = new ZSocket(context, ZSocketType.SUB))
        {
            Console.WriteLine("I: Connecting to {0}…", endpoint);
            subscriber.Connect(endpoint);

            // Subscribe to zipcode
            string zipCode = "90210 ";
            Console.WriteLine("I: Subscribing to zip code {0}…", zipCode);
            subscriber.Subscribe(zipCode);

            while(true)
            {
                using (var replyFrame = subscriber.ReceiveFrame())
                {
                    string reply = replyFrame.ReadString();
                    Console.WriteLine(reply);
                }
            }
        }
    }

发布者:

    static void Main(string[] args)
    {
        using (var context = new ZContext())
        using (var publisher = new ZSocket(context, ZSocketType.PUB))
        {
            var address = "tcp://*:5556";
            Console.WriteLine("I: Publisher.Bind'ing on {0}", address);
            publisher.Bind(address);

            // Initialize random number generator
            var rnd = new Random();
            while (true)
            {
                // Get values that will fool the boss
                int zipcode = 90210;
                int temperature = rnd.Next(-55, +45);

                // Send message to all subscribers
                var update = string.Format("{0:D5} {1}", zipcode, temperature);
                using (var updateFrame = new ZFrame(update))
                {
                    publisher.Send(updateFrame);
                }

                Thread.Sleep(1000);
            }
        }
    }

我尝试了以下建议中的建议：

• 使用显式IP地址：这没有什么区别
• 删除主题过滤：这没有什么区别
• 创建新的AnyCPU（而不是x64）项目：这没有什么区别
• 尝试其他语言：这很有趣

使用 Python 等效发布者和订阅者：

• Python订阅者在发布者之前启动时、连接到Python发布者或C#发布者时工作。
• C#订阅者在发布者之前启动时不工作，无论它是连接到Python还是C#发布者。

因此，看起来 C# 订阅者代码有问题。

>

我的示例代码（下面的最新版本）有问题吗？

还是ZeroMQ的问题。网库？

这是正常工作的Python订阅者：

import sys
import zmq

#  Socket to talk to server
context = zmq.Context()
socket  = context.socket( zmq.SUB )

print( "Python: Collecting updates from weather server" )
socket.connect( "tcp://localhost:5556" )

socket.setsockopt_string( zmq.SUBSCRIBE, "" )

while True:
    string = socket.recv_string()
    zipcode, temperature = string.split()
    print( zipcode + " " + temperature )

以下是C#订阅者的最新等效（非工作）版本：

static void Main(string[] args)
{
    // Socket to talk to server
    using (var context = new ZContext())
    using (var socket = new ZSocket(context, ZSocketType.SUB))
    {
        Console.WriteLine("C#: Collecting updates from weather server");
        socket.Connect("tcp://localhost:5556");
        socket.Subscribe("");

        while (true)
        {
            using (var replyFrame = socket.ReceiveFrame())
            {
                string reply = replyFrame.ReadString();
                Console.WriteLine(reply);
            }
        }
    }
}

Answer 1

如果您遵循此处重新发布的流程图，那么< code>PUB/SUB的问题就会凸显出来。

最近（EoY-2017）API v4.x的重新设计工作已经改变了一些设计方法（无论是在SUB-端处理主题过滤器，还是在较新的API版本中，在PUB-端，逆转开销分布/集中，排除流量缓冲/处理开销），PUB/SUB操作顺序似乎保持不变（参见上述流程图）。

事后根因隔离测试：

感谢积极的代码重新测试，这有助于在根本原因歧视方面向前推进几步。

现在让我们关注为什么：

ZeroMQ通常有两个抽象层，ZeroMQ内部层，实现框架的核心设施，如ZeroMQ协议RFC规范中所定义的。这是负责所有RFC定义的交互变得兼容和交叉兼容的部分，以便以ZeroMQ发布的方式服务。

另一层由一个“外来”语言包装器/ API绑定构成，它帮助非ZeroMQ内部代码的其他语言使用ZeroMQ API为任何特定的第三方语言中介公开的服务，以便“外来”世界有机会在内部ZeroMQ层的世界中调用由库实现的服务。

因此，使用python＜code＞SUB＜/code＞-probe（根据定义，它工作得很好）到C#语言绑定来隔离差异，其中＜code＞SUB＜/code＞-probet仍然不工作。

正如Dijkstra在测试中指出的那样，一些测试按预期工作的事实并不意味着系统中没有其他错误/错误，绑定可能会有更多的问题，但是pythonSUB-客户端的积极确认表明，ZeroMQ核心服务不是那些导致错误的人。

你的代码看起来不错。

如上所述，这是主要的可疑ATM

向C#绑定维护者报告修复ZeroMQ不符合行为的请求，如上面观察和重新测试的全部细节所记录的，是帮助不符合C#绑定顺利工作的最佳下一步。