coherence组件文档.docx

Coherence组件整理文档 基础实验整理： 基本实验01 启动分区式coherence服务，并添加BackingMapListener。监听数据的插入，修改，删除。实验在单机上运行。启动一个服务节点和一个客户端节点。 注意：BackingMapListener不是在这个配置文件中配置的。采用编程的方式，只能 增加在NamedCache上的各个分区的公共监听器。各个分区自己的监听器只能在co Herence自己的配置文件里面配置。 实验结果：可以通过配置实现监听服务节点的插入，修改，删除事件。 基本实验02 启动分区式coherence服务，测试数据在集群节点之间的分发。 实验在两台机器上进行。分别在两台机器上启动一个服务节点，组成集群。在 任意一台机器上启动一个客户端节点，想集群添加数据。通过在服务及诶单上添加的BackingMap监听器观察数据的分发情况。 注意：在进行实验的过程中，可能存在通过eclipse杀coherence服务进程杀不掉的情况。这时候，会存在集群混乱的情况。可以通过任务管理器终止进程或者重启机器来解决。 实验结果：可以看到数据分散的存储在两台机器上的服务节点中。但是没有一定规律，而且有时候会不均匀。 基本实验 03 启动分区式coherence服务，测试节点成员离开集群后，集群对这个成员的感知和处理。 实验在两台机器A，B上进行： 分别在A，B两台机器上启动分区式coherence服务。在A上启动客户端，向集群中插入数据。可以看到数据分发到两个服务节点上。将B机器上的网线断掉，在经过一个时间间隔后（10—20 S），A集群会感知到B机器上集群成员离开集群。在这个时间间隔内，如果，程序查询B机器节点的数据，程序会阻塞，一直到A机器集群确定B机器节点是真的离开了集群，然后从A集群中B上节点的备份数据来响应程序。 节点恢复： B节点不能直接通过接通网线的方式来进行节点的恢复。这样会造成集群数据混乱。 在接通网线之前，要将B节点的进程终止，然后，接通网线，启动B节点，B节点可成功加入到集群中。注意如果是直接停止B节点进程，在重新启动也能成功加入到集群。 以上过程，本质上是新加入了个新的节点。这个时候，分区式缓存服务会把适当的数据分摊到这个新的节点上。 注意：在设计Coherence组件的时候，应该有一个管理组件，在监测全部的成员。一旦某一个服务节点脱离集群，就应该马上停止这个服务节点。否则会造成集群的混乱。 集群节点的心跳可以通过coherence-override.xml文件中按一下配置来指定： tcp-ring-listener ip-timeout system-property=tangosol.coherence.ipmonitor.pingtimeout5s/ip-timeout ip-attempts2/ip-attempts listen-backlog10/listen-backlog /tcp-ring-listener 4）基础实验04 coherence在JBoss OSGi中运行 在OSGi环境中运行coherence服务的时候，会抛出以下异常： java.net.MalformedURLException: invalid url: jar:Coherence.class!/META-INF/MANIFEST.MF (java.net.MalformedURLException: no !/ in spec) The Manifest is corrupted or inaccessible; some functionality may be disabled 但是接下来程序仍然会启动coherence服务。 提示说原信息文件找不到。通过反编译coherence字节码看到，bundle类加载器没有成功读到coherence.jar文件的路径，查看查看API文档后，不能访问时安全策略的限制，在读取一个jar文件的路径的时候，会先进行安全策略的验证，在策略允许的情况下才能正确读取jar文件的位置。在接下来的提示中说明，一些功能会被关闭。就目前的测试来说，数据分发和集群成员功能可以正常使用。关于JBoss的访问jar包的安全策略还没有研究。 组件基本功能 根据配置文件，启动coherence服务，并提供coherenceAPI。 初始化信息： 组件的类型。为服务器端或者是客户端类型。如果是服务端类型，设置 System.setProperty(tangosol.coherence.distributed.localstorage, true); 如果是客户端类型，设置 System.setProperty(tangosol.coherence.distribu