Netty 实现群聊功能：在业务逻辑处理器中实现广播和转发

本文将介绍使用 Netty 实现群聊功能，并在业务逻辑处理器中实现消息广播和转发等操作。

1. 创建 ChannelGroup 对象

首先，创建一个 ChannelGroup 对象，用于保存所有连接的客户端 Channel。

public class ChatServerHandler extends SimpleChannelInboundHandler<String> {

    private static ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    // ...
}

2. 添加客户端 Channel

当有新的客户端连接时，将其 Channel 添加到 ChannelGroup 中。

@Override
public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
    Channel incoming = ctx.channel();
    channels.add(incoming);
    // ...
}

3. 移除客户端 Channel

当有客户端断开连接时，将其 Channel 从 ChannelGroup 中移除。

@Override
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
    Channel incoming = ctx.channel();
    channels.remove(incoming);
    // ...
}

4. 广播消息

当有客户端发送消息时，遍历 ChannelGroup 中的所有 Channel，并将消息发送给所有客户端。

@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
    Channel incoming = ctx.channel();
    for (Channel channel : channels) {
        if (channel != incoming) {
            channel.writeAndFlush("[‘ + incoming.remoteAddress() + ’] ‘ + msg + ’\n’);
        }
    }
}

完整代码

public class ChatServerHandler extends SimpleChannelInboundHandler<String> {

    private static ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        Channel incoming = ctx.channel();
        channels.add(incoming);
        for (Channel channel : channels) {
            if (channel != incoming) {
                channel.writeAndFlush("【系统】‘ + incoming.remoteAddress() + ’ 加入\n");
            }
        }
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        Channel incoming = ctx.channel();
        channels.remove(incoming);
        for (Channel channel : channels) {
            if (channel != incoming) {
                channel.writeAndFlush("【系统】‘ + incoming.remoteAddress() + ’ 离开\n");
            }
        }
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
        Channel incoming = ctx.channel();
        for (Channel channel : channels) {
            if (channel != incoming) {
                channel.writeAndFlush("[‘ + incoming.remoteAddress() + ’] ‘ + msg + ’\n’);
            }
        }
    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        Channel incoming = ctx.channel();
        System.out.println("【系统】‘ + incoming.remoteAddress() + ’ 异常");
        cause.printStackTrace();
        ctx.close();
    }
}

本文仅提供基本实现，实际应用中可能需要根据具体需求进行扩展和优化。例如，可以添加用户身份验证、私聊功能、消息历史记录等功能。

希望本文能帮助您理解使用 Netty 实现群聊功能的基本原理，并提供一些参考代码。