Netty 多用户聊天客户端示例 - Java 代码实现

import io.netty.handler.codec.string.StringDecoder; import io.netty.handler.codec.string.StringEncoder;

import java.io.BufferedReader; import java.io.InputStreamReader; //客户端： public class MultiChatClient { private final String host; private final int port; private ChannelHandlerContext ctx; // 构造函数，初始化主机和端口 public MultiChatClient(String host, int port) { this.host = host; this.port = port; } // 客户端运行方法 public void run() throws Exception { EventLoopGroup group = new NioEventLoopGroup(); try { Bootstrap b = new Bootstrap(); b.group(group) .channel(NioSocketChannel.class) .option(ChannelOption.SO_KEEPALIVE, true) .handler(new ChannelInitializer() { @Override public void initChannel(SocketChannel ch) throws Exception { // 添加解码器和编码器，以及客户端处理程序 ch.pipeline().addLast(new StringDecoder(), new StringEncoder(), new MultiChatClientHandler()); } }); // 连接到服务器 ChannelFuture f = b.connect(host, port).sync(); ctx = f.channel().pipeline().context(MultiChatClientHandler.class); // 从控制台读取输入，并将其发送到服务器 BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); while (true) { String line = in.readLine(); if (line == null) { break; } if (line.equals('LIST')) { String username = null; ctx.writeAndFlush(line + '|' + username + '\n'); // 发送LIST命令和用户名到服务器 } else { ctx.writeAndFlush(line + '\n'); // 发送输入的消息到服务器 } } /* BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); while (true) { String line = in.readLine(); if (line == null) { break; } ctx.writeAndFlush(line + '\n'); }

          */

    } finally {
        // 关闭事件循环组
        group.shutdownGracefully();
    }
}
// 主方法，创建客户端实例并运行
public static void main(String[] args) throws Exception {
    String host = 'localhost';
    int port = 8080;
    new MultiChatClient(host, port).run();
}

}