Netty框架的简单实现(客户端和服务端收发消息)

Netty框架的简单实现

一、Netty的原理分析图

 二、使用Netty框架的简单实现(实现client和server的消息收发)

 　　（1）NettyServer

public class NettyServer {
    public static void main(String[] args) throws Exception{
        
         //创建两个线程池
         
        //创建一个线程组，接收客户端的连接
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        //创建一个线程组，用于处理网络操作
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        //创建服务器端启动助手（用于配置参数）
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(bossGroup,workerGroup)//设置两个线程组
        .channel(NioServerSocketChannel.class)//精华部分，设置通道的底层实现，
        //通过NioServerSocketChannel
        //这也是Netty的与NIO搭配的地方(此处作为服务器端通道的实现)
        .option(ChannelOption.SO_BACKLOG, 12)//设置线程队列中等待连接的个数
        .childOption(ChannelOption.SO_KEEPALIVE, true)
        //是否启用心跳保活机制。在双方TCP套接字建立连接后（即都进入ESTABLISHED状态）并
         //且在两个小时左右
         //上层没有任何数据传输的情况下，这套机制才会被激活。
         * */
        .childHandler(new ChannelInitializer<SocketChannel>() {//(用内部类的方法)
        //创建一个通道初始化对象
            public void initChannel(SocketChannel sc){
                sc.pipeline().addLast(new NettyServerHandler());//往pipeline链中添加
                //自定义的handler类
            }
        });
        System.out.println("...Server is Ready...");
        //ChannelFuture接口，用于在之后的某个时间点确定结果
        ChannelFuture sf = serverBootstrap.bind(9999).sync();//绑定端口 非阻塞 异步
        System.out.println("....Server is Start....");
        //关闭通道，关闭线程组
        sf.channel().closeFuture().sync();
        bossGroup.shutdownGracefully();
        workerGroup.shutdownGracefully();
    }
}

　　（2）NettyServerHandler

//服务器中的业务处理类
public class NettyServerHandler extends ChannelInboundHandlerAdapter {

    //数据读取事件
    public void channelRead(ChannelHandlerContext ctx,Object msg){
        //传来的消息包装成字节缓冲区
        ByteBuf byteBuf = (ByteBuf) msg;
        //Netty提供了字节缓冲区的toString方法，并且可以设置参数为编码格式：CharsetUtil.UTF_8
        System.out.println("客户端发来的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
    }

    //数据读取完毕事件
    public void channelReadComplete(ChannelHandlerContext ctx){
         //数据读取完毕，将信息包装成一个Buffer传递给下一个Handler，Unpooled.copiedBuffer会返回一个Buffer
        //调用的是事件处理器的上下文对象的writeAndFlush方法
        //意思就是说将  你好  传递给了下一个handler
        ctx.writeAndFlush(Unpooled.copiedBuffer("你好!", CharsetUtil.UTF_8));
    }

    //异常发生的事件
    public void exceptionCaught(ChannelHandlerContext ctx,Throwable cause){
        //异常发生时关闭上下文对象
        ctx.close();
    }
}

　　（3）NettyClient

//网络客户端
public class NettyClient {
    public static void main(String[] args) throws Exception{
        //创建一个线程组(不像服务端需要有连接等待的线程池)
        EventLoopGroup group = new NioEventLoopGroup();
        //创建客户端的服务启动助手完成相应配置
        Bootstrap b = new Bootstrap();
        b.group(group)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<SocketChannel>() {//创建一个通道初始化对象
                    @Override
                    protected void initChannel(SocketChannel socketChannel) throws Exception {
                        socketChannel.pipeline().addLast(new NettyClientHandler());//往pipeline中添加自定义的handler
                    }
                });
        System.out.println("...Client is Ready...");
        //启动客户端去连接服务器端(通过启动助手)
        ChannelFuture cf = b.connect("127.0.0.1", 9999).sync();
        //关闭连接(异步非阻塞)
        cf.channel().closeFuture().sync();

    }
}

　　（4）NettyClientHandler

//客户端业务处理类
public class NettyClientHandler extends ChannelInboundHandlerAdapter {

    //通道就绪事件(就是在bootstrap启动助手配置中addlast了handler之后就会触发此事件)
    //但我觉得也可能是当有客户端连接上后才为一次通道就绪
    public void channelActive(ChannelHandlerContext ctx){
        System.out.println("Client :" + ctx);
        //向服务器端发消息
        ctx.writeAndFlush(Unpooled.copiedBuffer("你好啊！", CharsetUtil.UTF_8));
    }
    //数据读取事件
    public void channelRead(ChannelHandlerContext ctx,Object msg){
        //传来的消息包装成字节缓冲区
        ByteBuf byteBuf = (ByteBuf) msg;
        //Netty提供了字节缓冲区的toString方法，并且可以设置参数为编码格式：CharsetUtil.UTF_8
        System.out.println("服务器端发来的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
    }

}

　　通道的消息处理都是通过channelHandlerContext对象的writeAndFlush方法来处理的。