Java网络编程(四) 通过MulticastSocket实现广播

广播是网络通信中常用的一种方式，将数据包一次发送给多台机器。广播本身也是UDP通信，只是发送时地址不是具体某一台机器的IP，而是标识一组计算机D类IP地址，凡是加入这个组的机器都可以接收到数据。

这种情况下，发送数据的机器只有一台，这里将其称为Server，其代码如下

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.UnknownHostException;
import java.text.SimpleDateFormat;
import java.util.Date;

public class ServerMulticastSocketTest {
public static void main(String[] args) throws UnknownHostException, IOException, InterruptedException {
MulticastSocket multicastSocket = new MulticastSocket();
InetAddress address = InetAddress.getByName("239.0.0.1"); // 必须使用D类地址
multicastSocket.joinGroup(address); // 以D类地址为标识，加入同一个组才能实现广播

while (true) {
String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
byte[] buf = time.getBytes();
DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length);
datagramPacket.setAddress(address); // 接收地址和group的标识相同
datagramPacket.setPort(10000); // 发送至的端口号

multicastSocket.send(datagramPacket);
Thread.sleep(1000);
}
}
}

Client端代码

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.net.MulticastSocket;
import java.net.UnknownHostException;

public class ClientMulticastSocketTest {
public static void main(String[] args) throws UnknownHostException, IOException, InterruptedException {
MulticastSocket multicastSocket = new MulticastSocket(10000); // 接收数据时需要指定监听的端口号
InetAddress address = InetAddress.getByName("224.0.0.1");
multicastSocket.joinGroup(address);
byte[] buf = new byte[1024];

while (true) {
DatagramPacket datagramPacket = new DatagramPacket(buf, buf.length);
multicastSocket.receive(datagramPacket); // 接收数据，同样会进入阻塞状态
byte[] message = new byte[datagramPacket.getLength()]; // 从buffer中截取收到的数据
System.arraycopy(buf, 0, message, 0, datagramPacket.getLength());
System.out.println(datagramPacket.getAddress());
System.out.println(new String(message));
}
}
}

运行结果

/10.13.180.80

2016-11-22 23:43:03

/10.13.180.80

2016-11-22 23:43:04

/10.13.180.80

2016-11-22 23:43:05

/10.13.180.80

2016-11-22 23:43:06

可以看出，除了初始化之外，MulticastSocket 和 DatagramSocket 的使用方式几乎一样。而实际上前者就是后者的子类。

原文：http://www.androidstar.cn/java网络编程四-通过multicastsocket实现广播/