远程服务调用框架设计与实现

远程服务调用框架设计与实现<o:p></o:p>

Auther: cenwenchu<o:p></o:p>

Email: [e-mail]<o:p></o:p>

Version: 0.1<o:p></o:p>

Date: <st1:chsdate isrocdate="False" month="6" day="22" islunardate="False" w:st="on" year="2007" tabindex="" style="BACKGROUND-POSITION: left bottom; BACKGROUND-IMAGE: url(res://ietag.dll/#34/#1001); BACKGROUND-REPEAT: repeat-x">2007-6-22</st1:chsdate><o:p></o:p>

SVN: http://svn.alibaba-inc.com/repos/opentech/sandbox/remoting/trunk <o:p></o:p>

<o:p> </o:p>

目的... 2<o:p></o:p>

实现技术... 2<o:p></o:p>

接口定义和实现规范... 2<o:p></o:p>

设计实现... 3<o:p></o:p>

基本类图... 3<o:p></o:p>

基本流程图... 4<o:p></o:p>

具体的配置和使用... 4<o:p></o:p>

<o:p> </o:p>

目的<o:p></o:p>

为远程服务调用提供统一的框架，该框架集中解决远程调用过程中的三方面问题：

a.         应用透明性：应用的接口和实现不依赖于框架的实现。框架可以透明的切换各种远程调用技术，而上层应用的接口和实现不用做任何调整。

b.         安全性：安全性主要包括两个方面：身份及签名验证(防篡改伪造)；数据传输保密性(防监听)；IP认证。

c.         调用频度控制：为保证服务可用，需要对于调用频度根据一定的规则进行控制。

<o:p> </o:p>

实现技术<o:p></o:p>

由于调用双方都是基于Java的应用，实现技术上建议采用基于Spring的Remoting框架，这样可以实现应用透明性，接口开发人员不用考虑远程调用等与业务无关的技术细节。基于Spring框架并进行扩展，我们可以在框架层次实现安全性和调用频度限制。

       由于调用双方不在一个局域网环境内，因此在具体通讯协议上，最佳选择即为Http。因此我们推荐的实现技术包括：Spring Remoting + Spring HttpInvoker，以及Spring Remoting + Hessian。

       安全性包括身份验证和数据传输安全两个方面，身份验证可以根据调用双方的信任程度以及性能要求确定采用对称加密或者非对称加密，当前提供了三种验证措施，用户名加密认证，IP认证，以及消息数字摘要加密验证，该验证可以在Spring Remoting基础上进行扩展。数据传输安全则主要是担心数据在传输过程中被截获，对于基于Http的传输，使用Https即可(无需在框架或者应用层支持)。

       调用频度控制，则可以应用AOP技术，对于调用进行截获和统计，根据一定的规则，判断调用是否符合控制策略。

<o:p> </o:p>

接口定义和实现规范<o:p></o:p>

接口定义和实现为简单的POJI和POJO即可，不过为了满足远程调用的需要，需要保证所有参数和返回值都是可序列化的，另外，鉴于部分远程调用技术的序列化机制的特殊性(例如Hessian)，数据类型应尽可能简单。此外，基于性能考虑，远程接口调用方式适用于中低频度的小数据量的调用，对于大批量数据同步或者相当高频度的调用，远程接口调用方式并不合适。

设计实现<o:p></o:p>

基本类图

<v:shapetype o:spt="75" coordsize="21600,21600" filled="f" stroked="f" id="_x0000_t75" path=" m@4@5 l@4@11@9@11@9@5 xe" o:preferrelative="t"><v:stroke joinstyle="miter"></v:stroke><v:formulas><v:f eqn="if lineDrawn pixelLineWidth 0 "></v:f><v:f eqn="sum @0 1 0 "></v:f><v:f eqn="sum 0 0 @1 "></v:f><v:f eqn="prod @2 1 2 "></v:f><v:f eqn="prod @3 21600 pixelWidth "></v:f><v:f eqn="prod @3 21600 pixelHeight "></v:f><v:f eqn="sum @0 0 1 "></v:f><v:f eqn="prod @6 1 2 "></v:f><v:f eqn="prod @7 21600 pixelWidth "></v:f><v:f eqn="sum @8 21600 0 "></v:f><v:f eqn="prod @7 21600 pixelHeight "></v:f><v:f eqn="sum @10 21600 0 "></v:f></v:formulas><v:path o:extrusionok="f" o:connecttype="rect" gradientshapeok="t"></v:path><o:lock v:ext="edit" aspectratio="t"></o:lock></v:shapetype><v:shape coordsize="21600,21600" id="_x0000_i1026" type="#_x0000_t75" style="WIDTH: 414.75pt; HEIGHT: 387.75pt"><v:imagedata src="D68C4E15.files/image001.emz" o:title=""></v:imagedata></v:shape>

 

 图1 远程服务发布类结构图

       针对Hessian和HttpInvoker两种远程服务调用的方式封装了对于安全控制的两个安全发布类，具体的安全配置以及安全操作都在RemoteContractTemplate中，这样可以方便扩展任何安全的需求变更，并且对原有任何的Exporter做了安全切面处理，防止过度耦合。

