c#-4.0 - 发布者和订阅者中的 NetMQ 不工作

Question

我正在尝试实现 NetMQ 发布/订阅模型，但订阅者未收到任何消息。这里可能有什么问题？

  private static void ServerTask()
    {
        using (var context = NetMQContext.Create())
        {
            using (var socket = context.CreateSubscriberSocket())
            {
                socket.Bind("tcp://10.120.19.109:5000");
                socket.Subscribe(string.Empty);

                while (true)
                {
                    Thread.Sleep(100);
                    string receivedMessage = socket.ReceiveString();
                    Console.WriteLine("Received: " + receivedMessage);
                }
            }
        }
    }

     public static void ClientTask()
    {
        using (NetMQContext ctx = NetMQContext.Create())
        {
            using (var socket = ctx.CreatePublisherSocket())
            {
                socket.Connect("tcp://10.120.19.109:5000");

                string obj = "hi";
                socket.Send(obj);
            }
        }
    }

两者在不同的应用程序中。

Answer 1

如果您是 NetMQ 的新手，我建议您阅读 zeromq 指南 http://zguide.zeromq.org/page:all .

底线是您在订阅者发送订阅之前发送消息。

zeromq 和 NetMQ 中的 Pubsub 就像 radio ，只有在您开始收听的那一刻，您才会收到消息。

一个简单的方法(不是现实生活中的解决方案)是在连接后休眠一段时间。

对于现实生活中的解决方案，我需要了解您想要实现的目标