15. Hadoop RPC框架之服务端Stub

最新推荐文章于 2022-05-13 16:14:17 发布

ZFH__ZJ

最新推荐文章于 2022-05-13 16:14:17 发布

阅读量260

点赞数

本文链接：https://blog.csdn.net/ZJ__ZFH/article/details/103628861

版权

服务端Stub程序会将通信模块接收的数据反序列化，然后调用服务程序对应的方法响应这个RPC请求。具体来说，就是Server类是服务端从网络接收RPC请求的类，成功接收一个RPC请求后，Server会调用call()方法响应这个请求

RPC.Server.call()实现了父类Server的抽象方法call()。RPC.Server.call()代码如下所示

public Writable call(RPC.RpcKind rpcKind, String protocol,
    Writable rpcRequest, long receiveTime) throws Exception {
  return getRpcInvoker(rpcKind).call(this, protocol, rpcRequest,
      receiveTime);
}

它首先调用getRpcInvoker()获取一个RpcInvoker对象，然后调用RpcInvoker.call()方法响应这个RPC请求，这个RpcInvoker对象可以理解为服务端Stub程序的实现

不同的RpcEngine会实现自己的Server队形(RPC.Server的子类)，Server对象又会实现一个内部的RpcInvoker对象，例如ProtobufRpcEngine实现了内部类Server，而Server类又定义了自己的ProtoBufRpcInvoker类。这个ProtoBufRpcInvoker对象会使用protobuf反序列化RPC请求(RpcRequestWrapper类型)，然后调用服务程序响应这个请求，最后ProtoBufRpcInvoker会将响应信息序列化包装成一个RpcResponseWrapper对象并返回。