[Asm] 纯文本查看 复制代码 public void run() throws Exception {
EventLoopGroup bossGroup = new NioEventLoopGroup(); // (1)
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap(); // (2)
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() { // (4)
@Override
public void initChannel(SocketChannel ch) throws Exception {
ch.pipeline().addLast(new ByteToMessageDecoder() {
protected void decode(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf, List<Object> list) throws Exception {
byte[] bytes = ByteBufUtil.getBytes(byteBuf.copy());
System.out.println(new String(bytes));
if (byteBuf.readableBytes() < 4) {
return; // (3)
}
list.add(byteBuf.readBytes(4)); // (4)
}
});
ch.pipeline().addLast(new DiscardServerHandler());
}
})
.option(ChannelOption.SO_BACKLOG, 128) // (5)
.childOption(ChannelOption.SO_KEEPALIVE, true);
// 绑定端口,开始接收进来的连接
ChannelFuture f = b.bind(port).sync(); // (7)
// 等待服务器 socket 关闭 。
// 在这个例子中,这不会发生,但你可以优雅地关闭你的服务器。
f.channel().closeFuture().sync();
} finally {
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
}
这个代码启动后 怎么拿握手包呢? 这个sokcet好像是基于tcp的 他把tcp已经实现了 我现在的需求是自己实现协议 拿到的流可以直接判断是tcp还是udp 刚学不是很明白这块
我现在的需求是做一个转发服务器
比如abc三个服务器 a和c要通信必须要通过b,我能理解的是a发过来的数据包直接转发给c,包括tcp握手包,而不是a和b建立tcp链接后再发送数据包过去吧 好迷茫啊
|