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.对外接口

public interface IService extends Remote {

   public String queryName(String no) throws RemoteException;

}

2.服务实现

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

// 服务实现
public class ServiceImpl extends UnicastRemoteObject implements IService {

   /**
    */
   private static final long serialVersionUID = 682805210518738166L;

   /**
    * @throws RemoteException
    */
   protected ServiceImpl() throws RemoteException {
       super();
   }

   /* (non-Javadoc)
    *
    */
   @Override
   public String queryName(String no) throws RemoteException {
       // 方法的具体实现
       System.out.println("hello" + no);
       return String.valueOf(System.currentTimeMillis());
   }
   
}

3.RMI客户端

import java.rmi.AccessException;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

// RMI客户端
public class Client {

   public static void main(String[] args) {
       // 注册管理器
       Registry registry = null;
       try {
           // 获取服务注册管理器
           registry = LocateRegistry.getRegistry("127.0.0.1",8088);
           // 列出所有注册的服务
           String[] list = registry.list();
           for(String s : list){
               System.out.println(s);
           }
       } catch (RemoteException e) {
           
       }
       try {
           // 根据命名获取服务
           IService server = (IService) registry.lookup("vince");
           // 调用远程方法
           String result = server.queryName("ha ha ha ha");
           // 输出调用结果
           System.out.println("result from remote : " + result);
       } catch (AccessException e) {
           
       } catch (RemoteException e) {
           
       } catch (NotBoundException e) {
           
       }
   }
}

4.RMI服务端

import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

// RMI服务端
public class Server {

   public static void main(String[] args) {
       // 注册管理器
       Registry registry = null;
       try {
           // 创建一个服务注册管理器
           registry = LocateRegistry.createRegistry(8088);

       } catch (RemoteException e) {
           
       }
       try {
           // 创建一个服务
           ServiceImpl server = new ServiceImpl();
           // 将服务绑定命名
           registry.rebind("vince", server);
           
           System.out.println("bind server");
       } catch (RemoteException e) {
           
       }
   }
}

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

作者简介

陈睿|mikechen,10年+大厂架构经验,BAT资深面试官,就职于阿里巴巴、淘宝、百度等一线互联网大厂。

👇阅读更多mikechen架构文章👇

阿里架构 |双11秒杀 |分布式架构 |负载均衡 |单点登录 |微服务 |云原生 |高并发 |架构师

以上

关注作者「mikechen」公众号,获取更多技术干货!

后台回复架构,即可获取《阿里架构师进阶专题全部合集》,后台回复面试即可获取《史上最全阿里Java面试题总结

评论交流
    说说你的看法