码迷,mamicode.com
首页 > 编程语言 > 详细

【Hadoop】RpcServer 线程模型

时间:2015-05-07 08:49:39      阅读:124      评论:0      收藏:0      [点我收藏+]

标签:hadoop   server   


RpcServer 线程模型


  • NameNode启动过程:

技术分享


  • 线程模型

Listener 1个:

  1. 监听并接受来自客户端的连接.将新建连接放入pendingConnections.
  2. 清理空闲连接.
  3. 唤醒Reader.

Reader N个 : 从pendingConnections中获取连接,读取数据,从RpcRequest构造Call,并放入callQueue.

Handler N 个:

  1. 从callQueue获取客户端调用call,并执行.
  2. 调用Responder,将结果加入responseQueue的尾部.这里会调用一次发送.如果数据未发送完,注册WRITE事件到selector.并唤醒Responder.

Responder 1个:

  1. 从responseQueue中按照FIFO顺序发送数据.
  2. 处理selector select出的数据.
  3. 扫描callQueue,并丢弃过期的Call.

技术分享

【版权所有@foreach_break 博客:http://blog.csdn.net/gsky1986

【Hadoop】RpcServer 线程模型

标签:hadoop   server   

原文地址:http://blog.csdn.net/gsky1986/article/details/45546795

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!