java基於RMI遠程過程調用詳解
簡介
Java RMI,即遠程方法調用(Remote Method Invocation),一種用於實現遠程過程調用(RPCRemote procedure call)的Java API, 能直接傳輸序列化後的Java對象。它的實現依賴於Java虛擬機,因 此它僅支持從一個JVM到另一個JVM的調用。
1、服務端生成一個註冊表,並綁定一個端口
2、服務端將需要發佈的服務接口,註冊到註冊表中
3、啟動服務等待消費者
4、消費者根據服務端的IP和端口獲取註冊表
5、消費者從註冊表中根據名稱獲取想要提供服務的service接口
6、消費者調用接口中的方法完成方法的調用
環境搭建
創建一個工程模塊
創建pojo類:
package cn.hu.rmi.pojo; import java.io.Serializable; /** * @Author: hu.chen * @Description: 因為需要序列化和反序列化,所以需要實現Serializable接口 * @DateTime: 2021/12/26 5:05 PM **/ public class User implements Serializable { private Integer id; private String name; public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } @Override public String toString() { return "User{" + "id=" + id + ", name='" + name + '\'' + '}'; } }
創建user接口:
package cn.hu.rmi.service; import cn.hu.rmi.pojo.User; import java.rmi.Remote; import java.rmi.RemoteException; /** * @Author: hu.chen * @Description: 需要提供服務的接口需要繼承 Remote 並且所有的方法都需要拋出 RemoteException 異常 * @DateTime: 2021/12/26 5:06 PM **/ public interface UserService extends Remote { /** * 所有的方法都需要拋出 RemoteException 異常 * @param id * @return * @throws RemoteException */ User getUserById(Integer id) throws RemoteException; }
服務提供者:
創建userservice的實現類 package cn.hu.rmi.service.impl; import cn.hu.rmi.pojo.User; import cn.hu.rmi.service.UserService; import java.rmi.RemoteException; import java.rmi.server.UnicastRemoteObject; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; /** * @Author: hu.chen * @Description: 所有的實現類都需要繼承 UnicastRemoteObject 這個類 * @DateTime: 2021/12/26 5:07 PM **/ public class UserServiceImpl extends UnicastRemoteObject implements UserService { private static Map<Integer,User> userMap=new ConcurrentHashMap<>(8); static { User user1=new User(); user1.setId(1); user1.setName("張三"); User user2=new User(); user2.setId(2); user2.setName("李四"); userMap.put(user1.getId(),user1); userMap.put(user2.getId(),user2); } public UserServiceImpl() throws RemoteException { super(); } @Override public User getUserById(Integer id) throws RemoteException { return userMap.get(id); } }
啟動並將實現類添加到註冊表中:
package cn.hu.rmi.server; import cn.hu.rmi.service.UserService; import cn.hu.rmi.service.impl.UserServiceImpl; import java.rmi.RemoteException; import java.rmi.registry.LocateRegistry; import java.rmi.registry.Registry; /** * @Author: hu.chen * @Description: 服務端(服務提供者) * @DateTime: 2021/12/26 5:11 PM **/ public class RmiServer { public static void main(String[] args) throws RemoteException { // 1: 創建註冊表對象,之後服務提供者暴露的服務都需要註冊到這個註冊表中 Registry registry = LocateRegistry.createRegistry(8089); UserService userService=new UserServiceImpl(); // 將需要提供的service服務註冊到註冊表中 registry.rebind("userService",userService); System.err.println("服務提供者啟動成功"); } }
服務消費者:
package cn.hu.rmi.client; import cn.hu.rmi.pojo.User; import cn.hu.rmi.service.UserService; import java.rmi.NotBoundException; import java.rmi.RemoteException; import java.rmi.registry.LocateRegistry; import java.rmi.registry.Registry; /** * @Author: hu.chen * @Description: 客戶端(服務消費者) * @DateTime: 2021/12/26 5:18 PM **/ public class RmiClient { public static void main(String[] args) throws RemoteException, NotBoundException { //1: 獲取遠程的註冊表 Registry registry = LocateRegistry.getRegistry("127.0.0.1", 8089); UserService userService= (UserService) registry.lookup("userService"); User userById = userService.getUserById(1); System.err.println(userById); } }
啟動服務提供者,然後啟動服務消費者:
以上就是本文的全部內容,希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。
推薦閱讀:
- Java 中的控制反轉(IOC)詳解
- Java RMI機制講解
- SpringBoot使用JdbcTemplate訪問操作數據庫基本用法
- Java 自定義Spring框架以及Spring框架的基本使用
- 詳解Java Spring AOP