Spring HttpInvoke实现和效率提升

概念

Spring HTTP invoker是spring框架中的一个远程调用模型，执行基于HTTP的远程调用（意味着可以通过防火墙），并使用java的序列化机制在网络间传递 对象。

效率

远程调用效率: rmi>spring http invoker>webservice

优点

1.spring http invoker 采用java的序列化机制，并采用类似rmi的方式调用，既能够使用http协议轻松穿过防火墙，又能够保证高效的远程调用。

2.轻量级的远程调用模型，对于采用spring的项目可以无缝嵌入，侵入性小。

3.非常简单，容易上手。

缺点

只支持spring.

 

用户操作接口：

public interface UserService {
    /**
     * 获得用户
     *
     * @param username 用户名
     * @return
     */
    User getUser(String username);
}

 

用户实体类，注意实现Serializable接口，这是执行远程调用传递数据对象的第一要求——数据对象必须实现Serializable接口，因为，要执行序列化/反序列化操作！ 

public class User implements Serializable {  
  
    private static final long serialVersionUID = 5590768569302443813L;  
    private String username;  
    private Date birthday;  

    public User(String username, Date birthday) {
        this.username = username;
        this.birthday = birthday;
    }

    @Override  
    public String toString() {  
        return String.format("%s\t%s\t", username, birthday);  
    }
}

 

用户操作实现：

public class UserServiceImpl implements UserService {  
    private Logger logger = Logger.getLogger(UserServiceImpl.class);  

    @Override  
    public User getUser(String username) {  
        if (logger.isDebugEnabled()) {  
            logger.debug("username:[" + username + "]");  
        }  
        User user = new User(username, new Date());  
        if (logger.isDebugEnabled()) {  
            logger.debug("user:[" + user + "]");  
        }  
        return user;  
    }
}

 

服务端applicationContext-remote.xml 

<bean id="userService" class="org.springframework.remoting.httpinvoker.HttpInvokerServiceExporter">
    <property name="service">
        <bean class="org.zlex.spring.httpinvoke.service.impl.UserServiceImpl" />
    </property>
    <property name="serviceInterface" value="org.zlex.spring.httpinvoke.service.UserService" />
</bean>

<bean class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">
    <property name="urlMap">
        <map>  
            <entry key="userTest" value-ref="userService" />
        </map>
    </property>
</bean>
<!-- or
<bean class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">  
     <property name="mappings">  
        <props>  
	    <prop key="/userTest">userService</prop>
        </props>  
    </property>  
</bean>
-->

把userService暴露出去，这样外部就可以通过http接口调用这个接口的实现了。HttpInvokerServiceExporter这个类用来在服务器端包装需要暴露的接口。 

 

客户端applicationContext-client.xml 

<bean id="userService" class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">  
    <property name="serviceUrl" value="http://localhost:8080/spring/service/userTest" />  
    <property name="serviceInterface" value="org.zlex.spring.httpinvoke.service.UserService" />  
</bean>

这里我们可以通过Spring容器调用userService，而实际上，他是一个HttpInvokerProxyFactoryBean，在这个配置里，定义了访问地址serviceUrl和访问接口serviceInterface。  

 

如果我们这样写，其实默认调用了SimpleHttpInvokerRequestExecutor做实现，这个实现恐怕只能作为演示来用！这也是效率问题所在！！！为提高效率，应该通过Commons-HttpClient！  

<bean id="userService" class="org.springframework.remoting.httpinvoker.HttpInvokerProxyFactoryBean">  
    <property name="serviceUrl" value="http://localhost:8080/spring/service" />  
    <property  
        name="serviceInterface" value="org.zlex.spring.httpinvoke.service.UserService" />  
    <property name="httpInvokerRequestExecutor">  
        <ref bean="httpInvokerRequestExecutor" />  
    </property>  
</bean>  
<bean id="httpInvokerRequestExecutor" class="org.springframework.remoting.httpinvoker.CommonsHttpInvokerRequestExecutor">  
    <property name="httpClient">  
        <bean class="org.apache.commons.httpclient.HttpClient">  
            <property name="connectionTimeout" value="2000" />  
            <property name="timeout" value="5000" />  
        </bean>  
    </property>  
</bean>

 

通过HttpClient，我们可以配置超时时间timeout和连接超时connectionTimeout两个属性，这样服务器执行操作时，如果超时就可以强行释放连接，这样可怜的tomcat不会因为HttpInvoke连接不释放而被累死！

不过同事认为，这个效率还是不够高！！！

<bean id="httpInvokerRequestExecutor" class="org.springframework.remoting.httpinvoker.CommonsHttpInvokerRequestExecutor">  
    <property name="httpClient">  
        <bean class="org.apache.commons.httpclient.HttpClient">  
            <property name="connectionTimeout" value="2000" />  
            <property name="timeout" value="5000" />  
            <property name="httpConnectionManager">  
                <ref bean="multiThreadedHttpConnectionManager" />
            </property>  
        </bean>  
    </property>  
</bean>
<bean id="multiThreadedHttpConnectionManager" class="org.apache.commons.httpclient.MultiThreadedHttpConnectionManager">  
    <property name="params">  
        <bean class="org.apache.commons.httpclient.params.HttpConnectionManagerParams">  
            <property name="maxTotalConnections" value="600" />  
            <property name="defaultMaxConnectionsPerHost" value="512" />  
        </bean>  
    </property>  
</bean>

改用MultiThreadedHttpConnectionManager，多线程！！！

 

注意：在HttpClient的3.1版本中，已不支持如下配置，相应的方法已经废弃！

<property name="connectionTimeout" value="2000" />

<property name="timeout" value="5000" />

 

如果仔细看看文档，

引用

HttpClient that uses a default MultiThreadedHttpConnectionManager.

commons 系列的实现怎么会不考虑多线程呢？人家默认实现就是多线程的！同事多虑了！ 

当然，同事还补充了一句，需要控制连接数！ 

难怪，这里要设置  

<bean class="org.apache.commons.httpclient.params.HttpConnectionManagerParams">

    <property name="maxTotalConnections" value="600" />  

    <property name="defaultMaxConnectionsPerHost" value="512" />  

</bean>

默认啥情况？

引用

maxConnectionsPerHost 每个主机的最大并行链接数，默认为2  

public static final int DEFAULT_MAX_HOST_CONNECTIONS = 2;  

maxTotalConnections 客户端总并行链接最大数，默认为20   

public static final int DEFAULT_MAX_TOTAL_CONNECTIONS = 20;

 

web.xml中配置

 

<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>