Netty线程模型
2017-06-09 15:52
357 查看
Netty线程模型
传统的BIO实现的TCP服务器,特别对于TCP长连接,通常都要为每个连接开启一个线程,线程也是操作系统的一种资源,所以很难实现高性能高并发。而异步IO实现的TCP服务器,由于IO操作都是异步的,可以用一个线程或者少量线程来处理大量连接的IO操作,所以只需要少量的IO线程就可以实现高并发的服务器。
在网络编程过程中,通常有一些业务逻辑是比较耗时、阻塞的,例如数据库操作,如果网络不好,加上数据库性能差,SQL不够优化,数据量大,一条SQL可能会执行很久。由于IO线程本身数量就不多,通常只有一个或几个,而如果这种耗时阻塞的代码在IO线程中运行的话,IO线程的其他事情,例如网络read和write,就无法进行了,会影响IO性能以及整个服务器的性能。
所以,如果有耗时的任务,就绝对不能在IO线程中运行,而是要另外开启线程来处理。
public class Server { public void start() throws InterruptedException { EventLoopGroup boss = new NioEventLoopGroup(1); EventLoopGroup worker = new NioEventLoopGroup(4); ServerBootstrap serverBootstrap = new ServerBootstrap(); serverBootstrap.group(boss, worker) .channel(NioServerSocketChannel.class) .childHandler(new ChannelInitializer<Channel>() { EventExecutorGroup group = new DefaultEventExecutorGroup(16); @Override protected void initChannel(Channel arg0) throws Exception { ChannelPipeline channelPipeline = arg0.pipeline(); channelPipeline.addLast(new LineBasedFrameDecoder(80)); channelPipeline.addLast(group,new ServerHandler()); } }); ChannelFuture channelFuture = serverBootstrap.bind(7744).sync(); System.out.println("Server.enclosing_method()"); channelFuture.channel().closeFuture().sync(); } public static void main(String[] args) throws InterruptedException { Server server = new Server(); server.start(); } }
public class ServerHandler extends SimpleChannelInboundHandler<Object>{ @Override protected void channelRead0(ChannelHandlerContext arg0, Object arg1) throws Exception { } @Override public void channelRead(ChannelHandlerContext arg0, Object arg1) throws Exception { Thread.sleep(3000);//处理耗时操作 } }
相关文章推荐
- netty学习系列:NIO Reactor模型 & Netty线程模型
- Netty学习之旅------图说Netty线程模型
- Netty之基于EventLoop机制的高效线程模型
- Netty线程模型
- Netty系列之Netty线程模型
- Netty:Netty 3.x 线程模型
- Netty学习三:线程模型
- Netty框架之网络线程模型
- Netty3 VS Netty4 之线程模型
- Netty 4.x学习笔记 - 线程模型
- Netty in action—EventLoop和线程模型
- 【转】Netty系列之Netty线程模型
- Netty系列三:netty线程模型
- 【转】netty线程模型
- Netty线程模型及EventLoop和EventLoopGroup源码解析
- Netty学习三:线程模型
- Netty的线程模型
- netty线程模型
- netty线程模型
- Netty服务器线程模型概览