c# - 当订阅者在发布者之前启动时，ZeroMQ PUB/C# SUB 不工作

Question

运行 ZeroMQ 基本 PUB/SUB C# 示例时，如果我先启动发布者，它们会为我工作，但如果我先启动订阅者，则不会。当我这样做时，订户启动，但从未收到任何数据。根据我所阅读的内容，我认为我应该能够以任一顺序启动流程。

我在 .NET 4.6 x64 应用程序中使用来自 nuget 的 ZeroMQ 4.1.0.26 包。这些在 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 发布者或 C# 发布者时，Python 订阅者在发布者之前启动时工作。
• C# 订阅者在发布者之前启动时不起作用，无论它是连接到 Python 还是 C# 发布者。

所以看起来 C# 订阅者代码有问题。

问题:

• 我的示例代码(下面是最新版本)有问题吗？

• 还是 ZeroMQ .NET 库有问题？

这是正常工作的 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

如果你愿意跟随，一步一步the flow-chart re-published here , PUB/SUB 的问题突出显示。

最近 ( EoY-2017 ) API v4.x 重新设计工作改变了一些设计方法(主题过滤器是否在 SUB 端处理，从 v2.1+ 开始，或者——在较新的 API 版本中——在 PUB 端，反转开销分配/集中，exgress-flow缓冲+流量/处理开销)，然而，PUB/SUB 操作顺序似乎保持不变(引用上面提到的流程图)。

---

事后根本原因隔离测试:

Python SUB 运行正常，我的 C# 运行不正常。不清楚为什么:

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

现在让我们关注原因:

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

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

因此，差异被隔离使用 python SUB-probe(工作良好，如定义的那样)到 C#语言绑定(bind)，其中 SUB-probe 仍然无法正常工作。

正如 Dijkstra 在测试中指出的那样，一些测试按预期工作的事实并不意味着系统中没有其他错误/错误，绑定(bind)可能会有更多问题，但是来自 python 的肯定确认>SUB-client 表明，ZeroMQ 核心服务并不是导致错误的罪魁祸首。

---

A1:没有，

你的代码看起来没问题。

A2:是的，

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

向 C# 绑定(bind)维护者报告修复 ZeroMQ 不合规行为的请求，如上面所观察和重新测试的那样详细记录，是帮助不合规者的最佳下一步 C# 绑定(bind)可以轻松工作。