zeromq - zmq 中的端口分配是如何在幕后完成的？

Question

我研究 zmq 有一段时间了，并实现了一个简化的 poc - 模仿我的基础架构设计 - 使用它(特别是使用 NetMQ 包装器)，取得了很好的效果。

我的情况是这样的:

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

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

编辑

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

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

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

问题:

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

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

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

谢谢，

Answer 1

当您在 Windows 上的 zeromq/netmq 上创建一个套接字时，一个专用套接字用于在 io 线程和用户线程之间发送信号，这个套接字占用两个端口。如果您调用绑定(bind)，则将另一个端口与您选择的端口绑定(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();
        }
    }
}