1

我必须从服务器同一端口上的差异客户端接收数据。为此，我想为每个客户端创建单独的通道并接收每个客户端的数据。

我正在探索所有可用于设计它的选项。

选项 1：侦听单个套接字并处理来自各种设备的数据。

选项 2：在相同的 src 地址（在服务器中）上创建多个具有不同远程地址（客户端）的通道，并使用 NIO 选择器来处理这些通道上的数据。

选项 1 似乎有点冒险，因为远程设备数量众多。而且我似乎无法实现选项 2。即使在绑定通道之前使用 setReuseAddress() API，我也会遇到绑定异常。

有人能帮我一下吗？或者如果有更好的方法来设计这个。我已经探索了有关 stackoverflow 的其他问题，但我仍然无法正确理解它是否可行。

4

1 回答 1

1

单个 UDP 套接字可以为许多客户端提供服务。

由于 UDP 是一种无状态协议，您可以从所有这些客户端读取数据，而无需为每个客户端创建线程（或通道）。

int yourPort = // ...

try (DatagramSocket socket = new DatagramSocket(new InetSocketAddress("0.0.0.0", yourPort))) {
    byte[] buf = new byte[65535];
    DatagramPacket packet = new DatagramPacket(buf, 0, buf.length);
    while (socket.isBound() && !socket.isClosed()) {
        // The packets received here are from all sources, not just a single source
        socket.receive(packet);

        // If we simply send that same packet, without modifying anything, it
        // will echo the same content to whoever sent that packet
        socket.send(packet);
    }
} catch (IOException e) {
    // probably a good idea to close/re-bind here..
}

上面的代码片段理论上可以处理任意数量的客户端，只需要一个线程即可。UDP 中没有会话通道的这种概念。

您可以（并且可能应该）复制接收到的数据并在此循环之外对其进行处理，以最大化利用的网络吞吐量。这是您必须独立于您选择的策略而做的事情。

没有理由认为上述实现的性能会明显低于其他方式。

  • 创建多个套接字不会增加您的吞吐量。
  • 背后的想法setReuseAddress是允许多个注册到同一个多播端点。不是为了增加吞吐量。
  • 如果您认为接收和发送缓冲区可能会被流量溢出，则可以使用DatagramSocket#setReceiveBufferSizeand增加接收和发送缓冲区DatagramSocket#setSendBufferSize。
于 2021-07-24T16:27:00.473 回答