<o:p> </o:p>

<v:shape coordsize="21600,21600" id="_x0000_i1027" type="#_x0000_t75" style="WIDTH: 414.75pt; HEIGHT: 336.75pt"><v:imagedata src="D68C4E15.files/image003.emz" o:title=""></v:imagedata></v:shape>

图 2 远程服务调用类结构图

       远程服务调用对于不同的方法调用需要不同的定制，这里针对Hessian和HttpInvoker采用了替换植入内部处理类的方式，Hessian植入了新的HessianProxyFactory用来生成新的HessianProxy来植入安全机制，HttpInvokerFactoryBean植入了新的HttpInvokerRequestExecutor来植入安全机制，同样安全配置以及操作都封装在RemoteContractTemplate中，集中控制和配置，方便扩展和管理。

<o:p> </o:p>

<o:p> </o:p>

基本流程图<o:p></o:p>

<v:shape coordsize="21600,21600" id="_x0000_s2196" type="#_x0000_t75" style="WIDTH: 375.8pt; HEIGHT: 636.9pt; mso-position-horizontal-relative: char; mso-position-vertical-relative: line"><v:imagedata src="D68C4E15.files/image005.jpg" o:title="flow"></v:imagedata><w:wrap type="none"></w:wrap><w:anchorlock></w:anchorlock></v:shape>

图 3 基本流程图

       如上图所示，用户发起请求调用远程服务，首先是创建远程服务代理，然后通过植入安全信息将请求发送到远程服务发布处理类中，首先检查安全信息，如果通过安全检测就进入方法调用拦截器中检验类似于频率之类的限制过程中，通过拦截器的检测就可以调用真正的远程服务，并且获得结果，将结果返回并封装安全信息返回给服务调用代理，代理首先检测是否有合法的安全信息，如果通过安全信息认证，将结果返回给客户端。

<o:p> </o:p>

具体的配置和使用<o:p></o:p>

这里通过一个Demo来说明如何使用这个远程服务调用框架。

假定一个售票管理服务要发布，售票管理服务结构图如下：

<v:shape coordsize="21600,21600" id="_x0000_i1028" type="#_x0000_t75" style="WIDTH: 291pt; HEIGHT: 237.75pt"><v:imagedata src="D68C4E15.files/image007.emz" o:title=""></v:imagedata></v:shape>

图 4 售票管理服务结构图

服务类接口为TicketManage，实现类是TicketManageImpl。测试调用类为TicketManageClient。接口和接口的实现类就是按照普通的Java规范来实现即可，TicketManageClient根据你选择不同的服务调用方式来编写代码，这里用到了Hessian和HttpInvoker两种方式，代码如下：

public static void  main(String[] args)<o:p></o:p>

    {<o:p></o:p>

        ApplicationContext ctx = new ClassPathXmlApplicationContext("ticket.xml");<o:p></o:p>

        TicketManage ticketManage = (TicketManage)ctx.getBean("ticketService");//hession调用的配置<o:p></o:p>

        Ticket ticket = ticketManage.buyTicket(20);<o:p></o:p>

        System.out.println("ticket seat: " + ticket.getSeat());<o:p></o:p>

        <o:p></o:p>

        int returncost = ticketManage.returnTicket(ticket);<o:p></o:p>

        System.out.println("return ticket, get back cost :" + returncost);<o:p></o:p>

        TicketManage httpTicketManage = (TicketManage)ctx.getBean("ticketHttpService");//HttpInvoke调用的配置<o:p></o:p>

        ticket = httpTicketManage.buyTicket(30);<o:p></o:p>

        System.out.println("ticket seat: " + ticket.getSeat());<o:p></o:p>

        <o:p></o:p>

        returncost = httpTicketManage.returnTicket(ticket);<o:p></o:p>

        System.out.println("return ticket, get back cost :" + returncost);<o:p></o:p>

    }<o:p></o:p>

