`
benx
  • 浏览: 272204 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

netty 疑惑

    博客分类:
  • java
 
阅读更多

 

netty的nio 模式如下

 一个线程Boss使用选择器监听OP_ACCEPT,当有accept请求过来时,挑选一个worker线程,注册到worker里面去

 

cpu内核*2个线程Worker监听OP_Read和OP_WRITE(实际上是线程池中这么多线程),当可读时,可写时,读取或写入数据,然后发起事件执行pipe中的hander链

 

问题在于,系统就这么几个线程,不管是accept或read或write 都是同步处理,假设出现在处理过程中出现死锁或长处理等逻辑,那么直接导致阻塞后面的处理。

 

我的建议,因为netty是基于事件处理机制,使用线程池,专门负责read和write事件的逻辑处理,不过这样处理可能会开启大量线程,如果线程开启太少还是会出现如上情况。

 

 

 

netty的写机制:netty不会主动注册OP_WRITE,只有当向netty的channal写入数据时,netty判断缓存区是否有等待写的数据才会开启OP_WRITE操作。

分享到:
评论
1 楼 he3109006290 2014-03-17  
我猜它应该有个算法,当出现长时间处理的情况的,它自动会启动另外的线程
来处理请求

相关推荐

Global site tag (gtag.js) - Google Analytics