【Netty】——相关知识

「爱情、让人受尽委屈。」 2023-07-03 02:53 9阅读 0赞

依赖

<dependency>
                <groupId>io.netty</groupId>
                <artifactId>netty-all</artifactId>
                <version>4.1.30.Final</version>
            </dependency>

服务端

public class ServerClient{
    
        public void run() {
            //主线程组，用于接收客户端的请求，但是不做任何的具体的业务，老板一样接待客户
            EventLoopGroup boss = new NioEventLoopGroup(1);
            //工作线程，处理其他任务
            EventLoopGroup worker = new NioEventLoopGroup();
    
            try {
                ServerBootstrap server = new ServerBootstrap();
                server.group(boss,worker)
                        .channel(NioServerSocketChannel.class)
                        .childHandler(new ChildChannelHandler());
    
                //绑定端口
                ChannelFuture channelFuture = server.bind(8080).sync();
    
                System.out.println("服务器启动完成，监听端口：8080");
    
                //等待服务监听并关闭
                channelFuture.channel().closeFuture().sync();
            }catch (Exception e){
                e.printStackTrace();
            }finally {
                boss.shutdownGracefully();
                worker.shutdownGracefully();
            }
        }
    
        public static void main(String[] args) {
            ServerClient client = new ServerClient();
            client.run();
        }
    }

public class ServerHandler extends ChannelInboundHandlerAdapter {
        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
            ByteBuf in = (ByteBuf) msg;
            System.out.println("服务器收到消息："+in.toString(CharsetUtil.UTF_8));
            ctx.write(in);
        }
    
        @Override
        public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
            ctx.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);
        }
    
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            cause.printStackTrace();
            ctx.close();
        }
    
    }

客户端

public class Client {
        public void connect(int port, String host) {
            //工作线程组
            EventLoopGroup group = new NioEventLoopGroup();
    
            try {
    
                Bootstrap client = new Bootstrap();
                client.group(group)
                        .channel(NioSocketChannel.class)
                        .handler(new ChildChannelHandler());
    
                //发起异步连接
                ChannelFuture channelFuture = client.connect(host, port).sync();
    
                channelFuture.channel().closeFuture().sync();
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                group.shutdownGracefully();
            }
        }
    
        public static void main(String[] args) {
            Client client = new Client();
            client.connect(8080,"127.0.0.1");
        }
    }

public class ClientHandler extends SimpleChannelInboundHandler<ByteBuf> {
    
        @Override
        public void channelActive(ChannelHandlerContext ctx) throws Exception {
            ctx.writeAndFlush(Unpooled.copiedBuffer("这是一个netty实例程序！\n", CharsetUtil.UTF_8));
        }
    
        @Override
        protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf byteBuf) throws Exception {
            System.out.println("客户端接收到消息："+byteBuf.toString(CharsetUtil.UTF_8));
        }
    
        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
            cause.printStackTrace();
            ctx.close();
        }
    }

处理handler

public class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
        @Override
        protected void initChannel(SocketChannel socketChannel) throws Exception {
            socketChannel.pipeline().addLast(new ServerHandler())
                    .addLast(new ClientHandler());
        }
    }

备注：[https://www.cnblogs.com/guos/p/12186247.html][https_www.cnblogs.com_guos_p_12186247.html]

[https_www.cnblogs.com_guos_p_12186247.html]: https://www.cnblogs.com/guos/p/12186247.html