背景
对公司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等编辑码技术;
- 实现一个心跳,本人用来监听服务的健康情况;