以官方例子开启我们的netty源码之旅

Posted 大数据的那些事

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了以官方例子开启我们的netty源码之旅相关的知识,希望对你有一定的参考价值。

EchoClient类

EventLoopGroup group = new NioEventLoopGroup();
try {
    Bootstrap b = new Bootstrap();
    b.group(group)
     .channel(NiosocketChannel.class)
     .option(ChannelOption.TCP_NODELAY, true)
     .handler(new ChannelInitializer<SocketChannel>() {
         @Override
         public void initChannel(SocketChannel ch) throws Exception 
{
             ChannelPipeline p = ch.pipeline();
             if (sslCtx != null) {
                 p.addLast(sslCtx.newHandler(ch.alloc(), HOST, PORT));
             }
             //p.addLast(new LoggingHandler(LogLevel.INFO));
             p.addLast(new EchoClientHandler());
         }
     });

    // Start the client.
    ChannelFuture f = b.connect(HOST, PORT).sync();

    // Wait until the connection is closed.
    f.channel().closeFuture().sync();
finally {
    // Shut down the event loop to terminate all threads.
    group.shutdownGracefully();
}

EchoServer类

EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(bossGroup, workerGroup)
     .channel(NioServerSocketChannel.class)
     .option(ChannelOption.SO_BACKLOG, 100)
     .handler(new LoggingHandler(LogLevel.INFO))
     .childHandler(new ChannelInitializer<SocketChannel>() {
         @Override
         public void initChannel(SocketChannel ch) throws Exception {
             ChannelPipeline p = ch.pipeline();
             if (sslCtx != null) {
                 p.addLast(sslCtx.newHandler(ch.alloc()));
             }
             p.addLast(new LoggingHandler(LogLevel.INFO));
             //p.addLast(new EchoServerHandler());
         }
     });

    // Start the server.
    ChannelFuture f = b.bind(PORT).sync();

    // Wait until the server socket is closed.
    f.channel().closeFuture().sync();
finally {
    // Shut down all event loops to terminate all threads.
    bossGroup.shutdownGracefully();
    workerGroup.shutdownGracefully();
}

使用总结

1、ServerBootstrap类用于创建服务端实例,Bootstrap用于创建客户端实例。
2、在服务端,基于NioEventLoopGroup类创建了bossGroup、workerGroup这两个EventLoopGroup。客户端基于NioEventLoopGroup创建了一个group。它们可以理解为Netty中的线程池。
3、服务端的channel是NioServerSocketChannel(包装了nio原生的ServerSocketChannel),客户端的channel是NioSocketChannel(包装了nio原生的SocketChannel)
4、服务端ServerBootstrap有handler、childHandler;而客户端Bootstrap只有handler。
5、handler在初始化时执行,childHandler在客户端成功connect后才执行。如果需要在客户端连接前的请求进行    handler处理,则需要配置handler(),如果是处理客户端连接之后的handler,则需要配置在childHandler()。
6、pipeline:handler可以指定多个(需要上面的ChannelInitializer类辅助),它们会组成了一个 pipeline,它们其实就类似拦截器的概念,每个NioSocketChannel或NioServerSocketChannel内部都会有个pipeline实例。
7、ChannelFuture:涉及到Netty中的异步编程,和JDK中的Future接口类似。
8、handler可以指定多个(需要上面的ChannelInitializer类辅助)

展望

就这样,一个简单的netty应用程序就写完了。程序虽然简单,但世上的netty程序大体都是这几步:客户端和服务端各自开启EventLoopGroup和Bootstrap。使用很简单,所以我不会讲如何使用,但越简单的api往往意味着越复杂的底层代码。虽然使用起来就上面这几步,但是对应的底层代码非常复杂,你不应该想着短短几天就能搞明白。没有高手指路,甚至你很长时间都不一定能弄清楚,底层到底是如何运作的,相比于原生的NIO又有哪些异同。本系列文章就是这个目的,让你用最短的时间弄清楚netty的底层原理。如果你日常的工作只是CRUD,这个过程完成之后,你不只对netty,对NIO、多线程、异步、线程模型的理解也会更深一个层次。

以上是关于以官方例子开启我们的netty源码之旅的主要内容,如果未能解决你的问题,请参考以下文章

Netty之旅四你一定看得懂的Netty客户端启动源码分析!

dubbo源码实践-transport 网络传输层的例子

dubbo源码实践-transport 网络传输层的例子

zookeeper基于Idea启动zookeeper源码,开启源码之旅

netty 之 telnet HelloWorld 详解

Netty源码_NioEventLoop详解