聊完了Client聊Server,按惯例,先把类图贴出来。

 Hadoop源代码分析(七)

 

需要注意的是,这里的Server类是个抽象类,唯一抽象的地方,就是

 

Java代码

1 public abstract Writable call(Writable param, long receiveTime) throws IOException;  

 

这表明,Server提供了一个架子,Server的具体功能,需要具体类来完成。而具体类,当然就是实现call方法。

 

我们先来分析Server.Call,和Client.Call类似,Server.Call包含了一次请求,其中,idparam的含义和Client.Call是一致的。不同点在后面三个属性,connection是该Call来自的连接,当然,当请求处理结束时,相应的结果会通过相同的connection,发送给客户端。属性timestamp是请求到达的时间戳,如果请求很长时间没被处理,对应的连接会被关闭,客户端也就知道出错了。最后的response是请求处理的结果,可能是一个Writable的串行化结果,也可能一个异常的串行化结果。

 

Server.Connection维护了一个来之客户端的socket连接。它处理版本校验,读取请求并把请求发送到请求处理线程,接收处理结果并把结果发送给客户端。

 

HadoopServer采用了JavaNIO,这样的话就不需要为每一个socket连接建立一个线程,读取socket上的数据。在Server中,只需要一个线程,就可以accept新的连接请求和读取socket上的数据,这个线程,就是上面图里的Listener

 

请求处理线程一般有多个,它们都是Server.Handle类的实例。它们的run方法循环地取出一个Server.Call,调用Server.call方法,搜集结果并串行化,然后将结果放入Responder队列中。

 

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

 

相关文章:

  • 2021-08-27
  • 2022-03-11
  • 2022-02-19
  • 2021-09-17
猜你喜欢
  • 2022-01-15
  • 2021-12-20
  • 2021-10-24
  • 2021-05-25
  • 2021-07-13
  • 2021-10-19
相关资源
相似解决方案