[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部分代码见下一篇