rpc架构介绍以及原理分析

《rpc架构介绍以及原理分析》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、SayHello、SayGoodbye，一次RPC调用之旅架构演进RPC(RemoteProcedureCall)让构建分布式计算（应用）更容易，在提供强大的远程调用能力时不损失本地调用的语义简洁性。（就像调用本地方法一样调用远程服务——调用机制透明）目录Part1玩具级RPC框架实现Part2企业级RPC要解决的问题Part3为什么选择dubbo一、玩具级RPC框架实现1.1RPC调用流程1.2搭建一个RPC框架1.2搭建一个RPC框架——ServiceClientpublicclassServ

2、iceClient{publicstaticclassServiceProxyimplementsInvocationHandler{publicObjectinvoke(Objectproxy,Methodmethod,Object[]args)throwsThrowable{//1.构造请求参数model=newProtocol.ProtocolModel();model.setClazz(clazz.getName());model.setMethod(method.getName());m

3、odel.setArgs(args);for(inti=0;i

4、ocol.decode(rsp,method.getReturnType());}}}1.2搭建一个RPC框架——ProtocolpublicclassProtocol{publicbyte[]encode(Objecto){returnJSON.toJSONBytes(o);}publicTdecode(byte[]data,Classclazz){returnJSON.parseObject(data,clazz);}publicstaticclassProtocolModel{p

5、rivateStringclazz;privateStringmethod;privateString[]argTypes;privateObject[]args;}}1.2搭建一个RPC框架——ClientRemoterpublicclassClientRemoter{publicbyte[]getDataRemote(byte[]requestData){//1.建立网络连接socket=newSocket()socket.connect(newInetSocketAddress("127.0

6、.0.1",9999));//2.发送请求socket.getOutputStream().write(requestData);socket.getOutputStream().flush();//3.获取响应byte[]data=newbyte[10240];intlen=socket.getInputStream().read(data);returnArrays.copyOfRange(data,0,len);}}1.2搭建一个RPC框架——ServerRemoterpublicclass

7、ServerRemoter{privatestaticfinalExecutorServiceexecutor=Executors.newFixedThreadPool(…);publicvoidstartServer(intport)throwsException{//1.启动并接收socket请求socket=server.accept();executor.execute(newMyRunnable(socket));}classMyRunnableimplementsRunnable{pu

8、blicvoidrun(){//2.获取输入、输出流，用于读取请求，写入返回值is=socket.getInputStream();os=socket.getOutputStream();//3.解码(反序列化)model=Protocol.protocol.decode(data,Protocol.ProtocolModel.class);//4.调用服务端处理器object=ServiceProcessor.processor.process(model);//5.编码(序列化