Netty服务器事件

Question

我正在尝试在Netty中实现一个基本的多客户端聊天，我有一点被卡住了！代码是：

public class Server {

public static void main(String[] args) throws Exception {
    ChannelFactory factory =
        new NioServerSocketChannelFactory(
                Executors.newCachedThreadPool(),
                Executors.newCachedThreadPool());

    ServerBootstrap bootstrap = new ServerBootstrap(factory);

    bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
        public ChannelPipeline getPipeline() {
            return Channels.pipeline(new ServerHandler());
        }
    });

    bootstrap.setOption("child.tcpNoDelay", true);
    bootstrap.setOption("child.keepAlive", true);

    bootstrap.bind(new InetSocketAddress(8888));
}

}

public class ServerHandler extends SimpleChannelHandler {

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
        ChannelBuffer buf = (ChannelBuffer) e.getMessage();
        Channel ch=e.getChannel();
        while(buf.readable()) {
            System.out.println((char) buf.readByte());
            System.out.flush();
        }
        ch.write(e.getMessage());
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
    e.getCause().printStackTrace();

    Channel ch = e.getChannel();
    ch.close();
}

}

我想先读一下留言

Answer 1

我怀疑问题在于从缓冲区读取会改变缓冲区的读取索引。当您将缓冲区写入通道时，读取索引位于数据的末尾。有几个选择

• 使用readableBytes（）确定可读字节数，然后使用getByte（索引）检索字节而不更改读取索引
• 在读取循环中的字节前后使用markReaderIndex和resetReaderIndex
• 使用缓冲区。复制以获取共享基础数据但管理separeat读/写索引的缓冲区

有关详细信息，请参阅ChannelBuffer（Netty 3）。

Answer 2

下面是netty3和netty4的聊天应用程序示例。

此外，对于聊天客户机，您似乎正在使用服务器端类：NioServerSocketChannelFactory。我想您需要NioClientSocketChannelFactory。