摘要:前言昨天看了一篇關于用幾行代碼實現框架的博客,收獲很大,于是我想在這篇博客的基礎上理一理思路,盡可能的多加一點注釋,進一步降低學習框架原理的門檻。
前言
昨天看了一篇關于用幾行代碼實現RPC框架的博客[http://javatar.iteye.com/blog...](),收獲很大,于是我想在這篇博客的基礎上理一理思路,盡可能的多加一點注釋,進一步降低學習RPC框架原理的門檻。
原理圖先上一個原理圖,讀者可根據此圖來幫助理解后續的代碼。
RpcFramework核心類
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; public class RpcFramework { /** * 暴露服務 * * @param service 服務實現 * @param port 服務端口 * @throws Exception */ public static void export(final Object service, int port) throws Exception { System.out.println("Export service " + service.getClass().getName() + " on port " + port); ServerSocket server = new ServerSocket(port); //一直輪詢,相比while(true),這種方式性能更佳 for(;;) { try { //此處阻塞一直等到有consumer請求過來 final Socket socket = server.accept(); //每來一個消費請求就開啟一個新的線程 new Thread(() -> { try { try { ObjectInputStream input = new ObjectInputStream(socket.getInputStream()); try { //consumer會分三次發送所需要的方法信息,這里的readUTF(),readObject()都會發生阻塞 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); //將執行結果返回給consumer 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(); } } } /** * 引用服務 * * @param接口泛型 * @param interfaceClass 接口類型 * @param host 服務器主機名 * @param port 服務器端口 * @return 遠程服務 * @throws Exception */ @SuppressWarnings("unchecked") public static T refer(final Class interfaceClass, final String host, final int port) throws Exception { System.out.println("Get remote service " + interfaceClass.getName() + " from server " + host + ":" + port); //通過JDK動態代理的方式直接返回給調用refer方法的調用者一個被動態代理處理過的 對象 return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class>[] {interfaceClass}, new InvocationHandler() { @Override //調用該對象的每個方法都會先去調用下面的邏輯 public Object invoke(Object proxy, Method method, Object[] arguments) throws Throwable { //當方法真實被調用的時候才會發起RPC遠程請求provider執行服務 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(); } } }); } }
服務接口
public interface HelloService { String hello(String name); }
服務接口實現
public class HelloServiceImpl implements HelloService { @Override public String hello(String name) { System.out.println("被調用了"); return "Hello" + name; } }
provider引導類
public class RpcProvider { public static void main(String[] args) throws Exception { HelloService service = new HelloServiceImpl(); RpcFramework.export(service, 1234); } }
consumer引導類
public class RpcConsumer { public static void main(String[] args) throws Exception { //此時獲取到的service是被JDK動態代理包裝后的service,在調用方法的時候會進行遠程調用 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); } } }
下圖是provider項目的類結構圖
下圖是consumer項目的類結構圖
簡單總結了一下簡易RPC框架,題主最近正在學習dubbo原理,故并沒有延展講太多分布式內容,希望隨著學習的深入以后能寫一篇關于分布式的文章,共勉!
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/69478.html
摘要:都是分開部署,單獨上線的。序列化畢竟是遠程通信,需要將對象轉化成二進制流進行傳輸。服務化架構的演進架構當業務規模很小時,將所有功能都不熟在同一個進程中,通過雙機或者負載均衡器實現負債分流此時,分離前后臺邏輯的架構是關鍵。 showImg(https://segmentfault.com/img/bVbiI2F?w=2250&h=1500); 前言 為什么需要RPC,而不是簡單的HTTP...
摘要:等之所以支持跨語言,是因為他們自己定義了一套結構化數據存儲格式,如的,用于編解碼對象,作為各個語言通信的中間協議。 前段時間覺得自己一直用別人的框架,站在巨人的肩膀上,也該自己造造輪子了 一時興起 就著手寫起了RPC框架 這里寫了系列博客拿給大家分享下 這篇是開篇的思路篇 項目最終的代碼放在了我的github上https://github.com/wephone/Me... 歡迎sta...
摘要:是一個分布式服務框架,以及治理方案。手寫注意要點手寫注意要點基于上文中對于協議的理解,如果我們自己去實現,需要考慮哪些技術呢其實基于圖的整個流程應該有一個大概的理解。基于手寫實現基于手寫實現理解了協議后,我們基于來實現一個通信框架。閱讀這篇文章之前,建議先閱讀和這篇文章關聯的內容。[1]詳細剖析分布式微服務架構下網絡通信的底層實現原理(圖解)[2][年薪60W的技巧]工作了5年,你真的理解N...
閱讀 3156·2021-11-22 09:34
閱讀 2796·2021-09-22 15:28
閱讀 816·2021-09-10 10:51
閱讀 1853·2019-08-30 14:22
閱讀 2273·2019-08-30 14:17
閱讀 2734·2019-08-30 11:01
閱讀 2295·2019-08-29 17:19
閱讀 3653·2019-08-29 13:17