Spring HTTP Invoker 学习小记

Spring HTTP Invoker是spring框架中的一个远程调用模型，执行基于HTTP的远程调用，也就是说，可以通过防火墙，并使用java的序列化机制在网络间传递对象。客户端可以很轻松的像调用本地对象一样调用远程服务器上的对象，要注意的一点是，服务端、客户端都是使用Spring框架。下面通过一个例子，来 讲解Spring HTTP Invoker的使用，这里使用的是
Spring2.5.6
框架。

Spring HTTP Invoker的整体流程如下 （下图显示整个调用的过程）

客户端

向服务器发送远程调用请求
远程调用信息-->封装为远程调用对象-->序列化写入到远程调用http请求中-->向服务器端发送

接收服务器端返回的远程调用结果
服务器端返回的远程调用结果HTTP响应——>反序列化为远程调用结果对象

服务端


接收客户端发送的远程调用请求
客户端发送的远程调用HTTP请求——>反序列化为远程调用对象——>调用服务器端目标对象的目标方法处理

向客户端返回远程调用结果
服务器端目标对象方法的处理结果——>序列化写入远程调用结果HTTP响应中——>返回给客户端。



Spring HTTP Invoker有两种实现方式

基于Url映射方式，远程系统处理请求的方式同SpringMVC的controller类似，所有的请求通过在web.xml中的 org.springframework.web.servlet.DispatcherServlet统一处理，根据url映射，去对应的 【servlet名称-servlet.xml】文件中，查询跟请求的url匹配的bean配置

基于Servlet方式，由org.springframework.web.context.support.HttpRequestHandlerServlet去拦截url- pattern匹配的请求，如果匹配成功，去ApplicationContext中查找name与servlet-name一致的bean，完成远程方法调用。

这里采用第一种方式进行实现。先配置服务端

建立web项目

导入jar包

spring.jar

spring-webmvc.jar

commons-logging-1.1.2.jar

在web.xml新增如下配置文件

<servlet>
<servlet-name>application</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>application</servlet-name>
<url-pattern>/*</url-pattern>
</servlet-mapping>

在WEB-INF下增加application-servlet.xml (注意xml文件的命名，这里的application要和servlet-name名字保持一致)配置如下

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN"
"http://www.springframework.org/dtd/spring-beans-2.0.dtd">
<beans>
<bean id="userService" class="org.felix.service.impl.UserServiceImpl" />
<!-- 基于Url映射方式,这个配置，就是把userService接口，提供给远程调用 -->
<bean id="httpService"  class="org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter">
<property name="service" ref="userService"/>
<property name="serviceInterface" value="org.felix.service.UserService"/>
</bean>
<!-- 远程服务的URL -->
<bean
class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">
<property name="mappings">
<props>
<prop key="/test">httpService</prop>
</props>
</property>
</bean>
</beans>

建立相关类和包结构，如下图所示



各类代码如下
User类，需要实现Serializable 接口

package org.felix.model;

import java.io.Serializable;

public class User implements Serializable {

/**
*
*/
private static final long serialVersionUID = 1L;
private String name;
private String password;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}

}

UserService接口

package org.felix.service;

import org.felix.model.User;

public interface UserService {
void add(User u);
}

UserService接口的实现类UserServiceImpl

package org.felix.service.impl;

import org.felix.model.User;
import org.felix.service.UserService;

public class UserServiceImpl implements UserService {

@Override
public void add(User u) {
System.out.println("add user[" + u.getName() + "]");
}

}

配置客户端

复制服务端工程，重命名一下，工程结构如下图



在src目录下新建application-servlet.xml配置如下

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN 2.0//EN"
"http://www.springframework.org/dtd/spring-beans-2.0.dtd">
<beans>
<bean id="httpTestService"
class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">
<property name="serviceUrl">
<value>http://localhost:8080/felix_0400_SpringHttp_Server/test</value>
</property>
<property name="serviceInterface">
<value>org.felix.service.UserService</value>
</property>
</bean>
</beans>

新建测试类TestSpringHttp代码如下

import org.felix.model.User;
import org.felix.service.UserService;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestSpringHttp {
private static ApplicationContext context = new ClassPathXmlApplicationContext("application-servlet.xml");

public static UserService getUserService(){
return (UserService)context.getBean("httpTestService");
}
public static void main(String[] args) {
User user = new User();
user.setName("felix");
user.setPassword("felix");
getUserService().add(user);
}
}

运行程序在控制台输出如下



参考文章

Spring中HttpInvoker远程调用使用实例

Spring HTTP Invoker例子

《Spring技术内幕》学习笔记17——Spring HTTP调用器实现远程调用