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);
}
}
启动服务提供者，然后启动服务消费者：
