【发布时间】:2014-12-01 02:29:03
【问题描述】:
我正在尝试从 TCP 客户端应用程序获取字节数据。根据 Netty 项目的文档,我找到了这段代码并在我的系统中使用它:
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.option(ChannelOption.SO_KEEPALIVE, true)
.handler(new LoggingHandler(LogLevel.INFO))
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4));
p.addLast("bytesDecoder", new ByteArrayDecoder());
p.addLast(new ServerHandler());
}
});
但在我的 ServerHandler 类中,我无法找到并调用该方法:
void channelRead (ChannelHandlerContext ctx, byte[] bytes){}
而不是典型的:
void channelRead (ChannelHandlerContext ctx, Object msg){}
提前致谢!
【问题讨论】: