尋夢新聞LINE@每日推播熱門推薦文章，趣聞不漏接❤️
知識點：
1）什麼是rmi
2）簡單的做到rmi
3）rmi原理
4）手寫rmi框架
首先談下什麼RPC？
Remote procedure call protocal 遠程過程調用協議
不用知道具體細節，調用遠程系統中類的方法，就跟調用本地方法一樣。
RPC協議其實是一種規範。
包括Dubbo，Thrift，rmi，webservice，hessain
網路協議和網路IO對於調用端和服務端來說是透明的。
一個RPC框架應該包含的要素：
RMI概述
rmi（remote method invocation） 遠程方法調用
可以認為是RPC的java版本
RMI使用的是JRMP（JAVA Remote Messageing Protocol），可以說JRMP是專門為java定制的通信協議，所以它是純java的分布式解決方案。
怎麼做到一個RMI程序
1）創建遠程接口並且繼承java.rmi.Remote 接口
package com.llf.rmidemo;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface SayHello extends Remote{
public String sayHello(String name)throws RemoteException;
}
2）做到我們這個遠程接口並且繼承 UnicastRemoteObjectpackage com.llf.rmidemo;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
public class SayHelloImpl extends UnicastRemoteObject implements SayHello{
protected SayHelloImpl() throws RemoteException {
}
@Override
public String sayHello(String name) throws RemoteException {
return “Hello LLF –>”+name;
}
}
3）創建服務器程序 調用createRegistry方法註冊遠程對象package com.llf.rmidemo;
import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
public class HelloServer {
public static void main(String[] args) {
try {
SayHello hello=new SayHelloImpl();
LocateRegistry.createRegistry(8888);
try {
Naming.bind(“rmi://localhost:8888/sayhello”, hello);
System.out.println(“Server start success!”);
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (AlreadyBoundException e) {
e.printStackTrace();
}
} catch (RemoteException e) {
e.printStackTrace();
}
}
}
4）創建客戶端程序
package com.llf.rmidemo;
import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
public class HelloClient {
public static void main(String[] args) {
try {
SayHello hello=(SayHello) Naming.lookup(“rmi://localhost:8888/sayhello”);
System.out.println(hello.sayHello(“FXP”));
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (RemoteException e) {
e.printStackTrace();
} catch (NotBoundException e) {
e.printStackTrace();
}
}
}
結果：
自己去做到一個RMI
1）編寫服務器程序，暴露監聽，可以使用socket 2）編寫客戶端程序，通過IP和端口連接到指定的服務，並且把我們的數據做封裝（序列化） 3）服務器端收到請求先反序列化在進行業務邏輯處理，把返回結果序列化返回
rmi框架調用時序圖
rmi源碼分析
我們近乎的可以以如下的圖來理解： a） stub和skeleton這倆個身份都是作為代理存在，客戶端的稱為stub，服務端的稱為skeleton，通過這倆個對象屏蔽了遠程方法調用的具體細節，這倆個是必不可少的。 b）Registry：註冊所，提供了服務名到服務的映射。
結合這上面的圖，再以上面的demo代碼，我們來扒一扒rmi的底層源碼 首先我們看提供服務的server方 createRegistry方法
服務端先創建了一個RegistryImpl的對象，然後做了一個安全校驗，這邊我們不用關注，重點是看setup方法。
進入到RegistryImpl類
然後進入到UnicastServerRef的exportObject方法 1）首先為傳入的RegistryImpl創建一個代理對象stub 2）把UnicastServerRef的skeleton對象設置為當前RegistryImpl對象 3）skeleton，stub，unicastserverRef對象，id和一個boolean構造了一個target對象
再往下追就是export的exportObject方法
主要是調用listen方法創建一個serversocket，啟動一條線程等待客戶端請求。 至此為止我們的服務端已經起了服務等待客戶端連接了。客戶端
這邊其實就是創建一個stub的代理對象用代碼來模擬RMI底層過程如下： 新建一個User的對象package com.llf.rmi;
public class User {
private int age;
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
}
編寫一個Skeleton類供客戶端調用【這塊是rmi定義出來屏蔽底層序列化及流連接的，這邊模擬寫了下底層的序列化及流】
package com.llf.rmi;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
//server程序
public class User_Skeleton extends Thread {
private UserServer userServer;
public User_Skeleton(UserServer userServer) {
this.userServer = userServer;
}
public void run() {
ServerSocket serverSocket = null;
ObjectInputStream read = null;
ObjectOutputStream oos = null;
Socket socket=null;
try {
serverSocket = new ServerSocket(8888);
socket = serverSocket.accept();
while (socket != null) {
read = new ObjectInputStream(socket.getInputStream());
String method = (String) read.readObject();
if (method.equals(“age”)) {
int age = userServer.getAge();
oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeInt(age);
oos.flush();
}
}
} catch (Exception e) {
e.printStackTrace();
} finally {
if (serverSocket != null) {
try {
oos.close();
read.close();
socket.close();
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
}
寫一個stub
package com.llf.rmi;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
public class User_Stub extends User {
private Socket socket;
public User_Stub() {
try {
socket=new Socket(“localhost”, 8888);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public int getAge(){
ObjectOutputStream oos=null;
ObjectInputStream ois=null;
try {
oos=new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(“age”);
oos.flush();
ois=new ObjectInputStream(socket.getInputStream());
return ois.readInt();
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
ois.close();
oos.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
return 0;
}
}
編寫服務器代碼
package com.llf.rmi;
public class UserServer extends User{
public static void main(String[] args) {
UserServer server=new UserServer();
server.setAge(18);
//模擬rmi生成的skeleton代理對象
User_Skeleton user_Skeleton=new User_Skeleton(server);
user_Skeleton.start();
}
}
編寫客戶端代碼package com.llf.rmi;
public class UserClient {
public static void main(String[] args) {
User user=new User_Stub();
int age=user.getAge();
System.out.println(age);
}
}
