3

我一直在研究 zmq 并且已经实现了一个简化的 poc - 以模仿我的基础设施设计 - 使用它（特别是使用 NetMQ 包装器），效果很好。

我的情况是这样的：

将来我计划在一台机器上运行多个客户端，每个客户端都需要通过多个套接字与“服务器”（位于不同的机器上）进行通信。

我注意到，对于我明确声明和打开的每个套接字，zmq 在内部打开了更多套接字并由它管理。

编辑

绑定套接字在动态范围内分配了一个新端口，这很好，

但是虽然我的客户端只显式连接到 2 个端口，但 zmq 自动为他分配了大约 15 个端口。

我担心，这最终可能会导致端口短缺，这是我非常想避免的情况。

问题：

  1. zmq 是如何内部分配端口的，显式声明的套接字与 zmq 自动打开的端口之间的比率是多少？

  2. 有没有办法让我通过配置或任何其他方式以编程方式控制端口分配？

  3. 使用轮询如何影响端口使用？

肿瘤坏死因子，

4

1 回答 1

3

当您在 windows 上的 zeromq/netmq 上创建一个套接字时，一个专用套接字用于在 io 线程和用户线程之间发出信号，该套接字占用两个端口。如果您调用 bind，则将另一个端口与您选择的端口绑定。

专用套接字正在使用动态端口范围（netmq），因此如果您远离该范围，则不会有任何问题。

windows vista 及更高版本的动态端口范围是 49152 到 65535

港口计数代码：

static void Main(string[] args)
{
    var id = Process.GetCurrentProcess().Id;

    using (var context = NetMQContext.Create())
    {
        List<NetMQSocket> sockets = new List<NetMQSocket>();

        NetMQSocket server = context.CreateDealerSocket();
        server.Bind("tcp://localhost:6666");

        int i= 0;
        while (true)
        {
            var client = context.CreateDealerSocket();
            client.Connect("tcp://localhost:6666");

            sockets.Add(client);

            Thread.Sleep(1000);                                       

            ProcessStartInfo startInfo = new ProcessStartInfo("NETSTAT.EXE", "-a -o");
            startInfo.RedirectStandardOutput = true;
            startInfo.UseShellExecute = false;
            startInfo.CreateNoWindow = true;

            Console.WriteLine("Calculating taken ports...");

            Process process  = Process.Start(startInfo);                    
            int portCounter = -7; // start with minus 4 for framework and server socket

            while (!process.StandardOutput.EndOfStream)
            {
                if (process.StandardOutput.ReadLine().Contains(id.ToString()))
                {
                    portCounter ++;
                }
            }

            Console.Clear();
            Console.WriteLine("{0} sockets takes {1} ports, avg of {2} ports per socket", sockets.Count, portCounter, portCounter / sockets.Count);
            Console.WriteLine("Press enter to create another socket");

            Console.ReadLine();
        }
    }
}
于 2015-08-10T14:30:38.703 回答