Netty实现高效聊天室群发功能

本篇介绍如何使用Netty框架实现聊天室的群发消息功能，并提供详细的代码示例和解释。

// 群发消息方法
private void handleMessage(ChannelHandlerContext ctx, String roomName, String message) {
    StringBuilder sb = new StringBuilder();
    sb.append('[').append(ctx.channel().remoteAddress()).append('] ').append(message).append('
');
    // 遍历用户映射表，向指定聊天室中的用户发送消息
    for (Map.Entry<String, ChannelHandlerContext> entry : userMap.entrySet()) {
        if (entry.getKey().equals(roomName)) {
            entry.getValue().writeAndFlush(sb.toString());
        }
    }
}

代码解释:

handleMessage方法接收三个参数:
- ctx: ChannelHandlerContext对象，表示当前连接的上下文信息
- roomName: String类型，表示聊天室的名称
- message: String类型，表示要发送的消息内容
方法首先创建一个StringBuilder对象sb，用于拼接要发送的消息内容，包括发送者地址(ctx.channel().remoteAddress())和消息内容(message)。
接着遍历用户映射表userMap，该表存储了所有在线用户的用户名和对应的ChannelHandlerContext对象。
遍历过程中，如果用户的键值 (用户名) 与传入的聊天室名称相匹配，则通过用户的ChannelHandlerContext对象调用writeAndFlush方法发送消息。

总结:

这段代码演示了如何利用Netty框架实现聊天室的群发功能，通过遍历用户映射表，将消息发送给指定聊天室的所有用户，实现了高效的实时消息传递。