您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“java基于RMI遠(yuǎn)程怎么調(diào)用”的有關(guān)知識(shí),在實(shí)際案例的操作過程中,不少人都會(huì)遇到這樣的困境,接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
Java RMI,即遠(yuǎn)程方法調(diào)用(Remote Method Invocation),一種用于實(shí)現(xiàn)遠(yuǎn)程過程調(diào)用(RPCRemote procedure call)的Java API, 能直接傳輸序列化后的Java對(duì)象。它的實(shí)現(xiàn)依賴于Java虛擬機(jī),因 此它僅支持從一個(gè)JVM到另一個(gè)JVM的調(diào)用。
1、服務(wù)端生成一個(gè)注冊(cè)表,并綁定一個(gè)端口
2、服務(wù)端將需要發(fā)布的服務(wù)接口,注冊(cè)到注冊(cè)表中
3、啟動(dòng)服務(wù)等待消費(fèi)者
4、消費(fèi)者根據(jù)服務(wù)端的IP和端口獲取注冊(cè)表
5、消費(fèi)者從注冊(cè)表中根據(jù)名稱獲取想要提供服務(wù)的service接口
6、消費(fèi)者調(diào)用接口中的方法完成方法的調(diào)用
創(chuàng)建一個(gè)工程模塊
創(chuàng)建pojo類:
package cn.hu.rmi.pojo; import java.io.Serializable; /** * @Author: hu.chen * @Description: 因?yàn)樾枰蛄谢头葱蛄谢?,所以需要?shí)現(xiàn)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 + '\'' + '}'; } }
創(chuàng)建user接口:
package cn.hu.rmi.service; import cn.hu.rmi.pojo.User; import java.rmi.Remote; import java.rmi.RemoteException; /** * @Author: hu.chen * @Description: 需要提供服務(wù)的接口需要繼承 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; }
服務(wù)提供者:
創(chuàng)建userservice的實(shí)現(xiàn)類 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: 所有的實(shí)現(xiàn)類都需要繼承 UnicastRemoteObject 這個(gè)類 * @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); } }
啟動(dòng)并將實(shí)現(xiàn)類添加到注冊(cè)表中:
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: 服務(wù)端(服務(wù)提供者) * @DateTime: 2021/12/26 5:11 PM **/ public class RmiServer { public static void main(String[] args) throws RemoteException { // 1: 創(chuàng)建注冊(cè)表對(duì)象,之后服務(wù)提供者暴露的服務(wù)都需要注冊(cè)到這個(gè)注冊(cè)表中 Registry registry = LocateRegistry.createRegistry(8089); UserService userService=new UserServiceImpl(); // 將需要提供的service服務(wù)注冊(cè)到注冊(cè)表中 registry.rebind("userService",userService); System.err.println("服務(wù)提供者啟動(dòng)成功"); } }
服務(wù)消費(fèi)者:
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: 客戶端(服務(wù)消費(fèi)者) * @DateTime: 2021/12/26 5:18 PM **/ public class RmiClient { public static void main(String[] args) throws RemoteException, NotBoundException { //1: 獲取遠(yuǎn)程的注冊(cè)表 Registry registry = LocateRegistry.getRegistry("127.0.0.1", 8089); UserService userService= (UserService) registry.lookup("userService"); User userById = userService.getUserById(1); System.err.println(userById); } }
啟動(dòng)服務(wù)提供者,然后啟動(dòng)服務(wù)消費(fèi)者:
“java基于RMI遠(yuǎn)程怎么調(diào)用”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。