RMI方式缓存集群/配置分布式缓存

我就是我 2022-02-27 04:43 356阅读 0赞

> RMI 是 Java 的一种远程方法调用技术，是一种点对点的基于 Java 对象的通讯方式。EhCache 从 1.2 版本开始就支持 RMI 方式的缓存集群。在集群环境中 EhCache 所有缓存对象的键和值都必须是可序列化的，也就是必须实现 java.io.Serializable 接口，这点在其它集群方式下也是需要遵守的。

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

[![clip\_image004][clip_image004]][clip_image004_clip_image004]

> 采用 RMI 集群模式时，集群中的每个节点都是对等关系，并不存在主节点或者从节点的概念，因此节点间必须有一个机制能够互相认识对方，必须知道其它节点的信息，包括主机地址、端口号等。EhCache 提供两种节点的发现方式：手工配置和自动发现。手工配置方式要求在每个节点中配置其它所有节点的连接信息，一旦集群中的节点发生变化时，需要对缓存进行重新配置。
> 
> 由于 RMI 是 Java 中内置支持的技术，因此使用 RMI 集群模式时，无需引入其它的 Jar 包，EhCache 本身就带有支持 RMI 集群的功能。使用 RMI 集群模式需要在 ehcache.xml 配置文件中定义 cacheManagerPeerProviderFactory 节点。

**      分布式同步缓存要让这边的cache知道对方的cache，叫做Peer Discovery（成员发现） EHCache实现成员发现的方式有两种：**

**1、手动查找**

