netty实现私聊效果

Netty可以通过自定义协议实现私聊功能，具体实现步骤如下：

1. 定义私聊消息的协议格式，例如：[私聊目标用户ID]消息内容。

2. 在Netty服务端的ChannelHandler中，根据协议格式解析出私聊目标用户ID和消息内容，并将消息发送给目标用户。

3. 在Netty客户端中，发送私聊消息时需要按照协议格式构造消息，并将消息发送给服务端。

4. 在Netty客户端中，接收到私聊消息时需要根据协议格式解析出发送者ID和消息内容，并将消息显示在客户端界面上。

下面是一个简单的示例代码，实现了基于Netty的私聊功能：

// 服务端ChannelHandler
public class ChatServerHandler extends SimpleChannelInboundHandler<String> {
    // 存储所有连接的客户端Channel
    private static final ChannelGroup channels = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        // 新客户端连接时，将其Channel加入ChannelGroup
        channels.add(ctx.channel());
    }

    @Override
    protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
        // 解析私聊消息协议格式
        if (msg.startsWith("[私聊")) {
            int endIndex = msg.indexOf("]");
            if (endIndex != -1) {
                String targetUserId = msg.substring(4, endIndex);
                String content = msg.substring(endIndex + 1);
                // 遍历所有客户端Channel，找到目标用户并发送私聊消息
                for (Channel channel : channels) {
                    if (channel != ctx.channel()) {
                        if (channel.attr(ChatConstants.USER_ID).get().equals(targetUserId)) {
                            channel.writeAndFlush("[" + ctx.channel().attr(ChatConstants.USER_ID).get() + "私聊你]：" + content);
                            break;
                        }
                    }
                }
            }
        } else {
            // 广播消息给所有客户端
            for (Channel channel : channels) {
                if (channel != ctx.channel()) {
                    channel.writeAndFlush("[" + ctx.channel().attr(ChatConstants.USER_ID).get() + "]：" + msg);
                }
            }
        }
    }
}

// 客户端发送私聊消息
private void sendPrivateMessage(String targetUserId, String content) {
    String message = "[私聊" + targetUserId + "]" + content;
    channel.writeAndFlush(message);
}

// 客户端接收私聊消息
@Override
protected void channelRead0(ChannelHandlerContext ctx, String msg) throws Exception {
    // 解析私聊消息协议格式
    if (msg.startsWith("[私聊")) {
        int endIndex = msg.indexOf("]");
        if (endIndex != -1) {
            String senderId = msg.substring(4, endIndex);
            String content = msg.substring(endIndex + 1);
            // 显示私聊消息
            showMessage("[" + senderId + "私聊你]：" + content);
        }
    } else {
        // 显示广播消息
        showMessage(msg);
    }
}