多个线程监听一个 UDP 端口？

Question

我有问题。我有一个在 UDP 端口上侦听服务器的客户端程序。这些服务器发送带有 TCP 端口的数据包（每秒一个）。这些端口是识别服务器的方式。当这样的数据包第一次到达时，服务器被存储在一个集中的集合中。如果服务器在 5 秒内未能发送这些数据包，则该服务器被视为离线并从集合中删除。

我想做的是为每个服务器生成一个新线程。这个线程应该只听一个服务器。如果服务器超时，线程会从集合中删除服务器并自行终止。

我已经用 ThreadPool 实现了这个，但它根本不起作用。到目前为止我发现的是，这可能是由于不同线程的检查，如果一个数据包确实是它应该收听的数据包，传入数据包的顺序完全混乱，导致混乱的删除和添加服务器到集合。

是否有可能不止一个线程可以监听一个 UDP 端口？我怎样才能实现期望的行为？

感谢您的帮助！

编辑

在主线程中：

datagramSocket = new DatagramSocket(udpPort);
datagramSocket.setReuseAddress(true);

以及在新线程中。

java.net.BindException: Address already in use
 [java]     at java.net.PlainDatagramSocketImpl.bind0(Native Method)
 [java]     at java.net.AbstractPlainDatagramSocketImpl.bind(AbstractPlainDatagramSocketImpl.java:95)
 [java]     at java.net.DatagramSocket.bind(DatagramSocket.java:376)
 [java]     at java.net.DatagramSocket.<init>(DatagramSocket.java:231)
 [java]     at java.net.DatagramSocket.<init>(DatagramSocket.java:284)
 [java]     at java.net.DatagramSocket.<init>(DatagramSocket.java:256)
 [java]     at proxy.ServerHandler.<init>(ServerHandler.java:32)
 [java]     at proxy.DatagramSocketListener.run(DatagramSocketListener.java:59)
 [java]     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
 [java]     at java.util.concurrent.FutureTask.run(FutureTask.java:262)
 [java]     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
 [java]     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
 [java]     at java.lang.Thread.run(Thread.java:744)

编辑 2

再次感谢！但现在在主线程中：

datagramSocket = new DatagramSocket();
datagramSocket.setReuseAddress(true);
datagramSocket.bind(new InetSocketAddress(udpPort));

在新线程中：

datagramSocket = new DatagramSocket();
datagramSocket.setReuseAddress(true);
datagramSocket.connect(server.getAddress(), udpPort);

结果：

 [java] java.net.SocketException: already bound
 [java]     at java.net.DatagramSocket.bind(DatagramSocket.java:360)
 [java]     at proxy.DatagramSocketListener.<init>(DatagramSocketListener.java:33)
 [java]     at proxy.ProxyCli.<init>(ProxyCli.java:74)
 [java]     at proxy.ProxyCli.main(ProxyCli.java:30)

但这是我第一次初始化DatagramSocket？？？

Answer 1

在新线程的同一端口上创建一个新套接字。您必须在包括原始套接字在内的所有套接字上设置 SO_REUSEADDR 才能实现这一点。然后，将新套接字连接到所需的目标。那么该套接字将只接收来自该目标的数据报。