为什么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()循环中等待，还是只是坐在Receive()前等待，似乎都无关紧要。

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

我想知道它为什么会挂起来。我有最新版本的DLL，1.1.5。

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

Answer 1

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