代理模式——远程代理(Java RMI)

代理模式——远程代理(Java RMI)

@(设计模式)

一、远程代理——大使

在日常开发中,我们经常会有本地服务完成不了的功能,需要访问远程服务中的对象(以下称远程对象)。当然,不可能用下面的代码来引用远程对象,以获取其方法:

Ref ref = <另一个JVM堆的对象>
1. 从实践中归纳

从非面向对象角度,可以描述为本地服务通过网络请求远程服务。为了实现本地到远程的通信,我们需要实现网络通信,处理其中可能的异常。为良好的代码设计和可维护性,我们将网络通信部分隐藏起来,只暴露给本地服务一个接口,通过该接口即可访问远程服务提供的功能,而不必过多关心通信部分的细节。正如世上本没有设计模式,设计模式都是从实践中总结出来的良好设计方式,我们也将以上的总结为远程代理。最后,我们良好设计的通信方式可能如下:

良好设计的通信方式

通信时序如下:

远程通信时序图
2. 面向对象思考

从非面向对象角度,我们关注本地服务如何获得远程服务的功能,而从面相对象角度,我们关注本地服务如何获得远程对象,从而获得远程服务提供的功能。这样,本地对象具有与远程对象完全相同的行为,但是本地的行为是通过远程对象提供的,细细思考,这就是代理模式了。不同的是代理类和真实主题类不在同一个JVM堆中,但其类之间的关系还是与代理模式相同的:

代理模式
3.大使

远程代理为一个位于不同的地址空间的对象提供一个局域代表对象,这个不同的地址空间可以是在本机器中,也可以是在另一台机器中,远程代理的角色,就像一个国家在另一个国家的大使一样,重大问题还是要跟国内沟通。

二、Java RMI实现远程代理

现在,实现远程代理,我们需要实现网络通信,封装细节,处理异常,程序员都是懒惰而聪明的,Java已经提供了一套成熟的方案来实现远程代理。

利用Java RMI实现远程代理,需要分别实现客户端与服务端

1. 服务端

实现远程代理服务端,需要

  1. 制作远程接口,即主题接口
    远程接口需要实现java.rmi.Remote类,该标记接口表示其方法可能从非本地虚拟机调用;
    远程接口所有方法需声明java.rmi.RemoteException异常,涉及网络通信,方法调用可能产生异常;
    远程接口方法变量返回值都是原语或者可序列化类型,因为返回值和变量可能需要远程传输。
  2. 实现远程接口,即真正主题类
    继承java.rmi.server.UnicastRemoteObject类,该类提供远程对象
  3. 启动本地RMI registry
    可以使用JDK自带的rmiregistry命令启动,也可以使用java.rmi.registry.LocateRegistry提供的createRegistry方法启动
  4. 注册远程服务
    使用JNDI注册服务

最后远程服务的类图如下:

远程服务

代码清单

// 远程接口
public interface IMyRemote extends Remote {

    String sayHello() throws RemoteException;
}
// 远程接口实现-远程对象
public class MyRemoteImpl extends UnicastRemoteObject implements IMyRemote {

    public MyRemoteImpl() throws RemoteException {
        super();
    }

    @Override
    public String sayHello() throws RemoteException {
        return "Server says, 'Hey'";
    }

    public static void main(String[] args) throws RemoteException, MalformedURLException {
        IMyRemote service = new MyRemoteImpl();
        // 启动本地rmi registry,默认端口1099
        LocateRegistry.createRegistry(1099);
        // 注册远程对象
        Naming.rebind("rmi://localhost:1099/RemoteHello", service);
    }
}
2.客户端

对于客户端来说,只需要使用JNDI服务找到远程对象,使用即可。代码如下:

public class MyRemoteClient {

    private void go() throws RemoteException, NotBoundException, MalformedURLException {
        IMyRemote service = (IMyRemote) Naming.lookup("rmi://localhost/RemoteHello");
        System.out.println(service.sayHello());
    }

