c# - 为什么 nanomsg 会挂起？

Question

我刚开始用 C# 进行 nnanomsg 编程。对于一个简单的客户端/服务器示例，我将从以下示例开始，其中客户端与服务器连接以获取下一个数字。目前，该示例适用于 localhost，但我将网络 IP 地址硬编码以确保其正常工作。可能会有很多客户端连接到服务器，但是这个例子比现实生活中更积极地访问服务器。

客户代码：

using NNanomsg.Protocols;
using System;
using System.Text;
using System.Threading;

namespace Client {
    class Program {
        static void Main(string[] args) {
            string connect = "tcp://127.0.1.107:9595";
            while (true) {
                PairSocket s = new PairSocket();
                s.Connect(connect);
                s.Send(Encoding.UTF8.GetBytes("Hello!"));
                Console.WriteLine("Sent");
                byte[] ss = null;
                while (ss == null) {
                    ss = s.ReceiveImmediate(); 
                    Thread.Sleep(250);
                }
                s.Dispose();
                Console.WriteLine("Received: " + Encoding.UTF8.GetString(ss));
}   }   }   }

服务器代码：

using System;
using System.Text;
using NNanomsg.Protocols;

namespace Server {
    public class Server {
        public static int ITER = 0;
        public static int NEXT_ID = 10001;
        public static string CONNECT;
        public static int PORT = 9595;
        public static string QUERY;
        public static string TCP = "tcp://127.0.1.107";

        static void Main(string[] args) {
            string bind = TCP + ":" + PORT;
            Console.WriteLine("server starting...");
            PairSocket s = new PairSocket();
            s.Bind(bind);
            while (true) {
                byte[] ss = null;
                ss = s.Receive();
                Console.WriteLine("Received from client: " + Encoding.UTF8.GetString(ss));
                byte[] b = Encoding.UTF8.GetBytes(NEXT_ID.ToString());
                Console.WriteLine("Sent next id " + NEXT_ID);
                s.Send(b);
                NEXT_ID++;
                if (NEXT_ID > 65535) { NEXT_ID = 10001; }
}   }   }   }

一般来说，当有一个服务器和一个客户端时，这会很好地工作。但是，当我在同一台物理机器上启动第二个客户端时，它们会一起工作一段时间，可能进行 5 到 10 次迭代，然后其中一个客户端（通常是最近启动的那个）挂起。添加延迟（Thread.sleep(5000)例如）稍微改善了这种情况，但它最终会在 50 次迭代后挂起。目前，客户端在显示“已发送”后立即停止。我还没有尝试从网络上的另一台物理机器启动客户端。

此外，我是否在循环中等待ReceiveImmediate()或只是坐在 aReceive()似乎并不重要。

我期望的是每个客户端都有机会向服务器发送请求并得到回复。确切的顺序并不重要，只要服务器最终响应客户端的请求即可。

我想了解它为什么挂起。我有最新版本的 DLL，1.1.5。

非常感谢您的每一点帮助。

Answer 1

简单的解决方案：我切换到 ZeroMQ。显然 ZeroMQ 处理多线程要好得多。