Java RMI实现原理与使用详解

Java RMI实现原理与使用详解-mikechen

什么是Java RMI

RMI 指的是远程方法调用 (Remote Method Invocation),它是一种机制,能够让在某个 Java虚拟机上的对象调用另一个 Java 虚拟机中的对象上的方法,可以用此方法调用的任何对象必须实现该远程接口。

Java RMI的实现原理

RMI依赖的通信协议为JRMP(Java Remote Message Protocol ,Java 远程消息交换协议),该协议为Java定制,要求服务端与客户端都为Java编写。

这个协议就像HTTP协议一样,规定了客户端和服务端通信要满足的规范,在RMI中对象是通过序列化方式进行编码传输。

如图:

Java RMI实现原理与使用详解-mikechen

如上图所示,在JVM之间通信时,客户端要调用远程服务器上的对象时,并不是直接将远程对象拷贝到本地,而是通过传递一个stub。

其中stub就包含了远程服务器的地址和端口等信息,可以看作是远程对象的引用,客户端可以通过调用stub中的方法来对远程对象进行使用,也就是上图所说的逻辑上的调用,而非直接调用,即真实的数据是从客户端到服务端远程对象的stub(存根)到服务器的skeleton(骨架)之间的socket通信。

RMI包括以下三个部分:

Registry: 提供服务注册与服务获取。即Server端向Registry注册服务,比如地址、端口等一些信息,Client端从Registry获取远程对象的一些信息,如地址、端口等,然后进行远程调用。

Server: 远程方法的提供者,并向Registry注册自身提供的服务。

Client: 远程方法的消费者,从Registry获取远程方法的相关信息并且调用。

如图:

Java RMI实现原理与使用详解-mikechen

 

Java RMI 远程调用示例

Java  RMI的使用如下:

1.对外接口

  1. public interface IService extends Remote {
  2.    public String queryName(String no) throws RemoteException;
  3. }

2.服务实现

  1. import java.rmi.RemoteException;
  2. import java.rmi.server.UnicastRemoteObject;
  3. // 服务实现
  4. public class ServiceImpl extends UnicastRemoteObject implements IService {
  5.    /**
  6.     */
  7.    private static final long serialVersionUID = 682805210518738166L;
  8.    /**
  9.     * @throws RemoteException
  10.     */
  11.    protected ServiceImpl() throws RemoteException {
  12.        super();
  13.    }
  14.    /* (non-Javadoc)
  15.     *
  16.     */
  17.    @Override
  18.    public String queryName(String no) throws RemoteException {
  19.        // 方法的具体实现
  20.        System.out.println("hello" + no);
  21.        return String.valueOf(System.currentTimeMillis());
  22.    }
  23.    
  24. }

3.RMI客户端

  1. import java.rmi.AccessException;
  2. import java.rmi.NotBoundException;
  3. import java.rmi.RemoteException;
  4. import java.rmi.registry.LocateRegistry;
  5. import java.rmi.registry.Registry;
  6. // RMI客户端
  7. public class Client {
  8.    public static void main(String[] args) {
  9.        // 注册管理器
  10.        Registry registry = null;
  11.        try {
  12.            // 获取服务注册管理器
  13.            registry = LocateRegistry.getRegistry("127.0.0.1",8088);
  14.            // 列出所有注册的服务
  15.            String[] list = registry.list();
  16.            for(String s : list){
  17.                System.out.println(s);
  18.            }
  19.        } catch (RemoteException e) {
  20.            
  21.        }
  22.        try {
  23.            // 根据命名获取服务
  24.            IService server = (IService) registry.lookup("vince");
  25.            // 调用远程方法
  26.            String result = server.queryName("ha ha ha ha");
  27.            // 输出调用结果
  28.            System.out.println("result from remote : " + result);
  29.        } catch (AccessException e) {
  30.            
  31.        } catch (RemoteException e) {
  32.            
  33.        } catch (NotBoundException e) {
  34.            
  35.        }
  36.    }
  37. }

4.RMI服务端

  1. import java.rmi.RemoteException;
  2. import java.rmi.registry.LocateRegistry;
  3. import java.rmi.registry.Registry;
  4. // RMI服务端
  5. public class Server {
  6.    public static void main(String[] args) {
  7.        // 注册管理器
  8.        Registry registry = null;
  9.        try {
  10.            // 创建一个服务注册管理器
  11.            registry = LocateRegistry.createRegistry(8088);
  12.        } catch (RemoteException e) {
  13.            
  14.        }
  15.        try {
  16.            // 创建一个服务
  17.            ServiceImpl server = new ServiceImpl();
  18.            // 将服务绑定命名
  19.            registry.rebind("vince", server);
  20.            
  21.            System.out.println("bind server");
  22.        } catch (RemoteException e) {
  23.            
  24.        }
  25.    }
  26. }

服务注册管理器写在了Server里,当然也可以抽出来单独作为一个服务,在其他一些框架中,往往用Zookeeper充当注册管理角色。

评论交流
    说说你的看法
欢迎您,新朋友,感谢参与互动!