粘包和半包的解决（一）

1. public class HelloWordServer {
2. static final Logger log = LoggerFactory.getLogger(HelloWordServer.class);
3. 
4. public static void main(String[] args) {
5. NioEventLoopGroup boss = new NioEventLoopGroup(1);
6. NioEventLoopGroup worker = new NioEventLoopGroup();
7. try {
8. ServerBootstrap serverBootstrap = new ServerBootstrap()
9.                     .channel(NioServerSocketChannel.class)
10.                     .group(boss, worker)
11.                     .childHandler(new ChannelInitializer<SocketChannel>() {
12. protected void initChannel(SocketChannel ch) throws Exception {
13.                             ch.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
14.                             ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
15. public void channelActive(ChannelHandlerContext ctx) throws Exception {
16.                                     log.debug("connected{}", ctx.channel());
17. super.channelActive(ctx);
18.                                 }
19. 
20. @Override
21. public void channelInactive(ChannelHandlerContext ctx) throws Exception {
22.                                     log.debug("disconnected{}", ctx.channel());
23. super.channelActive(ctx);
24.                                 }
25. 
26.                             });
27.                         }
28.                     });
29. ChannelFuture channelFuture = serverBootstrap.bind(8080);
30.             channelFuture.sync();
31.             log.debug("{} bing",channelFuture.channel());
32.             channelFuture.channel().closeFuture().sync();
33. 
34.         } catch (Exception e) {
35.             log.error("server error",e);
36.         }
37.     }
38. 
39. }

1. public class HelloWordClient {
2. static final Logger log = LoggerFactory.getLogger(HelloWordServer.class);
3. public static void main(String[] args) {
4. NioEventLoopGroup work = new NioEventLoopGroup();
5. try {
6. Bootstrap bootstrap = new Bootstrap()
7.                     .channel(NioSocketChannel.class)
8.                     .group(work)
9.                     .handler(new ChannelInitializer<SocketChannel>() {
10. protected void initChannel(SocketChannel ch) throws Exception {
11.                             log.debug("connetred");
12.                             ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
13. public void channelActive(ChannelHandlerContext ctx) throws Exception {
14.                                     log.debug("sending");
15. Random r = new Random();
16. char c = 'a';
17. for (int i = 0; i < 10; i++) {
18. ByteBuf buffer = ctx.alloc().buffer();
19.                                         buffer.writeBytes(new byte[]{0, 1, 2, 3, 4,5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15});
20.                                         ctx.writeAndFlush(buffer);
21.                                     }
22. super.channelActive(ctx);
23.                                 }
24.                             });
25.                         }
26.                     });
27. ChannelFuture channelFuture = bootstrap.connect("127.0.0.1", 8080).sync();
28.             channelFuture.channel().closeFuture().sync();
29. 
30. 
31.         }catch (Exception e){
32.             log.error("client error...");
33.         }finally {
34.             work.shutdownGracefully();
35.         }
36. 
37.     }

1. ByteBuf buffer = ctx.alloc().buffer();
2. for (int i = 0; i < 10; i++) {
3.     buffer.writeBytes(new byte[]{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15});
4. }
5. ctx.writeAndFlush(buffer);

serverBootstrap.option(ChannelOption.SO_RCVBUF, 10);