netty系列(一) 初识netty

背景

对公司http服务进行压力测试，选择netty+springmvc与传统的tomcat服务进行对比。
选择的业务接口为用户能一步触达的页面（例如推送push后，许多用户会点击push通知条进入app某页面，造成并发）；与第三方合作平台进行对接，实时发布需要改动的数据。

什么是netty呢

• 它是一个网路编程框架；
• 它拥有极其强大的网路抽象核心代码（使用起来还是相当方便）；
• 我们熟知的tomcat和它有何不同，粗略点讲，tomcat只是实现了http的web容器，而netty是自定义协议。谁更强呢？本人进行了压力测试，在一个并发在特定范围中，netty优势明显，但是到随着并发数增大，两者几乎持平了。

netty能做什么

• 实现socket，发布实时数据；
• 监控服务；
• 实现自定义协议服务器；

为什么使用netty

• 支持成千上万的并发客户端；
• 直接使用java底层api十分复杂；
• 实时性NIO，拥有更高吞吐量和更低延迟（相比MQ）；
• 网络编程：tcp/udp/http网络应用，异步且非阻塞；
• 编码框架集成，如marshalling（不跨语言）和protobuf（跨语言）。且优势特别明显，java序列化无法跨语言，并且序列化后码流相当大，性能特别低。

事件驱动与组件

认识netty的话，一定需要提组件，组件是构成事件驱动的前提，利用组件构成一个个连串的行为，组件及其作用为以下几种：

• channel：一个实体开放的连接，例如：一次读写操作；
• 回调：一个处理事件的方法；
• future：每个IO后，都会返回的future，但是在netty中，称之为channelHandler；
• channelHandler：同上。
• 什么为事件驱动，我的理解是“利用组件构成一个个连串的行为”，看下面的代码应该可以更好理解：

EventLoopGroup group = new NioEventLoopGroup();
        Bootstrap b = new Bootstrap();

        b.group(group)
                .channel(NioSocketChannel.class)
                .handler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel sc) throws Exception {
                        sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingDecoder());
                        sc.pipeline().addLast(MarshallingCodeCFactory.buildMarshallingEncoder());
                        sc.pipeline().addLast(new ReadTimeoutHandler(30));
                        sc.pipeline().addLast(new ClienHeartBeattHandler());
                    }
                });

        ChannelFuture cf = b.connect("127.0.0.1", 8765).sync();

         cf.channel().closeFuture().sync();
         group.shutdownGracefully();

在对Bootstrap的group进行处理，先是创建一个Nio的channel，在handler对其进行特定的初始化操作等等，这是一个流程化的过程。

接下来的内容

• 理解NIO和AIO;
• marshalling等编辑码技术；
• 实现一个心跳，本人用来监听服务的健康情况；