Netty 实现群聊功能：使用业务逻辑处理器实现消息广播和转发

Netty 是一个高性能、异步事件驱动的网络编程框架，它提供了基于 NIO 的 TCP/UDP/HTTP 协议栈的实现，可以轻松地构建高性能、可扩展的网络应用程序。在 Netty 中，我们可以通过业务逻辑处理器来实现群聊功能。

在实现群聊功能之前，我们需要先了解 Netty 的一些基本概念和组件，包括 Channel、ChannelHandlerContext、ChannelPipeline、EventLoop 等。Channel 是 Netty 中的核心概念，它代表了一个网络连接，可以用来读写数据。ChannelHandlerContext 是 ChannelHandler 和 ChannelPipeline 之间的桥梁，它提供了 ChannelHandler 访问 ChannelPipeline 和其他 ChannelHandler 的方法。ChannelPipeline 是 Netty 中的事件处理机制，它由一系列 ChannelHandler 组成，每个 ChannelHandler 都可以处理特定类型的事件。EventLoop 是 Netty 中的事件循环机制，它负责处理所有的 IO 事件和任务。

实现群聊功能的关键是消息的广播和转发。在 Netty 中，我们可以通过 ChannelGroup 来实现消息的广播，它是一个特殊的 Channel，可以将消息发送给所有已连接的客户端。在业务逻辑处理器中，我们可以通过 ChannelHandlerContext 获取 ChannelGroup，并将消息发送给所有的客户端。

下面是一个简单的群聊业务逻辑处理器的实现：

public class ChatServerHandler extends SimpleChannelInboundHandler<String> {

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

    @Override
    public void handlerAdded(ChannelHandlerContext ctx) throws Exception {
        Channel incoming = ctx.channel();
        channels.writeAndFlush("[SERVER] - ' + incoming.remoteAddress() + ' 加入\n");
        channels.add(incoming);
    }

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        Channel incoming = ctx.channel();
        channels.writeAndFlush("[SERVER] - ' + incoming.remoteAddress() + ' 离开\n");
        channels.remove(incoming);
    }

    @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("Client:" + incoming.remoteAddress() + "异常");
        cause.printStackTrace();
        ctx.close();
    }
}

在上面的代码中，我们继承了 SimpleChannelInboundHandler 类，并重写了 handlerAdded、handlerRemoved、channelRead0 和 exceptionCaught 方法。handlerAdded 方法会在客户端连接到服务器时被调用，handlerRemoved 方法会在客户端断开连接时被调用，channelRead0 方法会在接收到客户端消息时被调用，exceptionCaught 方法会在发生异常时被调用。

在 handlerAdded 方法中，我们将客户端加入到 ChannelGroup 中，并向所有客户端发送一条加入消息。在 handlerRemoved 方法中，我们将客户端从 ChannelGroup 中移除，并向所有客户端发送一条离开消息。在 channelRead0 方法中，我们遍历所有的客户端，将消息发送给除了发送者之外的所有客户端。在 exceptionCaught 方法中，我们处理异常并关闭连接。

通过上面的代码，我们就可以实现一个简单的群聊功能了。当有客户端连接到服务器时，所有客户端都会收到一条加入消息；当有客户端发送消息时，所有客户端都会收到这条消息；当有客户端断开连接时，所有客户端都会收到一条离开消息。