【Netty】Netty基本服务端和客户端

　　本例介绍Netty基本服务端和客户端

一、服务端Netty的工作架构

　　

二、Netty服务端

　　代码如下：

　　1、NettyServer.java 服务端主类

public class NettyServer {

    public static void main(String[] args) throws InterruptedException {

        // 创建EventLoopGroup
        NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
        NioEventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            // 创建ServerBootstrap
            ServerBootstrap bootstrap = new ServerBootstrap();

            // 配置bootstrap
            bootstrap.group(bossGroup, workerGroup)
                    // 指定使用的 NIO传输Channel
                    .channel(NioServerSocketChannel.class)
                    // 指定端口，设置套接字地址
                    .localAddress(new InetSocketAddress(9000))
                    // 添加处理器
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            // 初始化channel时，添加处理器
                            ch.pipeline().addLast(new NettyServerHandler());
                        }
                    });

            // 绑定端口
            // sync()：调用sync()方法阻塞等待知道绑定完成
            ChannelFuture channelFuture = bootstrap.bind().sync();
            // 获取Channel的CloseFuture，并阻塞知道它完成
            channelFuture.channel().closeFuture().sync();
        } finally {
            // 关闭释放资源
            bossGroup.shutdownGracefully().sync();
            workerGroup.shutdownGracefully().sync();
        }

    }
}

　　2、NettyServerHandler.java 服务端处理类

public class NettyServerHandler extends ChannelInboundHandlerAdapter {

    // 对于每个传入的消息都要调用
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        // 记录已接收的消息
        ByteBuf byteBuf = (ByteBuf) msg;
        System.out.println("Server received: " + byteBuf.toString(CharsetUtil.UTF_8));
    }

    // 通知 ChannelInboundHandlerAdapter 最后一次 channelRead()的调用
    // 是当前批量读取中的最后一条消息
    @Override
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        // 将未决消息冲刷到远程节点，并且关闭该Channel;
        ctx.writeAndFlush(Unpooled.EMPTY_BUFFER)
                .addListener(ChannelFutureListener.CLOSE);
        System.out.println("读取完成");
    }

    // 在读取操作期间，有异常抛出时调用
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 打印异常
        cause.printStackTrace();
        // 关闭Channel
        ctx.channel();
    }
}

三、Netty客户端

　　代码如下：

　　1、NettyClient.java 客户端主类

public class NettyClient {
    public static void main(String[] args) throws InterruptedException {
        // 事件循环组
        NioEventLoopGroup group = new NioEventLoopGroup();
        try {
            // 启动对象
            Bootstrap bootstrap = new Bootstrap();
            // 配置
            bootstrap.group(group)
                    .channel(NioSocketChannel.class)
                    .remoteAddress(new InetSocketAddress("127.0.0.1",9000))
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(new NettyClientHandler());
                        }
                    });

            // 连接远程地址，阻塞至连接完成
            ChannelFuture channelFuture = bootstrap.connect().sync();
            // 阻塞直到channel关闭
            channelFuture.channel().closeFuture().sync();
        } finally {
            // 关闭释放资源
            group.shutdownGracefully().sync();
        }
    }
}

　　2、NettyClientHandler.java 客户端处理类

public class NettyClientHandler extends SimpleChannelInboundHandler<ByteBuf> {

    // 当从服务器接收到一条消息时被调用
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, ByteBuf msg) throws Exception {
        // 记录已接收的消息
        System.out.println("Client received: " + msg.toString(CharsetUtil.UTF_8));
    }

    // 在到服务器的连接已建立之后将被调用
    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        // 当被通知Channel是活跃的时侯，发送一条消息
        ctx.writeAndFlush(Unpooled.copiedBuffer("Netty rocks!", CharsetUtil.UTF_8));
    }

    // 在处理过程中引发异常时调用
    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        // 打印异常
        cause.printStackTrace();
        // 关闭Channel
        ctx.channel();
    }
}