import ohos.net.MulticastSocket;
import ohos.net.DatagramPacket;
import ohos.net.Inet4Address;
import java.io.IOException;

public class MulticastSocketExample {
    public static void main(String[] args) {
        try {
            // 创建 MulticastSocket 对象，并绑定到指定的组播地址和端口
            MulticastSocket multicastSocket = new MulticastSocket(12345);
            Inet4Address multicastGroup = (Inet4Address) Inet4Address.getByName("239.0.0.1");
            multicastSocket.joinGroup(multicastGroup);

            // 创建 DatagramPacket 用于发送数据
            String message = "Hello, multicast!";
            byte[] sendData = message.getBytes();
            DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, multicastGroup, 12345);

            // 发送数据
            multicastSocket.send(sendPacket);

            // 创建 DatagramPacket 用于接收数据
            byte[] receiveData = new byte[1024];
            DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);

            // 接收数据
            multicastSocket.receive(receivePacket);

            // 处理接收到的数据
            String receivedMessage = new String(receivePacket.getData(), 0, receivePacket.getLength());
            System.out.println("Received Message: " + receivedMessage);

            // 离开组播组
            multicastSocket.leaveGroup(multicastGroup);

            // 关闭 MulticastSocket
            multicastSocket.close();

        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}