<o:p> </o:p>

ticket.xml是客户端的spring配置文件，具体的内容如下：<o:p></o:p>

<?xml version="1.0" encoding="GB2312"?><o:p></o:p>

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"><o:p></o:p>

<beans default-autowire="byName"><o:p></o:p>

    <!—- 安全模版配置类，参数在后面会有详细解释 --><o:p></o:p>

    <bean id="remoteContractTemplate" class="com.alibaba.common.remoting.util.RemoteContractTemplate" init-method="init"><o:p></o:p>

       <property name="encryptKeyPath" value="file:c:\\key.ky" /><o:p></o:p>

       <property name="decryptKeyPath" value="file:c:\\key.ky" /><o:p></o:p>

       <property name="algonrithm" value="RSA"/><o:p></o:p>

       <property name="needMD" value="true"/><o:p></o:p>

       <property name="needUserAuth" value="true"/><o:p></o:p>

       <property name="user"><o:p></o:p>

           <list><o:p></o:p>

           <value>taobao</value><o:p></o:p>

           <value>zhifubao</value><o:p></o:p>

           <value>b2b</value><o:p></o:p>

           </list><o:p></o:p>

       </property><o:p></o:p>

       <property name="owner" value="alisoft"/><o:p></o:p>

<property name="connectTimeout" value="6"/><o:p></o:p>

<property name="readTimeout" value="0"/><o:p></o:p>

       <property name="needIPAuth" value="true"/><o:p></o:p>

<property name="ipList"><o:p></o:p>

           <list><o:p></o:p>

           <value><st1:chsdate isrocdate="False" month="12" day="30" islunardate="False" w:st="on" year="1899">10.0.26</st1:chsdate>.23</value><o:p></o:p>

           <value><st1:chsdate isrocdate="False" month="12" day="30" islunardate="False" w:st="on" year="1899">10.0.0</st1:chsdate>.42</value><o:p></o:p>

           </list><o:p></o:p>

       </property><o:p></o:p>

    </bean><o:p></o:p>

    <!—- 需要植入到HttpInvokerProxyFactoryBean的安全请求处理类 --><o:p></o:p>

    <bean id="securityHttpInvokerRequestExecutor" class="com.alibaba.common.remoting.http.SecurityHttpInvokerRequestExecutor"><o:p></o:p>

       <property name="remoteContractTemplate" ref="remoteContractTemplate" /><o:p></o:p>

    </bean><o:p></o:p>

    <!—- 发布服务的Bean --><o:p></o:p>

    <bean id="ticketHttpService" class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean"><o:p></o:p>

       <property name="serviceUrl" value="http://localhost:80/remote-examples/remote/TicketHttpService"/><o:p></o:p>

       <property name="serviceInterface" value="com.alibaba.common.remoting.test.TicketManage"/><o:p></o:p>

       <property name="httpInvokerRequestExecutor" ref="securityHttpInvokerRequestExecutor"/><o:p></o:p>

    </bean>    <o:p></o:p>

    <o:p></o:p>

<!—- Hessian的安全代理工厂类Bean --><o:p></o:p>

    <bean id="securityHessianProxyFactory" class="com.alibaba.common.remoting.hessian.SecurityHessianProxyFactory"><o:p></o:p>

       <property name="remoteContractTemplate" ref="remoteContractTemplate" /><o:p></o:p>

    </bean><o:p></o:p>

    <o:p></o:p>

    <bean id="ticketService" class="org.springframework.remoting.caucho.HessianProxyFactoryBean"><o:p></o:p>

       <property name="serviceUrl" value="http://localhost:80/remote-examples/remote/TicketService"/><o:p></o:p>

       <property name="serviceInterface" value="com.alibaba.common.remoting.test.TicketManage"/><o:p></o:p>

       <property name="proxyFactory" ref="securityHessianProxyFactory"/><o:p></o:p>

    </bean><o:p></o:p>

    <o:p></o:p>

</beans><o:p></o:p>

<o:p> </o:p>

上面的xml中蓝色的内容需要根据具体的情况作修改，黑色的内容则不需要修改。<o:p></o:p>