Spring 远程http调用

核心提示：Spring HTTP invoker简介 Spring HTTP invoker是spring框架中的一个远程调用模型，执行基于HTTP的远程调用（意味着可以通过防火墙），并使用java的序列化机制在网络间传递对象。客户端可以很轻松的像调用本地对象一样调用远程服务器上的对象，这有点类似于we

Spring HTTP invoker简介
Spring HTTP invoker是spring框架中的一个远程调用模型，执行基于HTTP的远程调用（意味着可以通过防火墙），并使用java的序列化机制在网络间传递对象。客户端可以很轻松的像调用本地对象一样调用远程服务器上的对象，这有点类似于webservice，但又不同于webservice，区别如下：

 

webservice	HTTP invoker
跨平台，跨语言	只支持java语言
支持SOAP，提供wsdl	不支持
结构庞大，依赖特定的webservice实现，如xfire等	结构简单，只依赖于spring框架本身

 
项目中使用哪种远程调用机制取决于项目本身的要求。

 

²        HTTP invoker 服务模式

 

 说明：

1.       服务器端：通过HTTP invoker服务将服务接口的某个实现类提供为远程服务

2.       客户端：通过HTTP invoker代理向服务器端发送请求，远程调用服务接口的方法

3.       服务器端与客户端通信的数据需要序列化

 

配置服务器端和客户端的步骤

配置服务器端
1.       添加springJAR文件

建议使用spring2+.jar版本

2.       创建服务接口

3.       创建服务接口的具体实现类

4.       公开服务

 

配置客户端
1.  添加springJAR文件

建议使用spring2+.jar版本

2.       创建服务接口

3.       访问服务

 

实例讲解

服务器端

1.服务接口：UcService.java

它提供两项服务，查询用户信息和记录日志，如下：

public interface UcService {

           public UserInfo getUserInfobyName(String userName);

           public int recordLog(String username, String point, String operate, String desc);

}

说明：举这个列子是因为其比较有代表性，它将展示普通数据类型（int,long等）和复杂数据类型（DTO等）的远程调用方式。UserInfo是一个普通的DTO，代码如下：

public class UserInfo implements Serializable {

    private static final long serialVersionUID = -6970967506712260305L;

    /**用户名*/

    private String userName;

    /**电子邮箱*/

    private String email;

    /**注册日期*/

    private Date registDate;



    public String getUserName() {

        return userName;

    }

    public void setUserName(String userName) {

        this.userName = userName;

    }

    public String getEmail() {

        return email;

    }

    public void setEmail(String email) {

        this.email = email;

    }

     public Date getRegistDate() {

        return registDate;

    }

    public void setRegistDate(Date registDate) {

        this.registDate = registDate;

    }

}

注意：因为是在网络间传输对象，所以需要将UserInfo实现Serializable接口，并指定一个serialVersionUID（任意值即可，同时客户端也要有这个类，否则在客户端接收对象时会因为serialVersionUID不匹配而出现异常）

 回到UcService.java，它提供了两个服务（在这里一个方法代表一个服务功能），我们需要具体的实现类来实现真正的服务

 

2.实现类是UCServiceImpl.java

public class UCServiceImpl implements UcService {

    private static Logger pointrecordlog = Logger.getLogger("pointrecordlog");

    private static Logger logger = Logger.getLogger(UCServiceImpl.class);

    private UcFacade ucFacade;

    public void setUcFacade(UcFacade ucFacade) {

        this.ucFacade = ucFacade;

    }

    public UserInfo getUserInfobyName(String userName) {

        UserInfo user = null;

        try {

            user = ucFacade.getUserInfoDetail(userName);

            logger.debug("get userinfo success by  username:" + userName);

        } catch (Throwable t) {

            logger.error("get userinfo fail by  username:" + userName, t);

        }

        return user;

    }

    public int recordLog(String username, String point, String operate, String desc) {

        int result = 0;

        try {

            pointrecordlog.info(username + " - " + point + " - " + operate + " - " + desc);

        } catch (Throwable t) {

            result = -1;

            logger.error(t);

        }

        return result;

    }

}

说明：ucFacade是通过spring注入的一个数据查询类，因为它与http invoker没有直接关系，所以不进行介绍。

3.公开服务UcService.java

