博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java RMI(远程方法调用) 实例与分析 (转)
阅读量:6884 次
发布时间:2019-06-27

本文共 3802 字,大约阅读时间需要 12 分钟。

目的:

  通过本文,可以加深对Java RMI的理解,知道它的工作原理,怎么使用等. 也为了加深我自己的理解,故整理成文.不足之处,还望指出.

概念解释:

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

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

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

 

容易混淆的概念:

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

RMI调用模型:

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

Java中RMI实现:

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

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

复制代码
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");

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

 

结束.

http://www.cnblogs.com/qinggege/p/5306852.html

 

你可能感兴趣的文章
弹性公网EIP,让网络更自由、灵活
查看>>
一对一直播源码都实现了哪几种常见的优化技术? ...
查看>>
Unity学习系列一简介
查看>>
利用Python框架pyxxnet_project实现的网络服务
查看>>
一个最简单的WebSocket hello world demo
查看>>
Midway 外部版启动过程分析
查看>>
JDK自带的java.util.Timer定时器的实现原理
查看>>
[Web开发] 检测IE版本号的方法总结
查看>>
普通PC机上安装XenServer
查看>>
fuse-dfs的设定手册
查看>>
SharePoint 2010 & Office 2010 reach RTM !
查看>>
Vmware vSphere 5.0实战教程之二 vMotion及Storage vMotion实战
查看>>
你的Winxp是不是原版,一看就知
查看>>
C# 8.0的三个令人兴奋的新特性
查看>>
关于ip_conntrack跟踪连接满导致网络丢包问题的分析
查看>>
烂泥:linux学习之VNC远程控制(一)
查看>>
IT技术晋级之路-VM中系统安装
查看>>
SNIA持久化内存峰会:虚拟机、数据库、SDS进展曝光
查看>>
[Android]AndroidInject增加sqlite3数据库映射注解(ORM)
查看>>
Oracle RAC负载均衡和透明应用失败切换的配置和测试过程(二、配置实例)
查看>>