Java RMI(远程方法调用) 实例与分析

目的:

  经过本文,能够加深对Java RMI的理解,知道它的工做原理,怎么使用等. 也为了加深我本身的理解,故整理成文.不足之处,还望指出.java

概念解释:

RMI(RemoteMethodInvocation):远程方法调用,顾名思义,经过远程的方式调用非本地对象的方法并返回结果。使用远程调用一般解决本地计算瓶颈问题,例如分布式记算,最近很火的阿尔法狗人机大战,听说运算使用上千个CPU。socket

JRMP(java remote method protocol):java远程方法协议,这是完成java到java远程调用的协议,基于TCP协议。分布式

stub与skeleton:这两个概念下面会用到,这里解释下,skeleton是放在服务端的代理,它知道真正的对象在哪。stub是放在客户端的代理,它记录了查找和调用skeleton信息。理解成远程对象引用也成.工具

 

容易混淆的概念:测试

  远程方法调用与远程过程调用的区别:远程方法调用是java独有的,基于JRMP对象流协议实现,支持传输java序列化对象。远程过程调用是基于socket技术实现的,不能传输java对象,socket套接字协议支持多种语言。它们都是基于TCP协议传输。远程方法调用传输的是java序列化对象和基本数据类型,而远程过程调用不支持传输对象。this

RMI调用模型:spa

从宏观看,想要远程调用须要作两件事情,1,服务端向本地对象注册表中注册能被调用的远程对象. 2,客户端向远程对象注册表请求远程对象的引用..net

Java中RMI实现:

 先经过一个例子了解Java中RMI是怎么用的,而后再根据代码分析源码是如何实现的.代理

1,先建立远程对象接口,继承自Remote(稍后源码中有分析为何要有这个接口)code

package remote.test;

import java.rmi.Remote;
import java.rmi.RemoteException;
/**
 * 远程接口,实现Remote
 * @author lxz
 *
 */
public interface IRemote extends Remote{

    public String show()throws RemoteException;//声明方法
}

2,接口实现,须要继承UnicastRemoteObject类,等会分析

package remote.test;

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

/**
 * 远程接口实现,继承UnicastRemoteObject
 * @author lxz
 *
 */
public class RemoteImpl extends UnicastRemoteObject  implements IRemote{
    public RemoteImpl()throws RemoteException{}//构造方法
    public String show()throws RemoteException{//调用方法实现
        System.out.println("进入");
        System.out.println(this.toString());
        return "远程调用成功";
    }
}

3,服务端向本地端口1234对象注册表注册对象和它的名字

package remote.test;

import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

/**
 *  服务端启动,建立端口上的对象注册列表,向对象注册表中注册远程调用对象
 * @author lxz
 *
 */
public class TestServer {
    public static void main(String[] args) throws MalformedURLException, RemoteException, AlreadyBoundException, InterruptedException {
        RemoteImpl r = new RemoteImpl();//建立远程对象
        Registry rr = LocateRegistry.createRegistry(1234); //建立1234端口上的对象注册表,若是已经建立了就用getRegistry方法获取
        rr.bind("testrmi", r);//向注册表中注册对象
        System.out.println(r.toString());
    }
}    

4,根据JDK API,以上远程服务就算搭建完毕了,下面经过客户端调用测试

package remote.test;

import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;

/**
 * 客户端启动,得到远程的对象注册表中的对象引用
 * @author lxz
 *
 */
public class TestClient {

    public static void main(String[] args) throws MalformedURLException, RemoteException, NotBoundException {
        IRemote r = (IRemote) Naming.lookup("rmi://localhost:1234/testrmi");//获取远程1234端口对象注册表中testrmi的stub
        String a = r.show();//调用引用的方法,实际上调用的是stub,由stub与服务端交互并返回结果
        System.out.println(a);
    }
}


执行结果以下:

------------------------------------------

服务端:

RemoteImpl[UnicastServerRef [liveRef: [endpoint:[192.168.1.253:58169](local),objID:[-60651394:1539d5944e6:-7fff, -6910034932968554489]]]]
客户端:

远程调用成功
------------------------------------------

这样就完成了一个远程对象注册与远程对象方法调用的完整例子. 如今根据这个例子来分析它为何要继承UnicastRemoteObject,实现Remote,向注册表注册等等.

首先远程对象实现类中须要继承UnicastRemoteObject类,UnicastRemoteObject具备注册为远程对象,生成远程引用的功能等,全部都已经被JDK封装好了,不须要编写,其中的实现有些是sun包开头的,不公开.

UnicastRemoteObject继承关系:

 

有了远程对象实现类,看服务端的启动逻辑,其中:

Registry rr = LocateRegistry.createRegistry(1234); 

LocateRegistry类:用于建立或获取某端口的对象注册表

LocateRegistry.createRegistry:这个方法表示得到远程对象注册表引用,返回Registry对象

Registry:真正操做远程对象注册表的接口

接着,

rr.bind("testrmi", r);

利用Registry的对象,把刚刚建立的远程对象注册为名称testrmi. 这里还有一种写法,效果是同样的.

LocateRegistry.createRegistry(1234); //建立,若是已经建立了就可省略这一句
Naming.bind("rmi://localhost:1234/testrmi", r);//须要带上端口

Naming:与对象注册表交互的工具类

上面是服务端从远程对象建立到对象注册的整个逻辑.客户端调用的逻辑比较简单,先经过Naming工具类获取到远程对象的引用之后,就能够正常使用了

(IRemote) Naming.lookup("rmi://localhost:1234/testrmi");

这里返回的"引用"和一般讲的对象引用不一样,是远程对象的引用信息.拿到这个"引用"之后就能够像使用真正的对象同样调用其中的方法.

 

结束.

相关文章
相关标签/搜索