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);     } }

启动服务提供者,然后启动服务消费者:

推荐阅读