怎么通過Java代碼來理解RPC

本篇內容主要講解“怎么通過Java代碼來理解RPC”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學習“怎么通過Java代碼來理解RPC”吧!

這整個過程可以用一句話概括：機器 A 通過網絡與機器B建立連接，A 發送一些參數給 B，B 執行某個過程，并把結果返回給 A。

“在寫代碼之前，先說一個前置背景，假設我們有一個商品類：

public class Product implements Serializable {      private Integer id;     private String name;      public Product(Integer id, String name) {         this.id = id;         this.name = name;     }      //toString()          //get set 方法 }

有一個商品服務接口：

public interface IProductService {      Product getProductById(Integer id); }

服務端有商品服務接口的實現類：

public class ProductServiceImpl implements IProductService {     @Override     public Product getProductById(Integer id) {         //實際上這里應該去查詢數據庫獲得數據，下面簡化了         return new Product(id, "手機");     } }

下面我們通過客戶端發送一個商品 id 到服務端，服務端獲得 id 后通過商品服務類獲取商品信息，返回給客戶端：

public class Client {      public static void main(String[] args) throws Exception {         //建立Socket         Socket socket = new Socket("127.0.0.1", 8888);         //獲取輸出流         ByteArrayOutputStream baos = new ByteArrayOutputStream();         DataOutputStream dos = new DataOutputStream(baos);         //把商品Id通過網絡傳到服務端         dos.writeInt(123);          socket.getOutputStream().write(baos.toByteArray());         socket.getOutputStream().flush();          //讀取服務端返回的商品信息         DataInputStream dis = new DataInputStream(socket.getInputStream());         Integer id = dis.readInt();     //商品id         String name = dis.readUTF();    //商品名稱         Product product = new Product(id, name);//通過服務端返回的商品信息生成商品          System.out.println(product);                  //關閉流資源為了方便閱讀，沒有做try-catch處理         dos.close();         baos.close();         socket.close();     } }  public class Server {     private static boolean running = true;      public static void main(String[] args) throws Exception {         //建立服務端Socket         ServerSocket ss = new ServerSocket(8888);         //不斷監聽，處理客戶端請求         while (running) {             Socket socket = ss.accept();             process(socket);             socket.close();         }         ss.close();     }      private static void process(Socket socket) throws Exception {         InputStream is = socket.getInputStream();         OutputStream os = socket.getOutputStream();         DataInputStream dis = new DataInputStream(is);         DataOutputStream dos = new DataOutputStream(os);          //讀取客戶端發過來的id         Integer id = dis.readInt();         //調用服務類生成商品         IProductService service = new ProductServiceImpl();         Product product = service.getProductById(id);         //把商品的信息寫回給客戶端         dos.writeInt(id);         dos.writeUTF(product.getName());         dos.flush();          dos.close();         dis.close();         os.close();         is.close();     } }

上面的是 RPC  遠程調用的原始簡易版本，可以看到聯網的代碼寫死在了客戶端中，網絡部分代碼和getProductById()耦合在了一起，如果想把別的方法改為遠程調用還要重新寫一遍聯網的代碼，非常麻煩。

在實際的使用中，我們會編寫各種各樣的遠程調用，打個比方，IProductService接口以后可能會擴展成這樣：

public interface IProductService {      Product getProductById(Integer id);          Product getProductByName(String name);          Product getMostExpensiveProduct(); }

我們總不可能為每個方法都編寫一段網絡連接的代碼吧，我們得想到一種辦法為所有的方法都嵌入一段共用的網絡連接代碼。

那具體應該怎樣嵌入呢?這里我們可以用到代理模式。

首先，服務端的代碼要進行修改，由于多個方法共用一套聯網的代碼，我們要在服務端識別調用的是哪一個方法：

public class Server {      private static boolean running = true;      public static void main(String[] args) throws Exception {         //......     }      private static void process(Socket socket) throws Exception {         //獲取輸入流，輸出流         InputStream is = socket.getInputStream();         OutputStream os = socket.getOutputStream();         ObjectInputStream ois = new ObjectInputStream(is);         ObjectOutputStream oos = new ObjectOutputStream(os);         //獲取本次遠程調用的方法名         String methodName = ois.readUTF();         //獲取本次遠程調用方法的參數類型         Class[] parameterTypes = (Class[]) ois.readObject();         //獲取具體的參數對象         Object[] args = (Object[]) ois.readObject();                  //創建商品服務類實例，（往后這里可以繼續優化）         IProductService service = new ProductServiceImpl();         //根據遠程獲取的方法名和參數，調用相應的方法         Method method = service.getClass().getMethod(methodName, parameterTypes);         Product product = (Product) method.invoke(service, args);         //把結果寫回給客戶端         oos.writeObject(product);          oos.close();         ois.close();         socket.close();     } }

然后在客戶端，我們創建一個新的代理類，對外提供一個 getStub 獲取代理類的方法。使用 JDK 的動態代理需要三個參數，一個是類加載器，一個是接口的  class 類，最后一個是InvocationHandler實例。

JDK 動態代理背后的邏輯是這樣的：JVM 會根據接口的 class  類動態創建一個代理類對象，這個代理對象實現了傳入的接口，也就是說它擁有了接口中所有方法的實現。方法具體的實現可以由用戶指定，也就是調用InvocationHandler的invoke方法。

public class Stub {      public static IProductService getStub() {          InvocationHandler h = new InvocationHandler() {             @Override             public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {                 //和服務端建立Socket連接                 Socket socket = new Socket("127.0.0.1", 8888);                 ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());                 //拿到遠程調用的方法名                 String methodmethodName = method.getName();                 //拿到遠程調用方法的參數類型                 Class[] parametersTypes = method.getParameterTypes();                 //把方法名傳遞給服務端                 oos.writeUTF(methodName);                 //把方法參數類型傳遞給服務端                 oos.writeObject(parametersTypes);                 //把方法參數傳遞給服務端                 oos.writeObject(args);                 oos.flush();                 //獲取遠程調用的返回結果                 ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());                 Product product = (Product) ois.readObject();                  ois.close();                 oos.close();                 socket.close();                 return product;             }         };         Object o = Proxy.newProxyInstance(IProductService.class.getClassLoader(), new Class[]{IProductService.class}, h);         return (IProductService) o;     } }

這個新版本比第一個版本又美好了一些，但是其實還可以繼續優化。現在我們的代理只能夠返回IProductService的實現類，得想辦法讓它返回任意類型的服務實現類。

思路和遠程調用方法相似，在遠程調用方法時，我們把方法的名稱，參數類型，參數傳遞給服務端;現在要動態創建服務類，我們可以把服務接口的名字傳給服務端。服務端拿到遠程接口的名字后，就可以從服務注冊表中找到對應服務實現類。

至于服務實現類如何注冊到服務注冊表，這里提供一個思路：可以考慮使用 Spring 的注解注入。這和我們平時寫 spring  代碼是相似的，在創建完服務實現類后我們會加上注解 @Service，這樣我們就可以在收到遠程調用后，遍歷使用了  @Service的Bean，找到對應的實現類。

到此，相信大家對“怎么通過Java代碼來理解RPC”有了更深的了解，不妨來實際操作一番吧！這里是億速云網站，更多相關內容可以進入相關頻道進行查詢，關注我們，繼續學習！