浏览 12339 次
精华帖 (3) :: 良好帖 (9) :: 新手帖 (0) :: 隐藏帖 (2)
|
|
---|---|
作者 | 正文 |
发表时间:2009-11-16
最后修改:2009-11-16
Spring中提供了轻量级的远端调用模块,从而为我们在上面提到的应用场景开发,提供平台支持。根据Spring的既定策略,它依然只是起到一个集成平台的作用,而并不期望在实现方案上,与已有的远端调用方案形成竞争。也就是说,在Spring远端调用架构中,具体的通信协议设计、通信实现,以及在服务器和客户端对远端调用的处理封装,Spring没有将其作为实现重点,在这个技术点上,并不需要重新发明轮子。对Spring来说,它所要完成的工作,是在已有远端调用技术实现的基础上,通过IoC与AOP的封装,让应用更方便地使用这些远端调用服务,并能够更方便灵活地与现有应用系统实现集成。通过Spring封装以后,应用使用远端过程调用非常方便,既不需要改变原来系统的相关实现接口,也不需要为远端调用功能增加新的封装负担。因此,这种使用方式,在某种程度上,可以称为轻量级的远端调用方案。 在实现远端调用的过程中,往往需要涉及客户端和服务器端的相关设置,这些设置通过Spring的IoC容器就可以很好的完成,这是我们已经很熟悉的IoC容器的强项了。同时,Spring为远端调用的实现,提供了许多不同的方案,玲琅满目,任君选择。如RMI、HTTP调用器、第三方远端调用库Hessian/Burlap、基于Java RMI的解决方案,等等。 Spring对不同的远端调用的实现封装,基本上,都采用了类似的模式来完成,比如在客户端,都是通过相关的ProxyFactoryBean和ClientInterceptor来完成的,在服务器端是通过ServiceExporter来导出远端的服务对象的。有了这些统一的命名规则,应用配置和使用远端调用会非常方便,同时,通过对这些Spring远端调用基础设施实现原理的分析,还可以看到一些常用处理方法的技术实现,比如对代理对象的使用、拦截器的使用、通过afterPropertiesSet来启动远端调用基础设施的建立,等等,这些都是在Spring中常用的技术。 HTTP调用器客户端的实现 在HtttpInvokerProxyFactory中,设置了serviceProxy对象作为远端服务的本地代理对象;同时,在依赖注入完成以后,通过afterPropertiesSet来对远端调用完成设置。 public class HttpInvokerProxyFactoryBean extends HttpInvokerClientInterceptor implements FactoryBean<Object> { //这是远端对象的代理 private Object serviceProxy; @Override //在注入完成之后,设置远端对象代理 public void afterPropertiesSet() { super.afterPropertiesSet(); //需要配置远端调用的接口 if (getServiceInterface() == null) { throw new IllegalArgumentException("Property 'serviceInterface' is required"); }//这里使用ProxyFactory来生成远端代理对象,注意这个this,因为HttpInvokerProxyFactoryBean的基类是HttpInvokerClientInterceptor,所以代理类的拦截器被设置为HttpInvokerClientInterceptor this.serviceProxy = new ProxyFactory(getServiceInterface(), this).getProxy(getBeanClassLoader()); } //FactoryBean生产对象的入口。返回的是serviceProxy对象,这是一个代理对象 public Object getObject() { return this.serviceProxy; } public Class<?> getObjectType() { return getServiceInterface(); } public boolean isSingleton() { return true; } 可以看到,为这个代理对象配置了一个拦截器HttpInvokerClientInterceptor,在这个拦截器中,拦截了对代理对象的方法调用。如以下代码所示: //对代理对象的方法调用入口 public Object invoke(MethodInvocation methodInvocation) throws Throwable { if (AopUtils.isToStringMethod(methodInvocation.getMethod())) { return "HTTP invoker proxy for service URL [" + getServiceUrl() + "]"; } //创建RemoteInvocation对象,这个对象封装了对远端的调用,这些远端调用通过序列化的机制完成 RemoteInvocation invocation = createRemoteInvocation(methodInvocation); RemoteInvocationResult result = null; try { //这里是对远端调用的入口 result = executeRequest(invocation, methodInvocation); } catch (Throwable ex) { throw convertHttpInvokerAccessException(ex); } try {//返回远端调用的结果 return recreateRemoteInvocationResult(result); } catch (Throwable ex) { if (result.hasInvocationTargetException()) { throw ex; } else { throw new RemoteInvocationFailureException("Invocation of method [" + methodInvocation.getMethod() + "] failed in HTTP invoker remote service at [" + getServiceUrl() + "]", ex); } } } 远端调用的具体实现过程,是由executeRequest来完成的,也就是在SimpleHttpInvokerRequestExecutor的实现中,封装了整个HTTP调用器客户端实现的基本过程,如下所示: //这是HTTP调用器实现的基本过程,通过HTTP的request和reponse来完成通信,在通信的过程中传输的数据是序列化的对象 protected RemoteInvocationResult doExecuteRequest( HttpInvokerClientConfiguration config, ByteArrayOutputStream baos) throws IOException, ClassNotFoundException { //打开一个标准J2SE HttpURLConnection HttpURLConnection con = openConnection(config); prepareConnection(con, baos.size()); //远端调用封装成RemoteInvocation对象,这个对象通过序列化被写到对应的HttpURLConnection中去 writeRequestBody(config, con, baos); //这里取得远端服务返回的结果,然后把结果转换成RemoteInvocationResult返回 validateResponse(config, con); InputStream responseBody = readResponseBody(config, con); return readRemoteInvocationResult(responseBody, config.getCodebaseUrl()); } //把序列化对象输出到HttpURLConnection去 protected void writeRequestBody( HttpInvokerClientConfiguration config, HttpURLConnection con, ByteArrayOutputStream baos) throws IOException { baos.writeTo(con.getOutputStream()); } //为使用HttpURLConnection完成对象序列化,需要进行一系列的配置 //比如配置请求方式为post,请求属性等等 protected void prepareConnection(HttpURLConnection con, int contentLength) throws IOException { con.setDoOutput(true); con.setRequestMethod(HTTP_METHOD_POST); con.setRequestProperty(HTTP_HEADER_CONTENT_TYPE, getContentType()); con.setRequestProperty(HTTP_HEADER_CONTENT_LENGTH, Integer.toString(contentLength)); LocaleContext locale = LocaleContextHolder.getLocaleContext(); if (locale != null) { con.setRequestProperty(HTTP_HEADER_ACCEPT_LANGUAGE, StringUtils.toLanguageTag(locale.getLocale())); } if (isAcceptGzipEncoding()) { con.setRequestProperty(HTTP_HEADER_ACCEPT_ENCODING, ENCODING_GZIP); } } //获得HTTP响应的IO流 protected InputStream readResponseBody(HttpInvokerClientConfiguration config, HttpURLConnection con) throws IOException { //如果是通过gzip压缩,那么需要先解压 if (isGzipResponse(con)) { // GZIP response found - need to unzip. return new GZIPInputStream(con.getInputStream()); } else { // Plain response found. // 正常的HTTP响应输出 return con.getInputStream(); } } HTTP调用器服务器端的实现 在服务器端使用Spring HTTP远端调用,需要配置HttpInvokerServiceExporter,作为远端服务的服务导出器,来接收HTTP服务请求。在通过HTTP请求,得到客户端传过来的RemoteInvocation对象以后,就可以进行服务方法的调用了。服务调用需要的基本信息,都封装在RemoteInvocation对象中。这个服务调用过程,是由invokeAndCreateResult方法来实现的,如RemoteInvocationSerializingExporter的invoke实现所示: protected Object invoke(RemoteInvocation invocation, Object targetObject) throws NoSuchMethodException, IllegalAccessException, InvocationTargetException { if (logger.isTraceEnabled()) { logger.trace("Executing " + invocation); } try {//调用RemoteInvocationExecutor,这个执行器是DefaultRemoteInvocationExecutor return getRemoteInvocationExecutor().invoke(invocation, targetObject); } catch (NoSuchMethodException ex) { if (logger.isDebugEnabled()) { logger.warn("Could not find target method for " + invocation, ex); } throw ex; } catch (IllegalAccessException ex) { if (logger.isDebugEnabled()) { logger.warn("Could not access target method for " + invocation, ex); } throw ex; } catch (InvocationTargetException ex) { if (logger.isDebugEnabled()) { logger.debug("Target method failed for " + invocation, ex.getTargetException()); } throw ex; } } 看到的invoke方法封装了服务器端调用的主体,这个invoke方法在HttpInvokerServiceExporter的基类RemoteInvocationSerializingExporter中实现,服务对象的方法调用完成之后,会把调用结果,通过HTTP响应和对象序列化,传给HTTP调用器客户端,从而完成整个HTTP调用器的远端调用过程,如以下代码所示: protected void writeRemoteInvocationResult( HttpServletRequest request, HttpServletResponse response, RemoteInvocationResult result) throws IOException { //设置Response的ContentType属性,设置为application/x-java-serialized-object response.setContentType(getContentType()); writeRemoteInvocationResult(request, response, result, response.getOutputStream()); } //输出到HTTP的Response,然后把Response关闭 protected void writeRemoteInvocationResult( HttpServletRequest request, HttpServletResponse response, RemoteInvocationResult result, OutputStream os) throws IOException { ObjectOutputStream oos = createObjectOutputStream(decorateOutputStream(request, response, os)); try { doWriteRemoteInvocationResult(result, oos); oos.flush(); } finally { oos.close(); } } 经过这一系列的处理过程,服务执行结果对象又回到了HTTP的远端调用客户端。在客户端从HTTP响应读取对象之后,它把这个看起来像是在本地实现,其实是由远端服务对象完成的调用结果,交给发起远端调用的客户端调用方法,从而最终完成整个远端调用的过程。这个过程很有特点,它使用了HTTP的请求和响应作为通信通道,在这个通信通道里面,并没有再做进一步的附加的通信协议的封装,而且,在这个处理过程中,使用的都是Java和Spring框架已有的特性,比如,通过IoC的配置,以及代理对象拦截器的封装处理,再加Java的序列化和反序列化,以及在服务器端的Spring MVC框架的使用,通过这些已有的技术实现,让使用者感觉,它的实现风格非常的简洁轻快,整个代码实现,阅读起来,也让人感到非常的赏心悦目。 声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2009-11-16
楼主的文章一直在看
更新真快 再次赞一个 |
|
返回顶楼 | |
发表时间:2009-11-17
很好,写的很详细
|
|
返回顶楼 | |
发表时间:2009-11-17
楼主的这系列文章真是没话说,如果看了这系列文章再回过头去审视和使用Spring,肯定又是另外一种境界了。
再次预告一下,楼主的这系列文章马上要出书了,书名就叫做《Spring技术内幕——深入解析Spring架构与设计原理》,预计在12月中旬会与大家见面,届时还请大家多多指教。 |
|
返回顶楼 | |
发表时间:2009-11-18
很好呀,呵呵,我要重新开始Sping之旅了
|
|
返回顶楼 | |
发表时间:2009-11-18
zhao_xiao_dong 写道 很好呀,呵呵,我要重新开始Sping之旅了
我觉得常常回过头去看看,会有意想不到的收获的:) 在对Spring的理解中,也就是在整个整理过程中,就常常让我有这样的感觉,但觉得还是有许多值得深究的地方没有挖掘到......见谅见谅,海涵海涵... |
|
返回顶楼 | |
发表时间:2009-11-19
最后修改:2009-11-19
看了下楼主自述经历,看来做开发很多很多年了啊。
我99年开始接触程序,可到现在还是对java不够深入,甚至对 s,s,h 这三个源码都一知半角,惭愧啊 |
|
返回顶楼 | |
发表时间:2009-11-20
lydawen 写道 看了下楼主自述经历,看来做开发很多很多年了啊。
我99年开始接触程序,可到现在还是对java不够深入,甚至对 s,s,h 这三个源码都一知半角,惭愧啊 据我了解,已经十几年了,哈哈! |
|
返回顶楼 | |
发表时间:2009-11-20
lydawen 写道 看了下楼主自述经历,看来做开发很多很多年了啊。
我99年开始接触程序,可到现在还是对java不够深入,甚至对 s,s,h 这三个源码都一知半角,惭愧啊 我觉得对Java要深入的话,一定要找个机会去捣鼓一阵JVM的源码。感觉一定也很不错。 |
|
返回顶楼 | |