Netty入门Demo使用

Love The Way You Lie 2022-03-27 01:49 257阅读 0赞

## 实现一个简单的服务端 demo ##

1、maven项目添加netty的jar

![20190111163714149.png][]

2、自定义一个类处理服务器接收到的消息，该类主要是实现了接收客户端发来的消息，并输出到控制台。

package com.coder.server;
    
    import io.netty.buffer.ByteBuf;
    import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.ChannelInboundHandlerAdapter;
    import io.netty.util.CharsetUtil;
    import io.netty.util.ReferenceCountUtil;
    
    /**
     * 输出接收到的消息
     * @author Coder
     *
     */
    public class HelloServerHandler extends ChannelInboundHandlerAdapter {
        /**
         * 收到数据时调用
         */
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            try {
                ByteBuf in = (ByteBuf)msg;
                System.out.print(in.toString(CharsetUtil.UTF_8));
            } finally {
                // 抛弃收到的数据
                ReferenceCountUtil.release(msg);
            }
            
    //        ctx.write(msg);
    //        ctx.flush();
        }
        
        /**
         * 当Netty由于IO错误或者处理器在处理事件时抛出异常时调用
         */
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            // 当出现异常就关闭连接
            cause.printStackTrace();
            ctx.close();
        }
    }

3、然后我们就能实现一个简单的服务端程序了

Netty 服务器的通信步骤为：

1.   创建两个NIO线程组，一个专门用于接收来自客户端的连接，另一个则用于处理已经被接收的连接。
2.   创建一个ServerBootstrap对象，配置Netty的一系列参数，例如接受传出数据的缓存大小等。
3.   创建一个用于实际处理数据的类ChannelInitializer，进行初始化的准备工作，比如设置接受传出数据的字符集、格式以及实际处理数据的接口。
4.   绑定端口，执行同步阻塞方法等待服务器端启动即可

package com.coder.server;
    
    import io.netty.bootstrap.ServerBootstrap;
    import io.netty.channel.ChannelFuture;
    import io.netty.channel.ChannelInitializer;
    import io.netty.channel.ChannelOption;
    import io.netty.channel.EventLoopGroup;
    import io.netty.channel.nio.NioEventLoopGroup;
    import io.netty.channel.socket.SocketChannel;
    import io.netty.channel.socket.nio.NioServerSocketChannel;
    
    public class HelloServer {
        private int port;
        
        public HelloServer(int port) {
            this.port = port;
        }
        
        public void run() throws Exception {
            EventLoopGroup bossGroup = new NioEventLoopGroup();        // 用来接收进来的连接
            EventLoopGroup workerGroup = new NioEventLoopGroup();    // 用来处理已经被接收的连接
            System.out.println("准备运行端口：" + port);
            
            try {
                ServerBootstrap b = new ServerBootstrap();
                b.group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)            // 这里告诉Channel如何接收新的连接
                .childHandler( new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) throws Exception {
                        // 自定义处理类
                        ch.pipeline().addLast(new HelloServerHandler());
                    }
                })
                .option(ChannelOption.SO_BACKLOG, 128)
                .childOption(ChannelOption.SO_KEEPALIVE, true);
                
                // 绑定端口，开始接收进来的连接
                ChannelFuture f = b.bind(port).sync();
                
                // 等待服务器socket关闭
                f.channel().closeFuture().sync();
            } catch (Exception e) {
                workerGroup.shutdownGracefully();
                bossGroup.shutdownGracefully();
            }
        }
        
        public static void main(String[] args) throws Exception {
            int port = 10110;
            new HelloServer(port).run();
        }
    
    }

![2019011116394194.png][]

二、测试

我们可以去自定义客户端程序，这里为了方便使用 telnet 充当客户端。

需要注意的是，Windows 默认是没有开启 telnet 客户端的，需要我们手动开启。

菜单->控制面板->程序->打开或关闭Windows功能，设置如图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2Njg4MTQz_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2Njg4MTQz_size_16_color_FFFFFF_t_70 1][]

原文链接：[https://www.cnblogs.com/coderJiebao/p/Netty01.html][https_www.cnblogs.com_coderJiebao_p_Netty01.html]

[20190111163714149.png]: /images/20220327/1a38b98ab0a34aa1a682e9e51be19494.png
[2019011116394194.png]: /images/20220327/f7cb3266a72646dfa15c93227a4540e1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2Njg4MTQz_size_16_color_FFFFFF_t_70]: /images/20220327/197168dbdb1b40bab4648cf856eddfda.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2Njg4MTQz_size_16_color_FFFFFF_t_70 1]: /images/20220327/f5a37b894a4349f1b934456dbde0e423.png
[https_www.cnblogs.com_coderJiebao_p_Netty01.html]: https://www.cnblogs.com/coderJiebao/p/Netty01.html