Hadoop 源代码分析（七）RPC-Server

时间：2015-05-14 18:50:51 阅读：100 评论：0 收藏：0 [点我收藏+]

聊完了Client 聊Server，按惯例，先把类图贴出来。
技术分享

需要注意的是，这里的Server 类是个抽象类，唯一抽象的地方，就是
Java 代码
1. public abstract Writable call(Writable param, long receiveTime) throws IOException;
这表明，Server 提供了一个架子，Server 的具体功能，需要具体类来完成。而具体类，当然就是实现call 方法。
我们先来分析Server.Call，和Client.Call 类似，Server.Call 包含了一次请求，其中，id 和param 的含义和Client.Call
是一致的。不同点在后面三个属性，connection 是该Call 来自的连接，当然，当请求处理结束时，相应的结果会通过相同的
connection，发送给客户端。属性timestamp 是请求到达的时间戳，如果请求很长时间没被处理，对应的连接会被关闭，客户
端也就知道出错了。最后的response 是请求处理的结果，可能是一个Writable 的串行化结果，也可能一个异常的串行化结果。
Server.Connection 维护了一个来之客户端的socket 连接。它处理版本校验，读取请求并把请求发送到请求处理线程，接收处
理结果并把结果发送给客户端。
Hadoop 的Server 采用了Java 的NIO，这样的话就不需要为每一个socket 连接建立一个线程，读取socket 上的数据。在Server
中，只需要一个线程，就可以accept 新的连接请求和读取socket 上的数据，这个线程，就是上面图里的Listener。
请求处理线程一般有多个，它们都是Server.Handle 类的实例。它们的run 方法循环地取出一个Server.Call，调用Server.call
方法，搜集结果并串行化，然后将结果放入Responder 队列中。

对于处理完的请求，需要将结果写回去，同样，利用NIO，只需要一个线程，相关的逻辑在Responder 里。

更多精彩内容请关注：http://bbs.superwu.cn

关注超人学院微信二维码：技术分享

Hadoop 源代码分析（七）RPC-Server

标签：hadoop rpc 吴超hadoop

原文地址：http://blog.csdn.net/crxy2016/article/details/45722617

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行