Spring框架学习[Spring RMI实现远程调用](一)

2014-11-24 03:00:32 · 作者: · 浏览: 8

1.Spring除了使用基于HTTP协议的远程调用方案,还为开发者提供了基于RMI机制的远程调用方法,RMI远程调用网络通信实现是基于TCP/IP协议完成的,而不是通过HTTP协议。

在Spring RMI实现中,集成了标准的RMI-JRIM解决方案,该方案是java虚拟机实现的一部分,它使用java序列化来完成对象的传输,是一个java到java环境的分布式处理技术,不涉及异构平台的处理。

2.RMI客户端配置:

和基于HTTP协议的远程调用类似,RMI远程调用客户端也需要进行类似如下的配置:

[java] view plaincopyprint rmi://hostAddress:1099/serviceUrl 远程调用接口

注意:上面的配置中serviceUrl必须和服务端的远程调用提供者的id一致,另外,serviceUrl中使用的是rmi协议,默认端口是1099.

3.RmiProxyFactoryBean:

RmiProxyFactoryBean的主要功能是对RMI客户端封装,生成代理对象,查询得到RMI的stub对象,并通过这个stub对象发起相应的RMI远程调用请求。其源码如下:

[java] view plaincopyprint public class RmiProxyFactoryBean extends RmiClientInterceptor implements FactoryBean , BeanClassLoaderAware { //远程调用代理对象 private Object serviceProxy; //Spring IoC容器完成依赖注入后的回调方法 public void afterPropertiesSet() { //调用父类RmiClientInterceptor的回调方法 super.afterPropertiesSet(); //获取客户端配置的远程调用接口 if (getServiceInterface() == null) { throw new IllegalArgumentException("Property 'serviceInterface' is required"); } //创建远程调用代理对象并为代理对象设置拦截器。注意第二个参数this,因为 //RmiProxyFactoryBean继承RmiClientInterceptor,因此其也是拦截器 this.serviceProxy = new ProxyFactory(getServiceInterface(), this).getProxy(getBeanClassLoader()); } //Spring IoC容器获取被管理对象的接口方法,获取远程调用代理 public Object getObject() { return this.serviceProxy; } public Class getObjectType() { return getServiceInterface(); } public boolean isSingleton() { return true; } }

通过对上面RmiProxyFactoryBean源码分析中,我们看到在创建远程调用代理对象的时候需要设置拦截器,因为我们继续分析远程调用客户端拦截器RmiClientInterceptor。

4.RmiClientInterceptor封装RMI客户端:

RmiClientInterceptor对客户端的远程调用进行拦截,具体的生成远程调用代理对象、查找远程调用stub、以及通过RMI stub向服务端发起远程调用请求的具体实现都由RMI客户端拦截器实现,其源码如下:

[java] view plaincopyprint public class RmiClientInterceptor extends RemoteInvocationBasedAccessor implements MethodInterceptor { //在Spring启动时查找远程调用stub private boolean lookupStubOnStartup = true; //对查找到或使用过的远程调用stub进行缓存 private boolean cacheStub = true; //当连接失败是是否刷新远程调用stub private boolean refreshStubOnConnectFailure = false; //RMI客户端socket工厂 private RMIClientSocketFactory registryClientSocketFactory; //缓存的远程调用stub private Remote cachedStub; //创建远程调用stub监控器 private final Object stubMonitor = new Object(); //设置是否启动时查找RMI stub public void setLookupStubOnStartup(boolean lookupStubOnStartup) { this.lookupStubOnStartup = lookupStubOnStartup; } //设置是否缓存以查找的RMI stub public void setCacheStub(boolean cacheStu