Ehcache一台服务器多个Tomcat组成的集群间的缓存同步实践
Tomcat集群部署情况说明
成都创新互联公司长期为上千家客户提供的网站建设服务,团队从业经验10年,关注不同地域、不同群体,并针对不同对象提供差异化的产品和服务;打造开放共赢平台,与合作伙伴共同营造健康的互联网生态环境。为陇西企业提供专业的成都网站建设、成都网站制作,陇西网站改版等技术服务。拥有10余年丰富建站经验和众多成功案例,为您定制开发。两台Web服务器,每台服务器部署两个tomcat
server1 192.168.178.101
tomcat1 tomcat2
server2 192.168.178.102
tomcat3 tomcat4
采用Ehcache的RMI方式来实现缓存同步复制
方式一:自动发现集群成员
ehcache.xml配置如下:
xsi:noNamespaceSchemaLocation="ehcache.xsd" updateCheck="true"monitoring="autodetect" dynamicConfig="true"> class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory" properties="peerDiscovery=automatic, multicastGroupAddress=230.0.0.1, multicastGroupPort=4446 timeToLive=1"/> class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory"/> maxElementsInMemory="100" eternal="true" overflowToDisk="false" memoryStoreEvictionPolicy="LFU"> PS: a、配置简单,每个tomcat使用完全相同的ehcache配置; b、通过多播( multicast )来维护集群中的所有有效节点。这也是最为简单而且灵活的方式,与手工模式不同的是,每个节点上的配置信息都相同,大大方便了节点的部署,避免人为的错漏出现。 c、timeToLive的值指的是数据包可以传递的域或是范围。约定如下: 0是限制在同一个服务器 1是限制在同一个子网 32是限制在同一个网站 64是限制在同一个region 128是限制在同一个大洲 255是不限制 在Java实现中默认值是1,也就是在同一个子网中传播。改变timeToLive属性可以限制或是扩展传播的范围。 d、自动的peer discovery与广播息息相关。广播可能被路由阻拦,像Xen和VMWare这种虚拟化的技术也可以阻拦广播(阿里云主机好像也不提供广播,阿里云服务器上部署时可采用手动配置成员发现)。 如果这些都打开了,你可能还在要将你的网卡的相关配置打开。一个简单的办法可以告诉广播是否有效,那就是使用ehcache remote debugger来看“心跳”是否可用。 方式二:手动配置发现集群成员 ehcache.xml配置如下: xsi:noNamespaceSchemaLocation="ehcache.xsd" updateCheck="true"monitoring="autodetect" dynamicConfig="true"> class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory" properties="peerDiscovery=manual, rmiUrls= //192.168.178.101:50001/Cache1| //192.168.178.101:50001/Cache2| //192.168.178.102:40001/Cache1| //192.168.178.102:40001/Cache2| //192.168.178.102:50001/Cache1| //192.168.178.102:50001/Cache2"/> class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory" properties="hostName=192.168.178.101,port=40001,socketTimeoutMillis=2000"/> maxElementsInMemory="1000" eternal="true" overflowToDisk="false" memoryStoreEvictionPolicy="LFU"> class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" properties=" replicateAsynchronously=true, replicatePuts=true, replicateUpdates=true, replicateUpdatesViaCopy=false, replicateRemovals=true"/> maxElementsInMemory="2000" eternal="true" overflowToDisk="false" memoryStoreEvictionPolicy="LFU"> class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" properties=" replicateAsynchronously=true, replicatePuts=true, replicateUpdates=true, replicateUpdatesViaCopy=false, replicateRemovals=true"/> PS: a、每个tomcat的配置文件都不一样,部署集群时有点繁琐; b、配置cacheManagerPeerProviderFactory,rmiUrls配置需要同步的各个集群节点列表(不包括本服务器节点); 上面示例配置文件是tomcat1的配置,rmiUrls列表配置tomcat2,tomcat3,tomcat4需要同步的缓存项,每个缓存项的配置格式://server:port/cacheName 同理,tomcat2的配置中,rmiUrls列表就需要配置tomcat1,tomcat3,tomcat4的缓存项;tomcat3,tomcat4以此类推; c、配置cacheManagerPeerListenerFactory,本节点的缓存监听配置,属性中需指定本节点IP或域名、监听端口号、socket通信超时时间 hostName=192.168.178.101,port=40001,socketTimeoutMillis=2000 同理:tomcat2配置:hostName=192.168.178.101,port=50001,socketTimeoutMillis=2000 tomcat3配置:hostName=192.168.178.102,port=40001,socketTimeoutMillis=2000 tomcat4配置:hostName=192.168.178.102,port=50001,socketTimeoutMillis=2000 d、配置具体的cache,需要配置cacheEventListenerFactory,指定哪些操作时需要replicate cache(同步复制缓存) replicatePuts=true | false – 当一个新元素增加到缓存中的时候是否要同步复制到其他的peers. 默认是true。 Ehcahce官方文档中的描述: Thefactoryrecognisesthefollowingproperties: replicatePuts=true|false-whethernewelementsplacedinacachearereplicatedtoothers.Defaultstotrue. replicateUpdates=true|false-whethernewelementswhichoverrideanelementalreadyexistingwiththesamekeyarereplicated.Defaultstotrue. replicateRemovals=true-whetherelementremovalsarereplicated.Defaultstotrue. replicateAsynchronously=true|false-whetherreplicationsareasyncrhonous(true)orsynchronous(false).Defaultstotrue. replicateUpdatesViaCopy=true|false-whetherthenewelementsarecopiedtoothercaches(true),orwhetheraremovemessageissent.Defaultstotrue. 调用Ehcahe提供的API,编码缓存的加载及获取,更新 引入jar包:ehcache.jar 放入缓存的对象必须是可序列化的,即必须实现接口Serializable 示例代码: publicclassImeiWhiteListCacheHelper{ privatestaticfinalStringIMEI_CACHE="IMEICache"; privatestaticImeiWhiteListDAOimeiDao=newImeiWhiteListDAO(); privatestaticCachecache; static{ cache=CacheManager.getInstance().getCache(IMEI_CACHE); } /** *重新加载IMEI白名单到缓存中 * *@throwsSQLException */ publicstaticvoidreloadImeiWhiteListToCache()throwsSQLException{ synchronized(cache){ cache.removeAll(); List for(ImeiWhiteListDTOimeiWhiteListDTO:list){ Elemente=newElement(imeiWhiteListDTO.getImei(),imeiWhiteListDTO); cache.put(e); } } } /** *从缓存中获取某个IMEI的信息。如缓存获取失败,从DB中读取,再放入缓存 * *@paramimei *@return *@throwsSQLException */ publicstaticImeiWhiteListDTOgetImeiInfo(Stringimei)throwsSQLException{ ImeiWhiteListDTOimeiInfo=null; synchronized(cache){ Elementelement=cache.get(imei); if(element!=null){ //System.out.println("hitcount:"+element.getHitCount()); imeiInfo=(ImeiWhiteListDTO)element.getObjectValue(); }else{ imeiInfo=imeiDao.getModelByIMEI(imei); if(imeiInfo!=null){ cache.put(newElement(imeiInfo.getImei(),imeiInfo)); } } } returnimeiInfo; } }
replicateUpdates=true | false – 当一个已经在缓存中存在的元素被覆盖更新时是否要进行复制。默认是true。
replicateRemovals= true | false – 当元素移除的时候是否进行复制。默认是true。
replicateAsynchronously=true | false – 复制方式是异步的(指定为true时)还是同步的(指定为false时)。默认是true。
replicateUpdatesViaCopy=true | false – 当一个元素被拷贝到其他的cache中时是否进行复制(指定为true时为复制),默认是true。
网页题目:Ehcache一台服务器多个Tomcat组成的集群间的缓存同步实践
标题路径:http://scyanting.com/article/cgpghp.html