> A、 在ehcache.xml中配置PeerDiscovery成员发现对象
> 
>       Server1配置，配置本地hostName、port是400001，分别监听192.168.8.32:400002的mobileCache和192.168.5.231:400003 的mobileCache。注意这里的mobileCache是缓存的名称，分别对应着server2、server3的cache的配置。
> 
>     <?xml version="1.0" encoding="gbk"?>
> 
>     <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="ehcache.xsd">
> 
>     <diskStore path="java.io.tmpdir"/>
> 
>      
> 
>     
> 
>      
> 
>     
> 
>     <cacheManagerPeerProviderFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
> 
>     properties="hostName=localhost,
> 
>     port=400001,
> 
>     socketTimeoutMillis=2000,
> 
>     peerDiscovery=manual,
> 
>     rmiUrls=//192.168.8.32:400002/mobileCache|//192.168.5.231:400003/mobileCache"
> 
>     />
> 
>     </ehcache>
> 
> 以上注意cacheManagerPeerProviderFactory元素出现的位置在diskStore下
> 
>  
> 
> 同样在你的另外2台服务器上增加配置
> 
> Server2，配置本地host，port为400002，分别同步192.168.8.9:400001的mobileCache和192.168.5.231:400003的mobileCache
> 
>     
> 
>     <cacheManagerPeerProviderFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
> 
>     properties="hostName=localhost,
> 
>     port=400002,
> 
>     socketTimeoutMillis=2000,
> 
>     peerDiscovery=manual,
> 
>     rmiUrls=//192.168.8.9:400001/mobileCache|//192.168.5.231:400003/mobileCache"
> 
>     />
> 
> Server3，配置本地host，port为400003，分别同步192.168.8.9:400001的mobileCache缓存和192.168.8.32:400002的mobileCache缓存
> 
>     
> 
>     <cacheManagerPeerProviderFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
> 
>     properties="hostName=localhost,
> 
>     port=400003,
> 
>     socketTimeoutMillis=2000,
> 
>     peerDiscovery=manual,
> 
>     rmiUrls=//192.168.8.9:400001/mobileCache|//192.168.8.32:400002/mobileCache"
> 
>     />
> 
> 这样就在三台不同的服务器上配置了手动查找cache的PeerProvider成员发现的配置了。 值得注意的是你在配置rmiUrls的时候要特别注意url不能重复出现，并且端口、地址都是对的。
> 
> 如果指定，hostname将使用InetAddress.getLocalHost().getHostAddress()来得到。
> 
> 警告：不要将localhost配置为本地地址127.0.0.1，因为它在网络中不可见将会导致不能从远程服务器接收信息从而不能复制。在同一台机器上有多个CacheManager的时候，你应该只用localhost来配置。
> 
>  
> 
> B、 下面配置缓存和缓存同步监听，需要在每台服务器中的ehcache.xml文件中增加cache配置和cacheEventListenerFactory、cacheLoaderFactory的配置
> 
>     <defaultCache maxElementsInMemory="10000" eternal="false" timeToIdleSeconds="30" timeToLiveSeconds="30" overflowToDisk="false"/>
> 
>     
> 
>     <cache name="mobileCache"
> 
>     maxElementsInMemory="10000"
> 
>     eternal="false"
> 
>     overflowToDisk="true"
> 
>     timeToIdleSeconds="1800"
> 
>     timeToLiveSeconds="3600"
> 
>     memoryStoreEvictionPolicy="LFU">
> 
>     
> 
>     
> 
>     <cacheEventListenerFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
> 
>     properties="replicateAsynchronously=true,
> 
>     replicatePuts=true,
> 
>     replicateUpdates=true,
> 
>     replicateUpdatesViaCopy=false,
> 
>     replicateRemovals=true "/>
> 
>     
> 
>     <bootstrapCacheLoaderFactory class="net.sf.ehcache.bootstrap.BootstrapCacheLoaderFactory"/>
> 
>     </cache>
> 
>  
> 
> C、 这样就完成了3台服务器的配置，下面给出server1的完整的ehcache.xml的配置
> 
>     <?xml version="1.0" encoding="gbk"?>
> 
>     <ehcache xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="ehcache.xsd">
> 
>     <diskStore path="java.io.tmpdir"/>
> 
>      
> 
>     
> 
>      
> 
>     
> 
>     <cacheManagerPeerProviderFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
> 
>     properties="hostName=localhost,
> 
>     port=400001,
> 
>     socketTimeoutMillis=2000,
> 
>     peerDiscovery=manual,
> 
>     rmiUrls=//192.168.8.32:400002/mobileCache|//192.168.5.231:400003/mobileCache"
> 
>     />
> 
>      
> 
>     <defaultCache maxElementsInMemory="10000" eternal="false" timeToIdleSeconds="30" timeToLiveSeconds="30" overflowToDisk="false"/>
> 
>     
> 
>     <cache name="mobileCache"
> 
>     maxElementsInMemory="10000"
> 
>     eternal="false"
> 
>     overflowToDisk="true"
> 
>     timeToIdleSeconds="1800"
> 
>     timeToLiveSeconds="3600"
> 
>     memoryStoreEvictionPolicy="LFU">
> 
>     
> 
>     
> 
>     <cacheEventListenerFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheReplicatorFactory"
> 
>     properties="replicateAsynchronously=true,
> 
>     replicatePuts=true,
> 
>     replicateUpdates=true,
> 
>     replicateUpdatesViaCopy=false,
> 
>     replicateRemovals=true "/>
> 
>     
> 
>     <bootstrapCacheLoaderFactory class="net.sf.ehcache.bootstrap.BootstrapCacheLoaderFactory"/>
> 
>     </cache>
> 
>     </ehcache>

**2、自动发现**

