读书人

[HBase]RPC框架之 region server兑现

发布时间: 2013-03-01 18:33:02 作者: rapoo

[HBase]RPC框架之 region server实现

?HBaseServer核心类,实现了Reactor模型,主线程Listener负责accept外部连接,子线程Reader负责连接的具体读写操作,将数据反序列化成Call对象,通过Queue交给后面的Handler线程处理,Handler线程发起反射调用,并将response数据交给Responder线程处理,Responder线程将数据最终写回给client。

?

0.94代码实现如下:

HRegionServer启动时,构造函数中

?Listener初始化

?Responder初始化

?写数据过程

? ??

?

?

?具体channelWrite

?具体读

?Connection的read

?请求处理

?Invocation反序列化

?之后就是Handler线程处理了

?反射调用过程

?响应对象序列化

?最终数据被写回client,client部分代码见下一篇

读书人网 >开源软件

热点推荐