c# - 为什么 nanomsg 会挂起？

Question

我刚开始使用 C# 进行 nnanomsg 编程。对于一个简单的客户端/服务器示例，我从以下示例开始，其中客户端与服务器连接以获取下一个数字。现在，这个例子是针对本地主机的，除了我硬编码了我的网络 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 可以更好地处理多线程。