java基于RMI遠(yuǎn)程過程調(diào)用詳解

更新時(shí)間：2022年08月12日 12:02:29 作者：陳虎_63

這篇文章主要為大家詳細(xì)介紹了java基于RMI遠(yuǎn)程過程調(diào)用，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

簡介

Java RMI，即遠(yuǎn)程方法調(diào)用(Remote Method Invocation)，一種用于實(shí)現(xiàn)遠(yuǎn)程過程調(diào)用(RPCRemote procedure call)的Java API，能直接傳輸序列化后的Java對象。它的實(shí)現(xiàn)依賴于Java虛擬機(jī)，因此它僅支持從一個(gè)JVM到另一個(gè)JVM的調(diào)用。

1、服務(wù)端生成一個(gè)注冊表，并綁定一個(gè)端口
2、服務(wù)端將需要發(fā)布的服務(wù)接口，注冊到注冊表中
3、啟動(dòng)服務(wù)等待消費(fèi)者
4、消費(fèi)者根據(jù)服務(wù)端的IP和端口獲取注冊表
5、消費(fèi)者從注冊表中根據(jù)名稱獲取想要提供服務(wù)的service接口
6、消費(fèi)者調(diào)用接口中的方法完成方法的調(diào)用

環(huán)境搭建

創(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)類添加到注冊表中：

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)建注冊表對象，之后服務(wù)提供者暴露的服務(wù)都需要注冊到這個(gè)注冊表中
? ? ? ? Registry registry = LocateRegistry.createRegistry(8089);

? ? ? ? UserService userService=new UserServiceImpl();

? ? ? ? // 將需要提供的service服務(wù)注冊到注冊表中
? ? ? ? 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)程的注冊表
? ? ? ? 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)者：