基于Spring的RPC通讯模型.

一、概念和原理

    RPC(remote procedure call),远程过程调用,是客户端应用和服务端之间的会话。在客户端,它所需要的一些功能并不在该应用的实现范围之内,所以应用要向提供这些功能的其他系统寻求帮助。而远程应用通过远程服务暴露这些功能。RPC 是同步操作,会阻塞调用代码的执行,直到被调用的过程执行完毕。

    Spring支持多种不同的RPC模型,包括RMI、Caucho的Hessian和Burlap以及Spring自带的HTTP invoker:

    客户端:

    在所有的模型中,服务都是作为 Spring 所管理的 bean 配置到我们的应用中。这是通过一个代理工厂 bean 实现的,这个bean能够把远程服务像本地对象一样装配到其他bean的属性中。

    客户端向代理发起调用,就像代理提供了这些服务一样。代理代表客户端和远程服务进行通信,由它负责处理连接的细节并向远程服务发起调用。

    服务端:

Spring 使用远程导出器(remote exporter)将bean方法发布为远程服务。

二、RMI

    RMI 最初在JDK 1.1被引入到Java平台中,它为Java开发者提供了一种强大的方法来实现Java程序间的交互。

    Spring 提供了简单的方式来发布RMI服务,在服务端,RmiServiceExporter 可以把任何 Spring 管理的bean发布为RMI服务 ,如图所示,RmiServiceExporter 把bean包装在一个适配器类中,然后适配器类被绑定到RMI注册表中,并且代理到服务类的请求。

    /**
     * 服务端:
     * <p>
     * 1、默认情况下,RmiServiceExporter 会尝试绑定到本地机器1099端口上的RMI注册表。
     * 2、如果在这个端口没有发现RMI注册表,RmiServiceExporter 将会启动一个注册表。
     * 3、可重写注册表的路径和端口,这个是个大坑,当你设置了registryHost属性的时候,源码中就不创建Registry,而是直接去获取,可是我们自己也没有创建,所以就会报连接不上。
     *
     * @param userService
     * @return
     */
    @Bean(name = "rmiServiceExporter")
    public RmiExporter rmiServiceExporter(UserService userService, Environment environment) {
        String registryHost = environment.getProperty("registryHost");
        int registryPort = environment.getProperty("registryPort", Integer.class);
        RmiExporter rmiExporter = new RmiExporter();
        rmiExporter.setService(userService); //要把该bean(即rmiServiceImpl)发布为一个RMI服务
        rmiExporter.setServiceName("RmiService"); //命名RMI 服务
        rmiExporter.setServiceInterface(UserService.class); //指定服务所实现的接口
        rmiExporter.setRegistryHost(registryHost);
        rmiExporter.setRegistryPort(registryPort);
        return rmiExporter;
    }
/**
 * Created by XiuYin.Cui on 2018/5/14.
 * 
 * 解决设置 registryHost 后,报连接拒绝的问题。
 */
public class RmiExporter extends RmiServiceExporter {

    @Override
    protected Registry getRegistry(String registryHost, int registryPort, RMIClientSocketFactory clientSocketFactory,
                                   RMIServerSocketFactory serverSocketFactory) throws RemoteException {


        if (registryHost != null) {
            try {
                if (logger.isInfoEnabled()) {
                    logger.info("Looking for RMI registry at port '" + registryPort + "' of host [" + registryHost + "]");
                }
                //把spring源代码中这里try起来,报异常就创建一个
                Registry reg = LocateRegistry.getRegistry(registryHost, registryPort, clientSocketFactory);
                testRegistry(reg);
                return reg;
            } catch (RemoteException ex) {
                LocateRegistry.createRegistry(registryPort);
                Registry reg = LocateRegistry.getRegistry(registryHost, registryPort, clientSocketFactory);
                testRegistry(reg);
                return reg;
            }
        } else {
            return getRegistry(registryPort, clientSocketFactory, serverSocketFactory);
        }
    }
}

     接下来,来看看客户端是怎么使用这些远程服务的吧!Spring的RmiProxyFactoryBean是一个工厂bean,该bean可以为RMI服务创建代理。该代理代表客户端来负责与远程的RMI服务进行通信。客户端通过服务的接口与代理进行交互,就如同远程服务就是一个本地的POJO。

    @Bean(name = "rmiUserServiceClient")
    public RmiProxyFactoryBean RmiUserServiceClient(){
        RmiProxyFactoryBean rmiProxyFactoryBean = new RmiProxyFactoryBean();
        rmiProxyFactoryBean.setServiceUrl("rmi://127.0.0.1:9999/RmiService");
        rmiProxyFactoryBean.setServiceInterface(UserService.class);
        rmiProxyFactoryBean.setLookupStubOnStartup(false);//不在容器启动后创建与Server端的连接
        rmiProxyFactoryBean.setRefreshStubOnConnectFailure(true);//连接出错的时候自动重连
        rmiProxyFactoryBean.afterPropertiesSet();
        return rmiProxyFactoryBean;
    }
    @Resource(name="rmiUserServiceClient")
    private UserService userService;

     RMI 的缺陷:

