关于netty:netty-in-action学习笔记第二章-编写你的第一个netty程序

【netty in action】学习笔记-第二章 编写你的第一个netty程序

这一章简略粗犷，整个章节都是讲一个例子，例子很简略，然而麻雀虽小五脏俱全。通过这个示例你会对编写基于netty的应用程序有个直观的意识。

我先上代码，前面再剖析。

先看看服务端的示例，

public class EchoServer {
    public int port;

    public EchoServer(int port) {
        this.port = port;
    }

    public void start() {

        EventLoopGroup group = new NioEventLoopGroup();
        try {
            ServerBootstrap b = new ServerBootstrap();
            b.group(group)
                    .channel(NioServerSocketChannel.class)
                    .localAddress(new InetSocketAddress(port))
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {
                            ch.pipeline().addLast(new EchoServerHandler());
                        }
                    });

            ChannelFuture f = b.bind().sync();
            System.out.println(EchoServer.class.getName() + "started and listen on " + f.channel().localAddress());
            f.channel().closeFuture().sync();
        }catch (Exception e) {

        }finally {
            group.shutdownGracefully();
        }
    }

    public static void main(String[] args) {
        new EchoServer(8888).start();
    }
}

public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        ctx.writeAndFlush(Unpooled.copiedBuffer("netty rocks", CharsetUtil.UTF_8));
    }

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf msg) throws Exception {

        ByteBuf recieveMsg=(ByteBuf) msg;
        String result = ByteBufUtil.hexDump(recieveMsg).toUpperCase();//将bytebuf中的可读字节 转换成16进制数字符串
        String result2 = ByteBufUtil.hexDump(msg.readBytes(msg.readableBytes()));
        //看下两种形式输入的后果有什么区别
        System.out.println("client received:" + result);
        System.out.println("client received:" + result2);

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
}

而后是客户端的示例，

public class EchoClient {
    private final String host;
    private final int port;

    public EchoClient(String host, int port) {
        this.host = host;
        this.port = port;
    }

    public void start() throws InterruptedException {

        EventLoopGroup group = new NioEventLoopGroup();
        try {
            Bootstrap b = new Bootstrap();
            b.group(group)
                    .channel(NioSocketChannel.class)
                    .remoteAddress(new InetSocketAddress(host, port))
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        protected void initChannel(SocketChannel ch) throws Exception {

                            ch.pipeline().addLast(new EchoClientHandler());
                        }
                    });

            ChannelFuture f = b.connect().sync();
            f.channel().closeFuture().sync();

        }catch (Exception e) {

        }finally {
            group.shutdownGracefully().sync();
        }
    }

    public static void main(String[] args) {
        String host = "127.0.0.1";
        int port = 8888;

        new EchoClient(host, port).start();
    }
}

public class EchoClientHandler extends SimpleChannelInboundHandler<ByteBuf> {

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        ctx.write(Unpooled.copiedBuffer("netty rocks", CharsetUtil.UTF_8));
    }

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf msg) throws Exception {

        ByteBuf recieveMsg=(ByteBuf) msg;
        String result = ByteBufUtil.hexDump(recieveMsg).toUpperCase();//将bytebuf中的可读字节 转换成16进制数字符串
        String result2 = ByteBufUtil.hexDump(msg.readBytes(msg.readableBytes()));
        //看下两种形式输入的后果有什么区别
        System.out.println("client received:" + result);
        System.out.println("client received:" + result2);

    }

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
        cause.printStackTrace();
        ctx.close();
    }
}

这个代码是能够运行的。你能够本人跑一下。

上面就来解释下下面这些代码。当然这里只做简略的解释，因为每个概念在前面的章节都有具体的形容。

Bootstrap用来启动服务，客户端和服务端都应用这个。区别在于服务端应用的是ServerBootstrap。这两个类都是继承自AbstractBootstrap这个抽象类。

NioEventLoopGroup用来解决多个连贯，能够把它了解为线程池。

NioServerSocketChannel当然就是netty里最外围的概念channel。这里咱们指定channel的类型。当然这里你能够指定OioServerSocketChannel，示意阻塞的IO channel。

咱们通过childHandler指定业务解决外围逻辑的handler，这些handler是以链的形式治理的。ChannelPipeline是这个链的名字。这其实也是设计模式中的责任链模式。

接着咱们通过bind办法绑定服务器，sync示意这是一个阻塞的同步调用，在绑定胜利之前都会期待。

EchoServerHandler和EchoClientHandler是咱们业务解决类，他们的设计办法就是咱们后面章节说到的回调。看房办法的名字也能猜出一二。咱们须要继承ChannelInboundHandlerAdapter表明这是一个入口处的解决类。（进口和入口的前面会具体阐明）。

channelRead办法在服务端（客户端）收到数据时被调用，exceptionCaught是异样产生时调用。

须要留神的是，在接收数据的时候，channelRead（channelRead0）可能会调用屡次，比方接管5个字节，第一次收到3个，第二次收到2个。这其实是netty外面拆包，粘包的概念，这个在前面的章节也会讲到，这里不多说。只管会呈现拆包，粘包的状况，然而netty能保障在TCP协定下，数据接管的程序和发送的程序是统一的。（这个也是netty很多自带的解码器解决粘包的前提）