Intro
有许多关于创建多播发布者和接收者的教程 .
我使用了一个发现here的一些修改 .
其他几个:
请注意,这些教程都非常相似 .
Details:
服务器在端口 7777
上运行并将数据报发送到 224.0.0.0
(我在多播范围内测试了几个其他的ip: 224.0.0.0
到 239.255.255.255
,但是这些都不起作用)
然后,客户端加入多播组 224.0.0.0
并等待数据包响应(作为线程运行)
extra:我发送一条消息,如: 123.23.13.12[host-name]:1234
作为数据报数据 .
Problem:
来自服务器(在localhost上)的多播数据包未到达客户端(在localhost上) .
客户端包括一个java控制台应用程序(下面的代码)和Android Emulator上的Android应用程序 . 两个客户端都不接收多播数据包 .
我知道正在发送多播数据包,因为这显示在Wireshark中
您将在下面找到我所拥有的基本示例 .
TL;DR :服务器发送多播数据包(通过Wireshark确认)但客户端没有收到它们 .
建议非常欢迎!
UPDATE
根据 Just another Java programmer
的评论,我检查了我的防火墙 . 瞧,我的防火墙正在落在 input
和 forward
链上 . 我将此设置为 accept
所有传入(暂时)
根据 Ron Maupin
的评论 .
-
我已经更改了发送的消息以排除主机名,因此发送的消息是
123.12.13.23:1234
-
我已将组播发送地址更改为
239.254.0.0
,这在指定范围内(请参阅Ron的评论) -
多播端口设置为
7777
-
在
broadcastServer()
try catch
块中使用s.setInterface(InetAddress.getLocalHost())
设置传出接口
应用这些更改后,客户端仍然不会收到任何数据包 .
Code:
服务器端(控制台应用程序):
String multicastAddress = "239.254.0.0", multicastPort = 7777;
private void broadcastServer() {
String message = null;
MulticastSocket s = null;
InetAddress local = null, group = null;
InetAddress[] allByName;
try {
local = InetAddress.getLocalHost();
s = new MulticastSocket(multicastPort);
s.setReuseAddress(true);
s.setInterface(local)
s.joinGroup(InetAddress.getByName(multicastAddress));
group = InetAddress.getByName(multicastAddress);
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
MulticastSocket socket = s;
// getNetworkIP() gets lan network ip
// serverport = 1025
message = local.getHostAddress() + ":" + String.valueOf(serverPort);
byte[] buf = message.getBytes();
DatagramPacket packet = new DatagramPacket(buf, buf.length, group, multicastPort);
thdBroadcaster = new Thread(() -> {
while (bRunServer) {
try {
Thread.sleep(1000);
printf("[Broadcast] Broadcasting...");
socket.send(packet);
printf("OK\n");
printf("");
} catch (IOException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
socket.close();
});
thdBroadcaster.start();
}
客户端(控制台应用):
String multicastAddress = "239.254.0.0", multicastPort = 7777;
private void startServerListenerThread() {
Thread thdServerListener = new Thread(new Runnable() {
@Override
public void run() {
MulticastSocket socket = null;
InetAddress group = null;
try {
socket = new MulticastSocket(multicastPort);
socket.setReuseAddress(true);
group = InetAddress.getByName(multicastAddress);
socket.joinGroup(group);
handleServerBroadcasts(socket);
socket.leaveGroup(group);
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
private void handleServerBroadcasts(final MulticastSocket socket) {
while (true){
try {
byte[] buf = new byte[256];
DatagramPacket packet = new DatagramPacket(buf, buf.length);
socket.receive(packet);
String received = new String(packet.getData());
String address = received.substring(0, received.indexOf(":"));
String port = received.substring(received.indexOf(":") + 1);
System.out.println();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception x){
x.printStackTrace();
}
}
}
});
thdServerListener.start();
}
2 回答
绑定套接字后,您正在调用
setReuseAddress()
. 它没有效果 . 您需要创建一个未绑定的MulticastSocket
,调用setReuseAddress()
,然后绑定它 .解决方案最终是一个微不足道的变化 .
解决问题就像改变一样简单:
至
on the server side ONLY
注意:需要防火墙,检查是否允许通过多播数据包 . 我使用的接口是localhost,但不是必需的 . 但是,这可以通过获取所需的指定接口来设置 .
UPDATE
EJP的评论:
我将用过的端口更改为
8888
. 此端口用于发送服务器数据报,并用于客户端连接MulticastSocket