Spring HTTP Invoker例子

展开全文

Spring HTTP Invoker例子

标签： #Java编程 | 发布时间：2011-06-19

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

整体流程如下：
1.服务器端：通过Spring HTTP Invoker，将服务接口的某个实现类提供为远程服务。
2.客户端：通过Spring HTTP Invoker代理，向服务端发送请求，远程调用服务端接口。

注意事项：由于是通过网络传输，所以服务端、客户端的POJO类，都要实现Serializable接口，进行序列化、反序列化。

先看看服务端的配置：
1.先提供一个服务接口

package spring.invoker.service;
 
import spring.invoker.domain.UserInfo;
 
/**
* spring http invoker例子
* @author steven
*
*/
public interface UserService {
/**
* 根据用户名，获取用户信息
* @param userName  用户名
* @return   返回用户信息
*/
public UserInfo getUserInfobyName(String userName);
 
 
 
/**
* 根据用户名，获取用户邮箱
* @param userName  用户名
* @return   返回用户邮箱
*/
public String getUserEmailbyName(String userName);
}

2.再实现这个服务接口，像平时写service一样，这里只是一个简单的例子，可以在这里调用自己的DAO，查询数据库。

package spring.invoker.service.impl;
 
import spring.invoker.domain.UserInfo;
import spring.invoker.service.UserService;
 
/**
* spring http invoker例子
* @author steven
*
*/
public class UserServiceImpl implements UserService{
 
 
/**
* 根据用户名，获取用户信息
* @param userName  用户名
* @return   返回用户信息
*/
public UserInfo getUserInfobyName(String userName){
UserInfo userInfo = new UserInfo();
userInfo.setUserName(userName);
userInfo.setEmail("xxx@site.com");
 
return userInfo;
}
 
 
 
/**
* 根据用户名，获取用户邮箱
* @param userName  用户名
* @return   返回用户邮箱
*/
public String getUserEmailbyName(String userName){
return userName + "的邮箱地址为：xxx.site.com";
}
}

3.接下来，就是POJO类了，这个类一定要实现Serializable接口，并指定一个serialVersionUID。

package spring.invoker.domain;
 
import java.io.Serializable;
 
/**
* 用户基本信息
* @author steven
*
*/
public class UserInfo implements Serializable {
private static final long serialVersionUID = 1L;
private String userName;
private String email;
 
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;
}
 
}

4.将接口声明为HTTP Invoker服务

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www./schema/beans"
xmlns:xsi="http://www./2001/XMLSchema-instance"
xmlns:p="http://www./schema/p"
xmlns:context="http://www./schema/context"
xsi:schemaLocation="
http://www./schema/beans 
http://www./schema/beans/spring-beans-3.0.xsd
http://www./schema/context 
http://www./schema/context/spring-context-3.0.xsd">
 
<!-- 交给Spring管理，bean的名称是：userService -->
<bean id="userService" class="spring.invoker.service.impl.UserServiceImpl"/>
 
<!-- 这个配置，就是把userService接口，提供给远程调用 -->
<bean id="httpService"
class="org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter">
<property name="service">
<ref bean="userService" />
</property>
<property name="serviceInterface"
value="spring.invoker.service.UserService">
</property>
</bean>
 
<!-- 远程服务的URL -->
<bean
class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">
<property name="mappings">
<props>
<prop key="/test">httpService</prop>
</props>
</property>
</bean>
 
</beans>

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

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www./2001/XMLSchema-instance"
xmlns="http://java./xml/ns/javaee" xmlns:web="http://java./xml/ns/javaee/web-app_2_5.xsd"
xsi:schemaLocation="http://java./xml/ns/javaee http://java./xml/ns/javaee/web-app_2_5.xsd"
id="WebApp_ID" version="2.5">
<display-name>Spring3.0 Test Demo</display-name>
<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>
/WEB-INF/dispatcher-service.xml
/WEB-INF/dispatcher-servlet.xml
</param-value>
</context-param>
<listener>
<listener-class>
org.springframework.web.context.ContextLoaderListener
</listener-class>
</listener>
<servlet>
<servlet-name>dispatcher</servlet-name>
<servlet-class>
org.springframework.web.servlet.DispatcherServlet
</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>    
<servlet-mapping>
<servlet-name>dispatcher</servlet-name>
<url-pattern>/</url-pattern>
</servlet-mapping>
</web-app>

通过以上5步，就配置好了Spring HTTP Invoker服务，地址：http://${serviceName}:${port}/${contextPath}/test

下面就是客户端怎么调用远程Spring HTTP Invoker服务。
1.创建服务接口及网络间传输的POJO类，为了方便，可以将服务器端创建好的的UserService.java和UserInfo.java拷贝到客户端,或打个jar包放到lib下。

2.配置HTTP Invoker的代理，用来调用远程服务，spring配置文件如下:

<bean id="httpService"
class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">
<property name="serviceUrl">
<value>
http://${serviceName}:${port}/${contextPath}/test
</value>
</property>
<property name="serviceInterface" value="spring.invoker.service.UserService">
</property>
</bean>

3. 下面是使用Spring注解的方式，当然，你也可以使用配置的方式，把下面的类交给Spring管理，再把httpService通过set的方式，注入进来。

package spring.invoker;
 
import javax.annotation.Resource;
 
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
 
import spring.invoker.service.UserService;
 
@Controller
public class InvokerAction {
@Resource private UserService httpService;
 
@RequestMapping(value="/httpTest")
public void testInvoker(){
System.out.println(httpService.getUserEmailbyName("xxx"));
}
 
}