1、RMI很难穿越防火墙,这是因为RMI使用任意端口来交互——这是防火墙通常所不允许的。 2、RMI是基于Java的。这意味着客户端和服务端必须都是用java开发。因为RMI使用了Java的序列化机制,所以通过网络传输的对象类型必须要保证在调用两端的Java运行时中是完全相同的版本。

tips:最近发现 Dubbo 底层也是用 RMI 实现的,它把 zookeeper 当作注册表。

三、Hessian 和 Burlap

    Hession 和 Burlap 是 Caucho Technology 的两种基于HTTP的轻量级远程服务解决方案。借助于尽可能简单的API和通信协议,它们都致力于简化Web服务。

    Hession,像RMI一样,使用二进制消息进行客户端和服务端的交互。但是它与RMI不同的是,它的二进制消息可以移植到其他非Java的语言中。由于它是基于二进制的,所以它在带宽上更具优势。

    Burlap 是一种基于XML的远程调用技术,这使得它可以自然而然的移植到任何能够解析XML的语言上。正因为它基于XML,所以相比起Hessian的二进制格式而言,Burlap可读性更强。但是和其他基于XML的远程技术(例如SOAP或XML-RPC)不同,Burlap的消息结构尽可能的简单。

    下面我们会介绍 Hession 的使用。Spring 不推荐使用 Burlap,BurlapServiceExporter 在4.0后被废弃,不再提供支持。5.0 后直接从开发包丢弃了。

    服务端,类似于 RmiServiceExporter ,Hession 也有一个 HessianServiceExporter 将 Spring 管理的 bean 发布为 Hessian 服务,不同于RMI的是,HessianServiceExporter是一个Spring MVC控制器,它接收Hessian请求(HTTP协议的请求),并将这些请求转换成对被导出POJO的方法调用。既然是HTTP请求,那我们就必须配置Spring 的 DispatcherServlet ,并配置 HandlerMapping,将相应的URL映射给 HessianServiceExporter。

    /**
     * Hession没有注册表,不需要设置 serviceName
     */
    @Bean(name = "hessianServiceExporter")
    public HessianServiceExporter hessianServiceExporter(UserService userService) {
        HessianServiceExporter hessianServiceExporter = new HessianServiceExporter();
        hessianServiceExporter.setService(userService);
        hessianServiceExporter.setServiceInterface(UserService.class);
        return hessianServiceExporter;
    }
    /**
     * 需要配置一个URL映射来确保DispatcherServlet把请求转给HessianServiceExporter
     */
    @Bean(name = "handlerMapping")
    public HandlerMapping handlerMapping() {
        SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
        Properties mappings = new Properties();
        mappings.setProperty("/user.service", "hessianServiceExporter");
        handlerMapping.setMappings(mappings);
        return handlerMapping;
    }

    客户端,类似于 RmiProxyFactoryBean ,Hessian 也有一个代理工厂Bean——HessianProxyFactoryBean,来创建代理与远程服务进行通信:

    @Bean(name = "hessianUserServiceClient")
    public HessianProxyFactoryBean hessianUserServiceClient(){
        HessianProxyFactoryBean proxy = new HessianProxyFactoryBean();
        proxy.setServiceUrl("http://127.0.0.1:8080/user.service");
        proxy.setServiceInterface(UserService.class);
        return proxy;
    }
    @Resource(name="hessianUserServiceClient")
    private UserService userService; 

    Hessian 的缺陷:

    Hession 和 Burlap 都是基于HTTP的,它们都解决了RMI所头疼的防火墙渗透问题。但是当传递过来的RPC消息中包含序列化对象时,RMI就完胜 Hessian 和 Burlap 了。因为 Hessian 和 Burlap 都采用了私有的序列化机制,而RMI使用的是Java本身的序列化机制。

