tomcat 集群下ehcache 整合spring cache-annotation

系统环境：win7
部署环境：apache2.2 tomcat4
应用程序版本：spring3.2 ehcache2.6

1:tomcat 负载和集群配置
1.1 模型图

[img]

[/img]

tomcat负载需要apache协助，apache启的作用就是，接受client请求，调度tomcat.
各个tomcat分载请求，均衡流量，降低web server压力。通过tomcat cluster 可以实现各tomcat数据同步和共享。
1.2 配置
    解压两个统一版本的tomcat 分别命名为apache-tomcat-6080 和apache-tomcat-7080
   修改6080tomcat srever。xml

 <Server port="6005" shutdown="SHUTDOWN"> 
   <Connector port="6080" protocol="HTTP/1.1" 
        connectionTimeout="20000" 
        redirectPort="6443"  
        useBodyEncodingForURI ="true" 
        URIEncoding="UTF-8"
   />
   <Connector port="6009" protocol="AJP/1.3" redirectPort="6443" />
   <!--jvmRoute 是apache 检测通道名--> 
   <Engine name="Catalina" defaultHost="localhost"   
    jvmRoute="tomcat1">
   
   <Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster"
                 channelSendOptions="8">

          <Manager className="org.apache.catalina.ha.session.DeltaManager"
                   expireSessionsOnShutdown="false"
                   notifyListenersOnReplication="true"/>

          <Channel className="org.apache.catalina.tribes.group.GroupChannel">
            <Membership className="org.apache.catalina.tribes.membership.McastService"
                        address="228.0.0.4"
                        port="45564"
                        frequency="500"
                        dropTime="3000"/>
            <!--port 不同tomcat 设置不同-->
            <Receiver className="org.apache.catalina.tribes.transport.nio.NioReceiver"
                      address="auto"
                      port="4001"
                      autoBind="100"
                      selectorTimeout="5000"
                      maxThreads="6"/>

            <Sender className="org.apache.catalina.tribes.transport.ReplicationTransmitter">
              <Transport className="org.apache.catalina.tribes.transport.nio.PooledParallelSender"/>
            </Sender>
            <Interceptor className="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"/>
            <Interceptor className="org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor"/>
          </Channel>

          <Valve className="org.apache.catalina.ha.tcp.ReplicationValve"
                 filter=""/>
          <Valve className="org.apache.catalina.ha.session.JvmRouteBinderValve"/>

          <Deployer className="org.apache.catalina.ha.deploy.FarmWarDeployer"
                    tempDir="/tmp/war-temp/"
                    deployDir="/tmp/war-deploy/"
                    watchDir="/tmp/war-listen/"
                    watchEnabled="false"/>

          <ClusterListener className="org.apache.catalina.ha.session.JvmRouteSessionIDBinderListener"/>
          <ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/>
        </Cluster>

修改7080tomcat srever。xml

 <Server port="7005" shutdown="SHUTDOWN"> 
   <Connector port="7080" protocol="HTTP/1.1" 
        connectionTimeout="20000" 
        redirectPort="7443"  
        useBodyEncodingForURI ="true" 
        URIEncoding="UTF-8"
   />
   <Connector port="7009" protocol="AJP/1.3" redirectPort="7443" />
   <!--jvmRoute 是apache 检测通道名--> 
   <Engine name="Catalina" defaultHost="localhost"   
    jvmRoute="tomcat1">
   
   <Cluster className="org.apache.catalina.ha.tcp.SimpleTcpCluster"
                 channelSendOptions="8">

          <Manager className="org.apache.catalina.ha.session.DeltaManager"
                   expireSessionsOnShutdown="false"
                   notifyListenersOnReplication="true"/>

          <Channel className="org.apache.catalina.tribes.group.GroupChannel">
            <Membership className="org.apache.catalina.tribes.membership.McastService"
                        address="228.0.0.4"
                        port="45564"
                        frequency="500"
                        dropTime="3000"/>
            <!--port 不同tomcat 设置不同-->
            <Receiver className="org.apache.catalina.tribes.transport.nio.NioReceiver"
                      address="auto"
                      port="4002"
                      autoBind="100"
                      selectorTimeout="5000"
                      maxThreads="6"/>

            <Sender className="org.apache.catalina.tribes.transport.ReplicationTransmitter">
              <Transport className="org.apache.catalina.tribes.transport.nio.PooledParallelSender"/>
            </Sender>
            <Interceptor className="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"/>
            <Interceptor className="org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor"/>
          </Channel>

          <Valve className="org.apache.catalina.ha.tcp.ReplicationValve"
                 filter=""/>
          <Valve className="org.apache.catalina.ha.session.JvmRouteBinderValve"/>

          <Deployer className="org.apache.catalina.ha.deploy.FarmWarDeployer"
                    tempDir="/tmp/war-temp/"
                    deployDir="/tmp/war-deploy/"
                    watchDir="/tmp/war-listen/"
                    watchEnabled="false"/>

          <ClusterListener className="org.apache.catalina.ha.session.JvmRouteSessionIDBinderListener"/>
          <ClusterListener className="org.apache.catalina.ha.session.ClusterSessionListener"/>
        </Cluster>

   配置apache
   将mod_jk-1.2.31-httpd-2.2.3.so 复制到apache moudles 中。
    在conf中创建mod_jk.conf 和workers.properties。
    mod_jk.conf  主要定义mod_jk模块的位置以及mod_jk模块的连接日志设置，还有定义worker.properties文件的位置。
   

    LoadModule jk_module modules/mod_jk-1.2.31-httpd-2.2.3.so