> 自动发现配置和手动查找的方式有一点不同，其他的地方都基本是一样的。同样在ehcache.xml中增加配置，配置如下
> 
>     
> 
>     <cacheManagerPeerProviderFactory
> 
>     class="net.sf.ehcache.distribution.RMICacheManagerPeerProviderFactory"
> 
>     properties="peerDiscovery=automatic, multicastGroupAddress=192.168.0.1,
> 
>     multicastGroupPort=400004, timeToLive=32"
> 
>     />
> 
> 常见的问题
> 
> Windows上的Tomcat
> 
> > 有一个Tomcat或者是JDK的bug，在tomcat启动时如果tomcat的安装路径中有空格的话，在启动时RMI监听器会失败。参见http://archives.java.sun.com/cgi-bin/wa?A2=ind0205&L=rmi-users&P=797和[http://www.ontotext.com/kim/doc/sys-doc/faq-howto-bugs/known-bugs.html][http_www.ontotext.com_kim_doc_sys-doc_faq-howto-bugs_known-bugs.html]。
> > 
> > 由于在Windows上安装Tomcat默认是装在“Program Files”文件夹里的，所以这个问题经常发生。
> 
> 广播阻断
> 
> > 自动的peer discovery与广播息息相关。广播可能被路由阻拦，像Xen和VMWare这种虚拟化的技术也可以阻拦广播。如果这些都打开了，你可能还在要将你的网卡的相关配置打开。一个简单的办法可以告诉广播是否有效，
> > 
> > 那就是使用ehcache remote debugger来看“心跳”是否可用。
> 
> 广播传播的不够远或是传得太远
> 
> > 你可以通过设置badly misnamed time to live来控制广播传播的距离。用广播IP协议时，timeToLive的值指的是数据包可以传递的域或是范围。约定如下：
> > 
> > 0是限制在同一个服务器
> > 
> > 1是限制在同一个子网
> > 
> > 32是限制在同一个网站
> > 
> > 64是限制在同一个region
> > 
> > 128是限制在同一个大洲
> > 
> > 255是不限制
> > 
> > 译者按：上面这些资料翻译的不够准确，请读者自行寻找原文理解吧。
> > 
> > 在Java实现中默认值是1，也就是在同一个子网中传播。改变timeToLive属性可以限制或是扩展传播的范围。
> > 
> >  
> > 
> > **其它可能造成缓存同步失败的问题**
> > 
> >  
> > 
> > ehcache 集群通过rmi组播 Multicast进行同步的，如果发现更新数据集群没有同步的话，可能原因：
> > 
> >  
> > 
> > 1、开启防火墙问题
> > 
> > 2、没有开启组播功能
> > 
> > windows下默认是开启的。
> > 
> > Linux下可能没有开启
> > 
> > route add -net 224.0.0.0 netmask 240.0.0.0 dev eth1
> > 
> > 3、Linux服务器的主机名（hostname）在/etc/hosts文件中设置的IP地址为127.0.0.1。检测方法为：
> > 
> > home>hostname -i
> > 
> > 如果返回值为127.0.0.1，那么这就是问题。
> > 
> > 解决方法：修改/etc/hosts文件，127.0.0.1 IP不能对应主机名，它对应localhost就可以了。
> > 
> > 修改之前的hosts文件：
> > 
> > 127.0.0.1       OAServer1  localhost localhost.localhost
> > 
> > 修改之后的hosts文件：
> > 
> > 127.0.0.1        localhost localhost.localhost
> > 
> >  
> 
> 其他的配置和手动查找方式的配置是一样的，这里就不再赘述了。关于ehcache的其他缓存配置方式这里将不再介绍，大家可以自己去研究。可以参考：

官方文档：[http://www.ehcache.org/documentation/user-guide/cache-topologies\#using-a-cache-server][http_www.ehcache.org_documentation_user-guide_cache-topologies_using-a-cache-server]

ibm developerworks文档：[http://www.ibm.com/developerworks/cn/java/j-lo-ehcache/index.html][http_www.ibm.com_developerworks_cn_java_j-lo-ehcache_index.html]

有不懂的，或者更好的见解可以随时交流！每天都会看的。

[clip_image004]: https://images.cnblogs.com/cnblogs_com/hoojo/201207/201207191626379120.jpg
[clip_image004_clip_image004]: /images/20220227/829ab8ce327d473982ac7c8c02e663b6.png
[http_www.ontotext.com_kim_doc_sys-doc_faq-howto-bugs_known-bugs.html]: http://www.ontotext.com/kim/doc/sys-doc/faq-howto-bugs/known-bugs.html
[http_www.ehcache.org_documentation_user-guide_cache-topologies_using-a-cache-server]: http://www.ehcache.org/documentation/user-guide/cache-topologies#using-a-cache-server
[http_www.ibm.com_developerworks_cn_java_j-lo-ehcache_index.html]: http://www.ibm.com/developerworks/cn/java/j-lo-ehcache/index.html