四、HttpInvoker

    RMI 和 Hessian 各有自己的缺陷,一方面,RMI使用Java标准的对象序列化机制,但是很难穿透防火墙。另一方面,Hessian和Burlap能很好地穿透防火墙,但是使用私有的对象序列化机制。就这样,Spring的HTTP invoker应运而生了。HTTP invoker是一个新的远程调用模型,作为Spring框架的一部分,能够执行基于HTTP的远程调用,并使用Java的序列化机制。

    HttpInvoker 的使用和 Hessian 很类似,HttpInvokerServiceExporter 也是一个Spring MVC 控制器,也是通过 DispatcherServlet 将请求分发给它...

    /*Http Invoker*/
    @Bean(name = "httpInvokerServiceExporter")
    public HttpInvokerServiceExporter httpInvokerServiceExporter(UserService userService){
        HttpInvokerServiceExporter httpInvokerServiceExporter = new HttpInvokerServiceExporter();
        httpInvokerServiceExporter.setService(userService);
        httpInvokerServiceExporter.setServiceInterface(UserService.class);
        return httpInvokerServiceExporter;
    }
    /**
     * 需要配置一个URL映射来确保DispatcherServlet把请求转给HessianServiceExporter
     */
    @Bean(name = "handlerMapping")
    public HandlerMapping handlerMapping() {
        SimpleUrlHandlerMapping handlerMapping = new SimpleUrlHandlerMapping();
        Properties mappings = new Properties();
        mappings.setProperty("/user.service", "hessianServiceExporter");
        mappings.setProperty("/userInvoker.service", "httpInvokerServiceExporter");
        handlerMapping.setMappings(mappings);
        return handlerMapping;
    }

    客户端,像 RmiProxyFactoryBean 和 HessianProxyFactoryBean 一样,HttpInvoker 也提供了一个代理工厂Bean——HttpInvokerProxyFactoryBean,用于创建HttpInvoker代理来与远程服务通信:

    @Bean(name = "httpInvokerUserServiceClient")
    public HttpInvokerProxyFactoryBean httpInvokerUserServiceClient(){
        HttpInvokerProxyFactoryBean proxy = new HttpInvokerProxyFactoryBean();
        proxy.setServiceUrl("http://127.0.0.1:8080//userInvoker.service");
        proxy.setServiceInterface(UserService.class);
        return proxy;
    }
    @Resource(name="httpInvokerUserServiceClient")
    private UserService userService;

参考资料:《Spring 实战第四版》

演示源代码链接:https://github.com/JMCuixy/SpringForRpc

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏张善友的专栏

当调用GetAuthorizationGroups() 的错误-“试图访问卸载的应用程序域“(Exception from HRESULT: 0x80131014)解决方案

针对 Windows® 平台,Microsoft 提供了三个主要目录平台:Active Directory® 域服务、每台 Windows 计算机上的本地安全帐...

1987
来自专栏SDNLAB

LLDP在ODL中的实现及源码分析(一)

本文中主要是与大家分享一下LLDP在ODL中的实现以及其源码分析,主要内容涉及ODL控制器中LLDP帧的产生及发送。文章都是个人理解,希望能够帮助到大家,更希望...

40510
来自专栏开源FPGA

SDRAM读写状态解析

(1)在IDLE状态需要先给ACT命令激活某一行,此时处于Row Active状态。

730
来自专栏岑玉海

hbase源码系列(六)HMaster启动过程

  这一章是server端开始的第一章,有兴趣的朋友先去看一下hbase的架构图,我专门从网上弄下来的。   按照HMaster的run方法的注释,我们可以了解...

3899
来自专栏逸鹏说道

2.并发编程~先导篇(下)

代码实例:https://github.com/lotapp/BaseCode/tree/master/python/5.concurrent/Linux/进程...

783
来自专栏积累沉淀

JNDI数据库连接池

JNDI的全称是java命名与目录接口(Java Naming and Directory Interface),是一个应用程序设计的API,为开发人员提供了查...

1805
来自专栏chenssy

【死磕Sharding-jdbc】---异步送达JOB

当最大努力送达型监听器多次失败尝试后,把任务交给最大努力送达型异步JOB任务处理,异步多次尝试处理;核心源码在模块 sharding-jdbc-transact...

882
来自专栏SDNLAB

OpenStack Neutron中的DVR简介与OVS流表分析

本文主要介绍DVR的概念,比较了DVR和非DVR情况下,数据在network节点上的流量变化。同时也介绍了在OpenStack里面如何配置DVR,比较详细地介绍...

34210
来自专栏魏琼东

分布式消息总线,基于.NET Socket Tcp的发布-订阅框架之离线支持,附代码下载

     在前面的分享一个分布式消息总线,基于.NET Socket Tcp的发布-订阅框架,附代码下载一文之中给大家分享和介绍了一个极其简单也非常容易上的基于...

790
来自专栏coder修行路

socket编程进阶

1、   动态导入模块 第一种方法(python解释器自己内部用的): ? 上图是我程序的目录结构 下面代码是动态导入模块3.py的源码: 1 #AUTHOR:...

3048

扫码关注云+社区