²        WEB-INF/application-context.xml：将接口声明为HTTP invoker服务

<bean id="httpService"

        class="org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter">

        <property name="service">

            <ref bean="ucService" />

        </property>

        <property name="serviceInterface"

            value="com.netqin.baike.service.UcService">

        </property>

    </bean>

    <bean id="ucService" class="com.netqin.baike.service.impl.UCServiceImpl"/>

说明：HttpInvokerServiceExporter实际上是一个spring mvc控制器，它处理客户端的请求并调用服务实现。

²         WEB-INF/service-servlet.xml：HttpInvokerServiceExporter实际上是一个spring mvc控制器，所以需要为其提供spring URL 处理器，这里我们使用SimpleUrlHandlerMapping

<bean

        class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">

         <property name="mappings">

            <props>

                  <prop key="/httpService">httpService</prop>

            </props>

        </property>

    </bean>

²         WEB-INF/web.xml：配置spring监听及DispatcherServlet

<context-param>

        <param-name>contextConfigLocation</param-name>

        <param-value>

            /WEB-INF/application-context.xml

        </param-value>

    </context-param>



    <listener>

        <listener-class>

            org.springframework.web.context.ContextLoaderListener

        </listener-class>

    </listener>



<servlet>

        <servlet-name>service</servlet-name>

        <servlet-class>

            org.springframework.web.servlet.DispatcherServlet

        </servlet-class>

        <load-on-startup>1</load-on-startup>

    </servlet>



    <servlet-mapping>

        <servlet-name>service</servlet-name>

        <url-pattern>/service/*</url-pattern>

    </servlet-mapping>

说明：不了解为什么这么配置的可以去看看spring mvc方面的资料。

好了，经过以上配置，一个基于spring HTTP invoker的远程服务就完成了，服务的地址为：

http://${serviceName}:${port}/${contextPath}/service/httpService

 

客户端

1.       创建服务接口及网络间传输的DTO类

为了方便，可以将服务器端创建好的的UcService.java和UserInfo.java拷贝到客户端,或打个jar包放到lib下。

2.       配置访问服务

²       WEB-INF/application-context.xml：如果项目中已经存在spring配置文件，则不需要创建该文件，需要配置HTTP invoker的代理

<bean id="httpService"

class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">

        <property name="serviceUrl">

            <value> http://${serviceName}:${port}/${contextPath}/service/httpService

</value>

        </property>

        <property name="serviceInterface"

            value="com.netqin.baike.service.UcService">

        </property>

</bean>

说明：客户端使用HttpInvokerProxyFactoryBean代理客户端向服务器端发送请求，请求接口为UcService的服务

注意：需要修改serviceUrl为实际的服务器地址

²         WEB-INF/web.xml：配置spring监听

如果项目没有spring环境，则需要在web.xml中加入对spring的支持

<context-param>

        <param-name>contextConfigLocation</param-name>

        <param-value>

            /WEB-INF/application-context.xml

        </param-value>

    </context-param>



    <listener>

        <listener-class>

            org.springframework.web.context.ContextLoaderListener

        </listener-class>

</listener>

 

3.       访问服务方法

u         读取spring上下文，以远程调用getUserInfobyName方法为例

²         在jsp,servlet,action等等文件中

UcService service = (UcService) WebApplicationContextUtils

        .getRequiredWebApplicationContext(

            request.getSession().getServletContext()).getBean(

            "httpService");

UserInfo user = service.getUserInfobyName("hanqunfeng");

 ²         如果不想配置spring运行环境，可以使用如下方式：

ApplicationContext applicationContext

= new FileSystemXmlApplicationContext("classpath:application-context.xml");

service = (UcService) applicationContext.getBean("httpService");

u         依赖注入，远程调用recordLog方法为例

²         在WEB-INF/application-context.xml中加入如下配置：

<bean id="abc" class="com.netqin.test.abc">

        <property name="service">

            <ref bean="httpService" />

        </property>

</bean>

²         为com.netqin.test.abc中加入对service的set方法：

private UcService service;

    public void setService(UcService service){

        this.service = service;

    }



    public String recordUserLog(String username,String point,String operate,String desc){

        String result = service.recordLog(username, point, operate, desc);

        return result;

}