講義ApacheDubbo是一款高性能、輕量級(jí)的開(kāi)源JavaRP

day03ApacheDubbo是一款高性能、輕量級(jí)的開(kāi)源JavaRPC框架，提供面向接口的高性能RPC調(diào)用、智官網(wǎng)1、RPC（RemoteProcedureCall）— 過(guò)程調(diào)用，它是一種通過(guò)網(wǎng)絡(luò)從計(jì)算機(jī)程序上請(qǐng)求服務(wù)， ava中RPC框架比較多，常見(jiàn)的有RMI、HessianThrftgRPC、bRPC、motan、DubboRPC框架而言，模塊就是通訊和序列化接下來(lái)我們就分別看一下常見(jiàn)的RPC框RMI(remotemethodinvocation)是java原生支持的調(diào)用，RMI采用JRMP（JavaRemoteMessageingProtocol）作為通信協(xié)議，可以認(rèn)為是純java版本的分布式調(diào)用解決方案。RMI的概RMI步創(chuàng)建接口，并且繼承java.rmi.Remote接實(shí)現(xiàn)接口，并且繼承創(chuàng)建服務(wù)器程序：createRegistry()方法對(duì)創(chuàng)建客戶端程序(獲取信息，調(diào)用接口方法常見(jiàn)實(shí)體類（注意實(shí)體類privateintage;privateStringsex;}publicpublicinterfaceUserServiceextendsRemoteStringo(Stringname)throws}提供接口的實(shí)現(xiàn)publicpublicclassUserServiceImplextendsUnicastRemoteObjectimplements{publicUserServiceImpl()throwspublicStringo(Stringname)RemoteException{return }}將本地服 出去，供外部調(diào)客戶 調(diào)用服務(wù)，客戶端需要依賴服務(wù)接userService=(UserService) 對(duì) try Naming.bind("rmi://localhost:8888/UserService",userService);}catch(RemoteException{}catch(AlreadyBoundException{}catch(MalformedURLException{}添加hessian的maven依publicinterfaceUserServicepublicinterfaceUserServiceStringo(String}實(shí)現(xiàn)publicpublicclassUserServiceImplimplementsUserServicepublicStringsay name){return" }}web.xml中配置 添加tomcat7插件啟動(dòng)服客戶端publicstaticvoidmain(String[]args)throws{Stringurl= HessianProxyFactoryfactory=new }}運(yùn)行結(jié)果如 語(yǔ)言開(kāi)發(fā)，thrift通過(guò)IDL(InterfaceDescriptionLanguage)來(lái)關(guān)聯(lián)客戶端和服務(wù)端。gRPC2、手寫RPC框基本實(shí)現(xiàn)思protocol服務(wù)提供者publicoServicevoido(String}publicoServicevoido(String}publicoServiceImploServicepublicvoido(String{}}實(shí)現(xiàn) 2、服 在map集合中，結(jié)構(gòu):Map<String,Map<URL,Class>>外邊map的key中心類提 服務(wù) 服務(wù)和發(fā)現(xiàn)服務(wù)功能Map<URL,Class>>(); @param@param@parampublicstaticvoidregist(URLurl,StringinterfaceName,ClassimplClass){Map<URL,Class>map=newHashMap<URL,Class>();} @param@parampublicstaticClassget(URLurl,StringinterfaceName){returnURL類定義publicclassURLprivateIntegerport;}啟動(dòng)服務(wù)提供 服務(wù) 服publicpublicclassServiceProviderpublicstaticvoidmain(String[]args) 服URLurl=newURL("localhost",8080); //啟動(dòng) 服HttpServerhttpServer=newHttpServer();}}3、protocol 創(chuàng)建<Serverport="8005"<Service0-publicvoidstart(Stringhostname,Integer//實(shí)例一個(gè)Tomcattomcat=new構(gòu)建Serverserver=獲取Serviceservice=構(gòu)建Connectorconnector=newConnector();構(gòu)建Engineengine=newStandardEngine();構(gòu)建Hosthost=newStandardHost();構(gòu)建StringcontextPath=Contextcontext=newStandardContext();context.addLifecycleListener(newTomcat.FixContextListener());//器然后按照server.xml，一層層把子節(jié)點(diǎn)添加到父節(jié)點(diǎn)//service在getServer時(shí)就被添加到server//tomcat是一個(gè)servlet,設(shè)置路徑與映射tomcat.addServlet(contextPath,"dispatcher",newDispatcherServlet()); trytomcat.start();//啟動(dòng)tomcattomcat.getServer().await接受請(qǐng)求}catch(LifecycleException}} 市昌平區(qū)建材城西路金燕龍辦公樓一 publicpublicclassHttpServerHandlerresp){try{//HttpInputStreamis=req.getInputStream();ObjectInputStreamois=newObjectInputStream(is);//尋 ClassimplClass=NativeRegister.get(newMethodmethod=Stringresult=(String)//}catch}}封裝調(diào)用參數(shù)publicclassInvocationimplementsSerializableprivateStringmethodName;privateObject[]params;privateClass[]paramTypes;}4、consumer服務(wù)消費(fèi)封裝HttpClient對(duì)象，發(fā) 調(diào)publicpublicclass@param @param 主機(jī)@paramtrytryHttpURLConnectionconnection=connection.setDoOutput(true必填項(xiàng)//OutputStreamos=connection.getOutputStream();//將輸入流轉(zhuǎn)為字符串（此處可是java對(duì)象）returnIOUtils.toStr