【发布时间】：2013-02-03 03:26:28
【问题描述】：
我正在尝试实现一种将 UDP 数据包发送到多个接收器的方法。我认为在接收 DatagramSocket 实例上设置 setReuseAddress(true) 应该是可行的。
我的问题是，在某些情况下，我需要限制与本地计算机的通信 - 因此是 localhost 接口（下面的演示代码中的 useLocalhost=true）。在这种情况下，突然只有第一个接收器套接字获得传入的数据包，另外两个什么都看不到。
我在 Windows (oracle 64bit) 和 Linux (OpenJDK 64bit) 上对此进行了测试，因此我只看到了三种可能性：
- 这是一种预期且已知的行为（我不了解整个机制 - 也就是“我的大脑中的错误”）
- Java JRE 中存在错误
- 我的代码中有一个错误。
有人对此主题有任何经验吗？我可以帮助确定问题所在吗？
请参阅下面的最小工作示例来演示这一点。 请注意，我使用广播地址来模拟来自真实外部主机的网络数据包。
如果一切顺利，您应该会在末尾看到三行（按此顺序或不同顺序）：
Thread-0 - packet received
Thread-1 - packet received
Thread-2 - packet received
public static void main(String[] args) throws Exception {
boolean useLocalhost = true;
InetSocketAddress addr;
String sendPacketTo = "192.168.1.255"; // we use broadcast so that packet comes from an real external address
if (useLocalhost)
sendPacketTo = "localhost"; // does not work (only listener 1 received packet)
addr = new InetSocketAddress(15002);
new MyThread(addr).start(); // Datagram socket listener 1
new MyThread(addr).start(); // Datagram socket listener 2
new MyThread(addr).start(); // Datagram socket listener 3
DatagramSocket so = new DatagramSocket();
so.setBroadcast(true); // does not change anything
so.connect(new InetSocketAddress(sendPacketTo, 15002));
so.send(new DatagramPacket("test".getBytes(), 4));
Thread.sleep(1000);
System.exit(0);
}
public static class MyThread extends Thread {
DatagramSocket socket;
public MyThread(InetSocketAddress addr) throws SocketException {
super();
setDaemon(true);
socket = new DatagramSocket(null);
socket.setReuseAddress(true);
socket.setBroadcast(true); // does not change anything
socket.bind(addr);
System.out.println("Listener started: " + socket.getLocalAddress());
}
public void run() {
byte[] buf = new byte[10];
DatagramPacket p = new DatagramPacket(buf, buf.length);
try {
socket.receive(p);
System.out.println(Thread.currentThread().getName() + " - packet received");
} catch (IOException e) {
e.printStackTrace();
}
}
}
【问题讨论】：
-
你的代码有点尝试做广播，有点尝试做多播，有点尝试做单播。选择一个模型并坚持下去！例如，如果您尝试进行广播，请使用广播地址。
-
@David：请阅读我的 cmets。广播地址仅用于模拟传入流量。否则我的例子会复杂得多，因为第二个程序需要在第二台 PC 上运行。
-
@Robert 所以如果这不是你的真实代码为什么要发布它？
-
这是一个演示问题和我的问题的最小工作示例。