/netty-study

Netty学习

Primary LanguageJava

Netty学习

1、简介

Netty是一个NIO客户端服务器框架，可以快速简单地开发协议服务器和客户端等网络应用程序。它极大地简化TCP和UDP套接字服务器等网络编程。

2、使用

  • maven依赖
<dependency>
    <groupId>io.netty</groupId>
    <artifactId>netty-all</artifactId>
    <version>4.1.20.Final</version>
</dependency>

  • 事例一

  • 服务器端

    • 通过创建EventLoopGroup实例创建NIO线程组

    • 创建ServerBootstrap对象，它是Netty用于启动NIO服务端的辅助启动类，并调用ServerBootstrap对象的group方法，将线程组传递到ServerBootstrap实例

    • 设置创建的channel为NioServerSocketChannel，NioServerSocketChannel相当于JDK NIO中的ServerSocketChannel

    • 设置NioServerSocketChannel的TCP参数

    • 绑定I/O事件的处理类，用于处理网络I/O事件

    • 服务端启动辅助类配置完成之后，调用bind方法绑定监听端口，随后调用同步阻塞方法sync等待任务完成，并返回一个ChannelFuture对象，用于异步操作的通知回调

    • 使用channelFuture.channel().closeFuture().sync();方法进行阻塞，等待服务端链路关闭之后main函数才退出

    • 使用NIO线程组的shutdownGracefully，释放资源

  • 客户端操作与服务端基本类似，不过启动辅助类为Bootstrap,且channel设置为NioSocketChannel

3、使用Netty的半包解码器解决TCP粘包/拆包问题

  • 利用LineBasedFrameDecoder + StringDecoder(处理按行切换的文本)解决TCP粘包/拆包问题

    • 分别在服务端和客户端添加两个解码器

      • 服务端
      socketChannel.pipeline().addLast(new LineBasedFrameDecoder(1024));
socketChannel.pipeline().addLast(new StringDecoder());
      • 客户端
      socketChannel.pipeline().addLast(new LineBasedFrameDecoder(1024));
socketChannel.pipeline().addLast(new StringDecoder());

    • 分别在服务端和客户端的处理类中进行修改

    • 服务端

        @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        String str = (String) msg;
        System.out.println("信息：" + str + "; the counter is " + ++counter);
        String currentime = "QUERY TIME ORDER".equalsIgnoreCase(str) ? new Date(
                System.currentTimeMillis()
        ).toString() : "BAD ORDER";
        currentime = currentime + System.getProperty("line.separator");
        ByteBuf req = Unpooled.copiedBuffer(currentime.getBytes());
        // 异步发送消息给客户端
        ctx.writeAndFlush(req);
    }
    • 客户端
        @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        String body = (String) msg;
        System.out.println("Now is : " + body + "; the counter is " + ++counter);
    }

  • 说明

LineBasedFrameDecoder会依次便利ByteBuf中的可读字节，判断是否有\n或\r\n,如果有，就以次位置为结束位置，LineBasedFrameDecoder是以换行符为结束标志的解码器
StringDecoder将接收到的对象转换为字符串