UDP协议类_DatagramSocket——组播代码实现

组播地址：224.0.0.0--239.225.225.225，其中224.0.0.0--224.0.0.225为预留的组播地址，我们一般使用224.0.1.0及其之后的地址

public class ClientDemo {

    public static void main(String[] args) throws IOException {
        // 组播 DatagramSocket客户端发送数据的步骤

        // 1：创建DatagramSocket客户端对象
        DatagramSocket ds = new DatagramSocket();
        // 2：创建数据并打包（DatagramPacket）
        String s = "组播，你好啊。。。";
        byte[] bytes = s.getBytes();
        // 这里的地址是组播的地址
        InetAddress address = InetAddress.getByName("224.0.1.0");
        int port = 10000;
        DatagramPacket dp = new DatagramPacket(bytes, bytes.length, address, port);
        // 3：调用DatagramSocket客户端对象的方法发送数据
        System.out.println("发送数据前");
        ds.send(dp);
        System.out.println("发送数据后");
        // 4：释放资源
        ds.close();

    }

}

public class ServiceDemo {

    public static void main(String[] args) throws IOException {
        // DatagramSocket接收端接收数据的步骤

        // 1、创建组播接收端对象 new MulticastSocket(10000)表示从10000端口接收数据，如果不写参数，默认从随机端口接收数据。
        MulticastSocket ms = new MulticastSocket(10000);

        // 2、创建一个用于接收数据的箱子
        DatagramPacket dp = new DatagramPacket(new byte[1024], 1024);

        // 3、将接收端放入一个组播中,就是将当前计算机绑定一个组播地址，表示添加到这一组中
        ms.joinGroup(InetAddress.getByName("224.0.1.0"));

        // 4、调用DatagramSocket接收端对象的方法接收数据并放入箱子
        System.out.println("接收数据前");
        ms.receive(dp);
        System.out.println("接收数据后");

        // 5、解析箱子（数据包），并把数据展示
        byte[] data = dp.getData();
        int length = dp.getLength();
        String s = new String(data, 0, length);
        System.out.println(s);
        
        // 6、释放资源
        ms.close();

    }

}