zmq 中的端口分配是如何在幕后完成的?

How port allocation is done behind the scenes in zmq?

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

我的情况是这样的:

将来我计划在一台机器上 运行 多个客户端,其中每个客户端需要通过多个套接字与 "server"(位于不同机器上)通信。

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

编辑

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

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

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

题目:

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

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

  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();
        }
    }
}