有什么免费做h5的素材网站,joomla网站迁移,购物网页版,seo 网站描述长度Rpc服务消费者#xff08;Rpc服务调用者#xff09;实现思路
前面几节说到Rpc消费者主要通过UserServiceRPc_Stub这个protobuf帮我们生成的类来实现#xff0c;上代码回顾一下
class UserServiceRpc_Stub : public UserServiceRpc {public:UserServiceRpc_Stub(::PROTOBUF…Rpc服务消费者Rpc服务调用者实现思路
前面几节说到Rpc消费者主要通过UserServiceRPc_Stub这个protobuf帮我们生成的类来实现上代码回顾一下
class UserServiceRpc_Stub : public UserServiceRpc {public:UserServiceRpc_Stub(::PROTOBUF_NAMESPACE_ID::RpcChannel* channel);UserServiceRpc_Stub(::PROTOBUF_NAMESPACE_ID::RpcChannel* channel,::PROTOBUF_NAMESPACE_ID::Service::ChannelOwnership ownership);~UserServiceRpc_Stub();inline ::PROTOBUF_NAMESPACE_ID::RpcChannel* channel() { return channel_; }// implements UserServiceRpc ------------------------------------------void Login(::PROTOBUF_NAMESPACE_ID::RpcController* controller,const ::fixbug::LoginRequest* request,::fixbug::LoginResponse* response,::google::protobuf::Closure* done);private:::PROTOBUF_NAMESPACE_ID::RpcChannel* channel_;bool owns_channel_;GOOGLE_DISALLOW_EVIL_CONSTRUCTORS(UserServiceRpc_Stub);//xxx.pb.cc
void UserServiceRpc_Stub::Login(::PROTOBUF_NAMESPACE_ID::RpcController* controller,const ::fixbug::LoginRequest* request,::fixbug::LoginResponse* response,::google::protobuf::Closure* done) {channel_-CallMethod(descriptor()-method(0),controller, request, response, done);
}
};UserServiceRpc_Stub可以看做是一个给用户提供rpc远程调用的代理类这里面有rpcclient和rpcserver约定好的远程方法LoginLogin方法是调用了一个channel_的callMethod方法那么联想到其他服务方法应该也是底层调用了这个函数底层根据method的索引来区分具体的method那么这个方法具体如何工作的这个类需要接受一个RpcChannel类作为参数看看RpcChannel类
class PROTOBUF_EXPORT RpcChannel {public:inline RpcChannel() {}virtual ~RpcChannel();virtual void CallMethod(const MethodDescriptor* method,RpcController* controller, const Message* request,Message* response, Closure* done) 0;private:GOOGLE_DISALLOW_EVIL_CONSTRUCTORS(RpcChannel);
};很简单就是一个抽象类有个纯虚函数CallMethod需要rpc_stub来实现。要实现rpcService_Stub显然先需要具体化一个MyRpcChannel类这个MyRpcChannel类继承自RpcChannel 类最后通过多态调用在callMethod方法里面完成rpc远程调用的过程。那么具体怎么进行
void UserServiceRpc_Stub::Login(::PROTOBUF_NAMESPACE_ID::RpcController* controller,const ::fixbug::LoginRequest* request,::fixbug::LoginResponse* response,::google::protobuf::Closure* done) {channel_-CallMethod(descriptor()-method(0),controller, request, response, done);
}Login方法接收4个参数第一个controller先不用管显然第四个参数done也不需要管因为作为rpc消费者不需要在将什么结果反馈给rpc提供者。那么就只需要传递两个参数request即是rpc_stub封装用户端请求的参数response即是在远程调用完成之后rpcserver帮rpcclient填写的然后rpc_stub只需要反序列化出来结果反馈给用户即可,那么基本实现思路就有了 step1实现MyRpcchannel类继承自RpcChannel 并重写其CallMethod方法CallMethod实现有如下几小步 step1.1获取具体服务名和方法名以及将用户传入的request序列化最终封装成一个字符流header_size service_name method_name args_size args_str
//获取服务名和方法名const google::protobuf::ServiceDescriptor* service method-service();std::string service_name service-name(); //service_namestd::string method_name method-name(); //method_name//获取参数的序列化字符串长度 args_sizestd::string args_str;uint32_t args_size 0;if(request-SerializeToString(args_str)){args_size args_str.size();}else{std::cout request serlize error std::endl;return;}//定义rpc请求的HeaderRpcHeader rpcHeader;rpcHeader.set_service_name(service_name);rpcHeader.set_method_name(method_name);rpcHeader.set_args_size(args_size);std::string rpc_header_str;uint32_t header_size 0;if(rpcHeader.SerializeToString(rpc_header_str)){header_size rpc_header_str.size();}else{std::cout rpcheader_str serlize error std::endl;return;}//组织待发送的rpc请求的字符串std::string send_rpc_str;send_rpc_str.insert(0, std::string((char*)header_size, 4)); // header_sizesend_rpc_str rpc_header_str; //rpcHeadersend_rpc_str args_str; //argsstep1.2连接远程rpcServer服务器(可以是不同机器上的不同进程也可以是在不同的机器上 connect to rpcServer step1.2将封装的rpc字符流通过socket发送给RpcServer(远程rpc调用请求) send-----send_rpc_str step1.3阻塞等待rpcServer的响应并将响应饭序列化出来给用户端。 recv------recv_buf
//反序列化rpc调用的响应数据std::string response_str(recv_buf, 0, recv_size);if(!response-ParseFromString(response_str)){std::cout parse error ! response_str: response_str std::endl;return;}step2用户创建UserServiceRpc_Stub类对象并将MyRpcchannel实例对象传入进行构造。最后通过UserServiceRpc_Stub对象实例调用对应的rpc服务。实际调用的就是上述实现的CallMethod方法 fixbug::UserServiceRpc_Stub stub(new MyRpcChannel());//rpc方法的请求参数fixbug::LoginRequest request;request.set_name(zhang san);request.set_pwd(123);//rpc方法的响应同步的rpc调用过程fixbug::LoginResponse response;stub.Login(nullptr, request, response, nullptr); //RpcChannel--Rpchannel::callMethod 集中来做所有rpc方法调用的参数序列化和网络发送step3处理阻塞的响应消息response做相应的业务处理。 //一次rpc调用完成读调用的结果if(0 response.result().errcode()){std::cout rpc login response success: response.success() std::endl;}else{std::cout rpc login error msg : response.result().errmsg() std::endl;}至此RpcConsumer基本实现。
