當(dāng)前位置：
首頁(yè) >
RPC框架几行代码就够了
發(fā)布時(shí)間：2025/3/21
49
豆豆
生活随笔
收集整理的這篇文章主要介紹了
RPC框架几行代码就够了
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
轉(zhuǎn)于作者梁飛在公司的Blog：?
http://pt.alibaba-inc.com/wp/experience_1330/simple-rpc-framework.html ?
因?yàn)橐o百技上實(shí)訓(xùn)課，讓新同學(xué)們自行實(shí)現(xiàn)一個(gè)簡(jiǎn)易R(shí)PC框架，在準(zhǔn)備PPT時(shí)，就想寫個(gè)示例，發(fā)現(xiàn)原來一個(gè)RPC框架只要一個(gè)類，10來分鐘就可以寫完了，雖然簡(jiǎn)陋，也曬曬：?
Java代碼?? /*? ?*?Copyright?2011?Alibaba.com?All?right?reserved.?This?software?is?the? ?*?confidential?and?proprietary?information?of?Alibaba.com?("Confidential? ?*?Information").?You?shall?not?disclose?such?Confidential?Information?and?shall? ?*?use?it?only?in?accordance?with?the?terms?of?the?license?agreement?you?entered? ?*?into?with?Alibaba.com.? ?*/?? package?com.alibaba.study.rpc.framework;?? ?? import?java.io.ObjectInputStream;?? import?java.io.ObjectOutputStream;?? import?java.lang.reflect.InvocationHandler;?? import?java.lang.reflect.Method;?? import?java.lang.reflect.Proxy;?? import?java.net.ServerSocket;?? import?java.net.Socket;?? ?? /**? ?*?RpcFramework? ?*?? ?*?@author?william.liangf? ?*/?? public?class?RpcFramework?{?? ?? ????/**? ?????*?暴露服務(wù)? ?????*?? ?????*?@param?service?服務(wù)實(shí)現(xiàn)? ?????*?@param?port?服務(wù)端口? ?????*?@throws?Exception? ?????*/?? ????public?static?void?export(final?Object?service,?int?port)?throws?Exception?{?? ????????if?(service?==?null)?? ????????????throw?new?IllegalArgumentException("service?instance?==?null");?? ????????if?(port?<=?0?||?port?>?65535)?? ????????????throw?new?IllegalArgumentException("Invalid?port?"?+?port);?? ????????System.out.println("Export?service?"?+?service.getClass().getName()?+?"?on?port?"?+?port);?? ????????ServerSocket?server?=?new?ServerSocket(port);?? ????????for(;;)?{?? ????????????try?{?? ????????????????final?Socket?socket?=?server.accept();?? ????????????????new?Thread(new?Runnable()?{?? ????????????????????@Override?? ????????????????????public?void?run()?{?? ????????????????????????try?{?? ????????????????????????????try?{?? ????????????????????????????????ObjectInputStream?input?=?new?ObjectInputStream(socket.getInputStream());?? ????????????????????????????????try?{?? ????????????????????????????????????String?methodName?=?input.readUTF();?? ????????????????????????????????????Class<?>[]?parameterTypes?=?(Class<?>[])input.readObject();?? ????????????????????????????????????Object[]?arguments?=?(Object[])input.readObject();?? ????????????????????????????????????ObjectOutputStream?output?=?new?ObjectOutputStream(socket.getOutputStream());?? ????????????????????????????????????try?{?? ????????????????????????????????????????Method?method?=?service.getClass().getMethod(methodName,?parameterTypes);?? ????????????????????????????????????????Object?result?=?method.invoke(service,?arguments);?? ????????????????????????????????????????output.writeObject(result);?? ????????????????????????????????????}?catch?(Throwable?t)?{?? ????????????????????????????????????????output.writeObject(t);?? ????????????????????????????????????}?finally?{?? ????????????????????????????????????????output.close();?? ????????????????????????????????????}?? ????????????????????????????????}?finally?{?? ????????????????????????????????????input.close();?? ????????????????????????????????}?? ????????????????????????????}?finally?{?? ????????????????????????????????socket.close();?? ????????????????????????????}?? ????????????????????????}?catch?(Exception?e)?{?? ????????????????????????????e.printStackTrace();?? ????????????????????????}?? ????????????????????}?? ????????????????}).start();?? ????????????}?catch?(Exception?e)?{?? ????????????????e.printStackTrace();?? ????????????}?? ????????}?? ????}?? ?? ????/**? ?????*?引用服務(wù)? ?????*?? ?????*?@param?<T>?接口泛型? ?????*?@param?interfaceClass?接口類型? ?????*?@param?host?服務(wù)器主機(jī)名? ?????*?@param?port?服務(wù)器端口? ?????*?@return?遠(yuǎn)程服務(wù)? ?????*?@throws?Exception? ?????*/?? ????@SuppressWarnings("unchecked")?? ????public?static?<T>?T?refer(final?Class<T>?interfaceClass,?final?String?host,?final?int?port)?throws?Exception?{?? ????????if?(interfaceClass?==?null)?? ????????????throw?new?IllegalArgumentException("Interface?class?==?null");?? ????????if?(!?interfaceClass.isInterface())?? ????????????throw?new?IllegalArgumentException("The?"?+?interfaceClass.getName()?+?"?must?be?interface?class!");?? ????????if?(host?==?null?||?host.length()?==?0)?? ????????????throw?new?IllegalArgumentException("Host?==?null!");?? ????????if?(port?<=?0?||?port?>?65535)?? ????????????throw?new?IllegalArgumentException("Invalid?port?"?+?port);?? ????????System.out.println("Get?remote?service?"?+?interfaceClass.getName()?+?"?from?server?"?+?host?+?":"?+?port);?? ????????return?(T)?Proxy.newProxyInstance(interfaceClass.getClassLoader(),?new?Class<?>[]?{interfaceClass},?new?InvocationHandler()?{?? ????????????public?Object?invoke(Object?proxy,?Method?method,?Object[]?arguments)?throws?Throwable?{?? ????????????????Socket?socket?=?new?Socket(host,?port);?? ????????????????try?{?? ????????????????????ObjectOutputStream?output?=?new?ObjectOutputStream(socket.getOutputStream());?? ????????????????????try?{?? ????????????????????????output.writeUTF(method.getName());?? ????????????????????????output.writeObject(method.getParameterTypes());?? ????????????????????????output.writeObject(arguments);?? ????????????????????????ObjectInputStream?input?=?new?ObjectInputStream(socket.getInputStream());?? ????????????????????????try?{?? ????????????????????????????Object?result?=?input.readObject();?? ????????????????????????????if?(result?instanceof?Throwable)?{?? ????????????????????????????????throw?(Throwable)?result;?? ????????????????????????????}?? ????????????????????????????return?result;?? ????????????????????????}?finally?{?? ????????????????????????????input.close();?? ????????????????????????}?? ????????????????????}?finally?{?? ????????????????????????output.close();?? ????????????????????}?? ????????????????}?finally?{?? ????????????????????socket.close();?? ????????????????}?? ????????????}?? ????????});?? ????}?? ?? }??
用起來也像模像樣：?
(1) 定義服務(wù)接口 ?
Java代碼?? /*? ?*?Copyright?2011?Alibaba.com?All?right?reserved.?This?software?is?the? ?*?confidential?and?proprietary?information?of?Alibaba.com?("Confidential? ?*?Information").?You?shall?not?disclose?such?Confidential?Information?and?shall? ?*?use?it?only?in?accordance?with?the?terms?of?the?license?agreement?you?entered? ?*?into?with?Alibaba.com.? ?*/?? package?com.alibaba.study.rpc.test;?? ?? /**? ?*?HelloService? ?*?? ?*?@author?william.liangf? ?*/?? public?interface?HelloService?{?? ?? ????String?hello(String?name);?? ?? }??
(2) 實(shí)現(xiàn)服務(wù) ?
Java代碼?? /*? ?*?Copyright?2011?Alibaba.com?All?right?reserved.?This?software?is?the? ?*?confidential?and?proprietary?information?of?Alibaba.com?("Confidential? ?*?Information").?You?shall?not?disclose?such?Confidential?Information?and?shall? ?*?use?it?only?in?accordance?with?the?terms?of?the?license?agreement?you?entered? ?*?into?with?Alibaba.com.? ?*/?? package?com.alibaba.study.rpc.test;?? ?? /**? ?*?HelloServiceImpl? ?*?? ?*?@author?william.liangf? ?*/?? public?class?HelloServiceImpl?implements?HelloService?{?? ?? ????public?String?hello(String?name)?{?? ????????return?"Hello?"?+?name;?? ????}?? ?? }??
(3) 暴露服務(wù) ?
Java代碼?? /*? ?*?Copyright?2011?Alibaba.com?All?right?reserved.?This?software?is?the? ?*?confidential?and?proprietary?information?of?Alibaba.com?("Confidential? ?*?Information").?You?shall?not?disclose?such?Confidential?Information?and?shall? ?*?use?it?only?in?accordance?with?the?terms?of?the?license?agreement?you?entered? ?*?into?with?Alibaba.com.? ?*/?? package?com.alibaba.study.rpc.test;?? ?? import?com.alibaba.study.rpc.framework.RpcFramework;?? ?? /**? ?*?RpcProvider? ?*?? ?*?@author?william.liangf? ?*/?? public?class?RpcProvider?{?? ?? ????public?static?void?main(String[]?args)?throws?Exception?{?? ????????HelloService?service?=?new?HelloServiceImpl();?? ????????RpcFramework.export(service,?1234);?? ????}?? ?? }??
(4) 引用服務(wù) ?
Java代碼?? /*? ?*?Copyright?2011?Alibaba.com?All?right?reserved.?This?software?is?the? ?*?confidential?and?proprietary?information?of?Alibaba.com?("Confidential? ?*?Information").?You?shall?not?disclose?such?Confidential?Information?and?shall? ?*?use?it?only?in?accordance?with?the?terms?of?the?license?agreement?you?entered? ?*?into?with?Alibaba.com.? ?*/?? package?com.alibaba.study.rpc.test;?? ?? import?com.alibaba.study.rpc.framework.RpcFramework;?? ?? /**? ?*?RpcConsumer? ?*?? ?*?@author?william.liangf? ?*/?? public?class?RpcConsumer?{?? ?????? ????public?static?void?main(String[]?args)?throws?Exception?{?? ????????HelloService?service?=?RpcFramework.refer(HelloService.class,?"127.0.0.1",?1234);?? ????????for?(int?i?=?0;?i?<?Integer.MAX_VALUE;?i?++)?{?? ????????????String?hello?=?service.hello("World"?+?i);?? ????????????System.out.println(hello);?? ????????????Thread.sleep(1000);?? ????????}?? ????}?? ?????? }
http://pt.alibaba-inc.com/wp/experience_1330/simple-rpc-framework.html ?
因?yàn)橐o百技上實(shí)訓(xùn)課，讓新同學(xué)們自行實(shí)現(xiàn)一個(gè)簡(jiǎn)易R(shí)PC框架，在準(zhǔn)備PPT時(shí)，就想寫個(gè)示例，發(fā)現(xiàn)原來一個(gè)RPC框架只要一個(gè)類，10來分鐘就可以寫完了，雖然簡(jiǎn)陋，也曬曬：?
Java代碼??
用起來也像模像樣：?
(1) 定義服務(wù)接口 ?
Java代碼??
(2) 實(shí)現(xiàn)服務(wù) ?
Java代碼??
(3) 暴露服務(wù) ?
Java代碼??
(4) 引用服務(wù) ?
Java代碼??
from:?http://javatar.iteye.com/blog/1123915
總結(jié)
以上是生活随笔為你收集整理的RPC框架几行代码就够了的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： MySQL——EXPLAIN和执行计划
- 下一篇： sql必知必会(第四版) 学习笔记一