你好,我正在尝试java组播。
我有一个WIFI路由器在- 10.0.0.1(网关)
和两个节点:
Node_1 - 10.0.0.4Node_2 - 10.0.0.3
我的IP组播发送者看起来像:
private static class Sender extends Thread
{
// Create the socket but we don't bind it as we are only going to send data
private MulticastSocket s;
private static int senderPort = 15000;
private static String group = "225.4.5.6";
public Sender() throws IOException
{
s = new MulticastSocket(senderPort);
s.setInterface(InetAddress.getLocalHost());
s.joinGroup(InetAddress.getByName(group));
}
@Override
public void run() {
Integer data = 1;
while(true)
{
try {
s.send(new DatagramPacket(data.toString().getBytes(), data.toString().getBytes().length, InetAddress.getByName(group), senderPort));
Thread.sleep(3000);
data++;
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
System.out.println("Sender - UnknownHostException");
}catch (IOException e) {
// TODO Auto-generated catch block
System.out.println("Sender - IOException");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
和我的IP多播接收器看起来像:
private static class Receiver extends Thread
{
private MulticastSocket s;
private static int receiverPort = 15000;
private static String group = "225.4.5.6";
public Receiver() throws IOException
{
s = new MulticastSocket(receiverPort);
s.setInterface(InetAddress.getLocalHost());
s.joinGroup(InetAddress.getByName(group));
}
@Override
public void run() {
while (true)
{
byte buf[] = new byte[1024];
DatagramPacket pack = new DatagramPacket(buf, buf.length);
try {
System.out.println("Receiver waiting for data");
s.receive(pack);
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.write(pack.getData(),0,pack.getLength());
System.out.println();
}
}
}
当我有两个发送方和接收方在同一节点它工作,但当我有他们在不同的节点它不工作。
我在这里错过了什么?
通过对本地主机调用setInterface(),可以防止joinGroup()消息离开当前主机。这对发送方来说并不重要,因为发送方不需要加入组,但对接收方来说,它会阻止其他主机、路由器等知道接收主机在组中。