    public static void main(String[] args) throws RemoteException, NotBoundException, MalformedURLException {
        new MyRemoteClient().go();
    }
}

首先启动服务端,再启动客户端,就可以看到来自远程对象的问候了。

三、深入Java RMI

Java RMI固然为我们实现远程对象提供了简便的方式,深入了解其实现细节也会让我们受益匪浅。

1. 一切从通信开始

不管怎么封装,本地服务要想获得远程对象,调用远程服务的方法,必然要经过网络通信。Java RMI为我们处理了这些细节,现在我们要还原这些细节一窥RMI实现。一般地,其中涉及了socket编程与TCP通信:

  1. 服务端监听某个端口
  2. 客户端知道服务端地址,并向服务端监听的端口发请求

这样的通讯方式引入了一些问题:

  1. 谁处理服务端socket相关细节
  2. 谁处理客户端socket相关细节
  3. 客户端如何知道服务端地址,以及服务端监听哪一个端口

为解决以上三个问题,RMI引入如下概念

  1. 谁处理服务端socket相关细节 ——skeleton
    骨架skelton接收来自存根的TCP请求,隐藏通信细节,将真正的调用交给远程对象,并负责组织返回,解耦服务与网络通信;
  2. 谁处理客户端socket相关细节 ——stub
    存根stub接收来自客户的请求,组织参数通过TCP发送到服务端骨架,并接收组织返回给客户,解耦客户与网络通信;
  3. 客户端如何知道服务端地址,以及服务端监听哪一个端口 ——rmi registry
    服务端远程对象注册到rmi registry,客户端通过位置总所周知的rmi registry获取存根stub。rmi registry是一个独立的服务,只有在registry服务启动后,才能将远程服务注册(绑定)到registry中。

这样,远程对象的全部时序细节应该如下,其中Program是服务端负责启动的类,RMI registry与服务端在同一个JVM中。

远程对象通信
2. 代码细节

// TODO: java rmi的代码细节

四、分布式与RMI

rmi registry是一个不同于rmi服务端的独立服务(这也是要先启动rmi registry才能绑定rmi远程服务的原因)。由于将rmi服务绑定到RMI registry时,registry使用自己的类加载器加载服务类,因此registry必须能够访问到服务类的classpath,那么registry必须和rmi服务在同一台机器上了。这就意味这rmi 服务不能注册到远程机器的rmi registry上,不能依靠rmi registry解决分布式中rmi服务的单点故障。

成熟的方案是集成zookeeper,将分布式部署的rmi服务的rmi registry地址注册到zk某个节点,rmi客户端访问该节点获取rmi registry地址,采用合适的负载策略选择具体rmi registry,最后通过rmi registry访问到具体rmi服务。那么整个过程如下:

rmi registry -> zk node -> rmi registry list -> Load Balancing Strategy -> specific rmi registry -> rmi server

refer to

[1] 深入理解rmi原理
[2] Java RMI远程方法调用详解
[3] RMI注册表
[4] RMI(远程方法调用)
[5] 使用 RMI + ZooKeeper 实现远程调用框架

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,189评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,577评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,857评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,703评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,705评论 5 366
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,620评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,995评论 3 396
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,656评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,898评论 1 298
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,639评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,720评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,395评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,982评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,953评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,195评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,907评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,472评论 2 342

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,594评论 18 139
  • 目录 本文的结构如下: 引言 什么是代理模式 模式的结构 典型代码 代理模式分类 代码示例 代理模式和装饰者模式的...
    w1992wishes阅读 1,517评论 0 13
  • 代理模式是什么 如上图所示,代理代表着另一终端中的某个真实服务对象,Client 调用代理(Client help...
    野生西瓜阅读 2,290评论 2 14
  • 今早,跑完五公里时,第15天晨跑,在木凳上坐了好一会儿。心里没有想象中的那么激动。起初,在手帐上记录着✅五公里,要...
    梦在南方9899阅读 677评论 0 2
  • 一、用Vue改造React的一个Demo Game 2048 https://github.com/pengfu/...
    pengfoo阅读 440评论 0 0