netty UDP发送组播代码

Netty是一个高性能、异步事件驱动的网络应用框架，常用于Java中开发网络服务。在Netty中，如果你想实现UDP（用户数据报协议）的组播发送，你需要利用它的MulticastChannel和DatagramPacket功能。以下是一个简单的示例代码：

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.DatagramPacket;
import io.netty.channel.socket.MulticastSocket;
import io.netty.channel.socket.nio.NioDatagramChannel;

import java.net.InetAddress;
import java.net.MulticastSocketException;
import java.util.concurrent.TimeUnit;

public class NettyUdpGroupcastExample {
    public static void main(String[] args) throws InterruptedException, MulticastSocketException {
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        try {
            Bootstrap bootstrap = new Bootstrap();
            bootstrap.group(workerGroup)
                    .channel(NioDatagramChannel.class)
                    .handler(new ChannelInitializer<>() {
                        @Override
                        protected void initChannel(Channel ch) throws Exception {
                            // 创建一个自定义处理器来处理收到的数据包
                            ch.pipeline().addLast(new MyDatagramHandler());
                        }
                    });

            // 设置组播地址和端口
            InetAddress groupAddress = InetAddress.getByName("224.0.0.1"); // 组播地址
            int port = 12345; // 集群端口

            // 初始化并连接到组播组
            ChannelFuture future = bootstrap.joinGroup(groupAddress, port);
            future.sync();

            // 发送组播报文
            byte[] payload = "Hello, Group!".getBytes(); // 数据内容
            DatagramPacket packet = new DatagramPacket(payload, payload.length, groupAddress, port);

            // 发送数据
            Channel channel = future.channel();
            channel.writeAndFlush(packet).sync();

            // 停止组播接收，关闭连接
            future.channel().closeGroup();
            future.channel().close();
        } finally {
            workerGroup.shutdownGracefully(0, 0, TimeUnit.MILLISECONDS);
        }
    }
}

// 自定义处理器类
class MyDatagramHandler extends SimpleChannelInboundHandler< DatagramPacket > {
    @Override
    public void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) {
        System.out.println("Received data from multicast: " + new String(msg.content()));
        ctx.close(); // 示例中只处理一条数据后就关闭，实际应用中根据需求决定是否继续接收
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        cause.printStackTrace();
        ctx.close();
    }
}

相关问题--
1. 如何在Netty中创建一个UDP的MulticastSocket？
2. 在上述代码中，`joinGroup`方法的作用是什么？
3. 除了发送数据，`MyDatagramHandler`还做了哪些处理？