JkWorkersFile conf/workers.properties
JkMount /*.* controller

    

  
    workers.properties 定义worker的参数，主要是连接tomcat主机的地址和端口信息。如果Tomcat与apache不在同一台机器上，或者需要做多台机器上tomcat的负载均衡只需要更改workers.properties文件中的相应定义即可。
   

    #server
worker.list = controller,tomcat1,tomcat2
#========tomcat1========
worker.tomcat1.port=6009
worker.tomcat1.host=localhost
worker.tomcat1.type=ajp13
worker.tomcat1.lbfactor = 1
#========tomcat2========
worker.tomcat2.port=7009
worker.tomcat2.host=localhost
worker.tomcat2.type=ajp13
worker.tomcat2.lbfactor = 1

#========controller,负载均衡控制器========
worker.controller.type=lb
worker.controller.balanced_workers=tomcat1,tomcat2
worker.controller.sticky_session=false
worker.controller.sticky_session_force=1
#worker.controller.sticky_session=1


   

  
将conf/httpdf.conf 文件末尾追加：

Include conf/mod_jk.conf

2 ehcache 与 spring-cache 整合
  2.1 添加ehcache.xml

<?xml version="1.0" encoding="UTF-8"?>
<ehcache>
    <diskStore path="F:/eclipse_workspace/springmvc3.2/cache"/>
    <defaultCache
     maxElementsInMemory="500"
     eternal="false"
     timeToIdleSeconds="300"
     timeToLiveSeconds="1200"
     overflowToDisk="true"/>
    <cache name="user" maxElementsInMemory="150" eternal="false" timeToLiveSeconds="36000" timeToIdleSeconds="3600" overflowToDisk="true">
          <cacheEventListenerFactory class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" 
              properties="replicateAsynchronously=true, replicatePuts=true, replicateUpdates=true,replicateUpdatesViaCopy= true, replicateRemovals= true " />
          <!-- <cacheEventListenerFactory class="cn.com.dwsoft.test.ehcache.EventFactory" />    -->
    </cache>
   <cacheManagerPeerProviderFactory class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
   properties="peerDiscovery=manual,rmiUrls=//127.0.0.1:40002/user"/>

    <cacheManagerPeerListenerFactory class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory"
        properties="hostName=127.0.0.1,port=40001,socketTimeoutMillis=2000"/>
</ehcache>

cacheManagerPeerProviderFactory 其他tomcat 多个url 可以用，分割
cacheManagerPeerListenerFactory 当前tomcat
部署时，需要根据tomcat 集群监听端口 修改各自的ehcache.xml配置.


applictionContext.xml 配置

<!-- cacheManager工厂类 -->

	<bean id="cacheManagerFactory" class="org.springframework.cache.ehcache.EhCacheManagerFactoryBean"

     p:configLocation="classpath:ehcache.xml"

     p:shared="false" />


	<!-- 声明cacheManager -->
	<bean id="cacheManager" class="org.springframework.cache.ehcache.EhCacheCacheManager"
	   p:cacheManager-ref="cacheManagerFactory"/>

spring 注解缓存使用

package com.cn.ld.modules.user.service.impl;

import java.util.Arrays;

@EnableCaching
@Service
public class UserServiceImpl implements UserService ,UserDetailsService{
	private User[] users = null;
	{
		users = new User[5];
		users[0] = new User("java小生0", "111111", 21, '男');
		users[1] = new User("java小生1", "222222", 22, '男');
		users[2] = new User("java小生2", "333333", 23, '男');
		users[3] = new User("java小生3", "444444", 24, '男');
		users[4] = new User("java小生4", "555555", 25, '女');
	}

	@Cacheable(value = "user" , condition="#id < 3" ,unless="#result.age == 25")
	public User findById(int id) {
		System.out.println("--------findById start-----------");
		System.out.println("agrs{id:"+id+"}");
		User u = Arrays.asList(users).get(id);
		System.out.println("--------findById end-----------");
		return u;
	}

	@Override
	public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException
	{
		User user = new User(username, "111111", 25, '男');
		return user ;
	}
}