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;


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;


public interface UserService extends Remote {


    
    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;


public class UserServiceImpl extends UnicastRemoteObject implements UserService {

    private static Map 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;


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;


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

启动服务提供者，然后启动服务消费者：