EhCache RMI 集群模式

ゝ一世哀愁。 2022-08-09 16:40 96阅读 0赞

由于 EhCache 是进程中的缓存系统，一旦将应用部署在集群环境中，每一个节点维护各自的缓存数据，当某个节点对缓存数据进行更新，这些更新的数据无法在其它节点中共享，这不仅会降低节点运行的效率，而且会导致数据不同步的情况发生。例如某个网站采用 A、B 两个节点作为集群部署，当 A 节点的缓存更新后，而 B 节点缓存尚未更新就可能出现用户在浏览页面的时候，一会是更新后的数据，一会是尚未更新的数据，尽管我们也可以通过 Session Sticky 技术来将用户锁定在某个节点上，但对于一些交互性比较强或者是非 Web 方式的系统来说，Session Sticky 显然不太适合。  
EhCache从1.7版本开始，支持五种集群方案，分别是：  
• Terracotta  
• RMI  
• JMS  
• JGroups  
• EhCache Server  
其中的三种最为常用集群方式，分别是 RMI、JGroups 以及 EhCache Server 。分布式这个特性是以plugin的方式实现的。Ehcache自带了一些默认的分布式缓存插件实现，这些插件可以满足大部分应用的需要。如果需要使用其他的插件那就需要自己开发了，开发者可以通过查看distribution包里的源代码及JavaDoc来实现它。  
RMI 是 Java 的一种远程方法调用技术，是一种点对点的基于 Java 对象的通讯方式。EhCache 从 1.2 版本开始就支持 RMI 方式的缓存集群。在集群环境中 EhCache 所有缓存对象的键和值都必须是可序列化的，也就是必须实现 java.io.Serializable 接口，这点在其它集群方式下也是需要遵守的。

下图是 RMI 集群模式的结构图：、

![Center][]

采用 RMI 集群模式时，集群中的每个节点都是对等关系，并不存在主节点或者从节点的概念，因此节点间必须有一个机制能够互相认识对方，必须知道其它节点的信息，包括主机地址、端口号等。EhCache 提供两种节点的发现方式：手工配置和自动发现。手工配置方式要求在每个节点中配置其它所有节点的连接信息，一旦集群中的节点发生变化时，需要对缓存进行重新配置。

由于 RMI 是 Java 中内置支持的技术，因此使用 RMI 集群模式时，无需引入其它的 Jar 包，EhCache 本身就带有支持 RMI 集群的功能。使用RMI集群模式需要在 ehcache.xml 配置文件中定义 cacheManagerPeerProviderFactory 节点。

**1.环境**

同一台机器，模拟2个应用，使用不是同的RMI端口同步数据

127.0.0.1  4000

127.0.0.1  5000

**2.ehcache配置**

**APP1：**

<?xml version="1.0" encoding="UTF-8"?>
    <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd">
    
    	<diskStore path="java.io.tmpdir/ehcache-rmi-4000" />
    
    	
    	<cacheManagerPeerProviderFactory
    		class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
    		properties="peerDiscovery=manual,rmiUrls=//127.0.0.1:5000/demoCache">
    	</cacheManagerPeerProviderFactory>
    	
    	<cacheManagerPeerListenerFactory
    		class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory"
    		properties="hostName=127.0.0.1,port=4000,socketTimeoutMillis=120000" /> 
    	
    	
        	
    	
    	<defaultCache maxElementsInMemory="1000" eternal="true"
    		timeToIdleSeconds="120" timeToLiveSeconds="120" overflowToDisk="true"
    		diskSpoolBufferSizeMB="30" maxElementsOnDisk="10000000"
    		diskPersistent="true" diskExpiryThreadIntervalSeconds="120"
    		memoryStoreEvictionPolicy="LRU">
    	</defaultCache>
    
    	
    	<cache name="demoCache" maxElementsInMemory="1000" eternal="false"
    		timeToIdleSeconds="120" timeToLiveSeconds="120" overflowToDisk="true"
    		diskSpoolBufferSizeMB="30" maxElementsOnDisk="10000000"
    		diskPersistent="false" diskExpiryThreadIntervalSeconds="120"
    		memoryStoreEvictionPolicy="LRU">
    		<cacheEventListenerFactory
    			class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" />
    		
    		<bootstrapCacheLoaderFactory
    			class="net.sf.ehcache.distribution.RMIBootstrapCacheLoaderFactory" />
    	</cache>
    </ehcache>

以上是通过IP:PORT配置，也可以通过多播的方式配置

<cacheManagerPeerProviderFactory
    		class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
    		properties="peerDiscovery=automatic, multicastGroupAddress=224.1.1.1,
        	multicastGroupPort=40000, timeToLive=32" />

APP2配置：

<?xml version="1.0" encoding="UTF-8"?>
    <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:noNamespaceSchemaLocation="http://ehcache.org/ehcache.xsd">
    
    	<diskStore path="java.io.tmpdir/ehcache-rmi-5000" />
    
    	
    	 <cacheManagerPeerProviderFactory class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory" 
    		properties="peerDiscovery=manual,rmiUrls=//127.0.0.1:4000/demoCache"> </cacheManagerPeerProviderFactory> 
    		
    	<cacheManagerPeerListenerFactory class="net.sf.ehcache.distribution.RMICacheManagerPeerListenerFactory" 
    		properties="hostName=127.0.0.1,port=5000,socketTimeoutMillis=120000" /> 
    
    	
    
    	
    	<defaultCache maxElementsInMemory="1000" eternal="true"
    		timeToIdleSeconds="120" timeToLiveSeconds="120" overflowToDisk="true"
    		diskSpoolBufferSizeMB="30" maxElementsOnDisk="10000000"
    		diskPersistent="true" diskExpiryThreadIntervalSeconds="120"
    		memoryStoreEvictionPolicy="LRU">
    	</defaultCache>
    
    	
    	<cache name="demoCache" maxElementsInMemory="1000" eternal="false"
    		timeToIdleSeconds="120" timeToLiveSeconds="120" overflowToDisk="true"
    		diskSpoolBufferSizeMB="30" maxElementsOnDisk="10000000"
    		diskPersistent="false" diskExpiryThreadIntervalSeconds="120"
    		memoryStoreEvictionPolicy="LRU">
    		<cacheEventListenerFactory
    			class="net.sf.ehcache.distribution.RMICacheReplicatorFactory" />
    		
    		<bootstrapCacheLoaderFactory
    			class="net.sf.ehcache.distribution.RMIBootstrapCacheLoaderFactory" />
    	</cache>
    </ehcache>

可以使用 [上一节][Link 1]spring配置，创建不同APP，启动，控制台输入，即可看到同步效果。这里不详细演示了。

源码：[http://download.csdn.net/detail/tianwei7518/9231745][http_download.csdn.net_detail_tianwei7518_9231745]

参考文章：

1.[EhCache 分布式缓存/缓存集群][EhCache]   
2.[ehcache配置文件译文][ehcache]   
[3.EhCache集群][3.EhCache]

[Center]: /images/20220731/a3683cefba6d433091a46bca0f01af32.png
[Link 1]: http://blog.csdn.net/zhu_tianwei/article/details/49560179
[http_download.csdn.net_detail_tianwei7518_9231745]: http://download.csdn.net/detail/tianwei7518/9231745
[EhCache]: http://www.cnblogs.com/hoojo/archive/2012/07/19/2599534.html
[ehcache]: http://dreamzhong.iteye.com/blog/1161954
[3.EhCache]: http://blog.csdn.net/ni_hao_ya/article/details/9339275