Infinispan集群式REPL_ASYNC缓存：命令在两个节点之间无限期反弹

如何解决Infinispan集群式REPL_ASYNC缓存：命令在两个节点之间无限期反弹

我在2节点集群中使用infinispan 10.1.8运行spring boot应用程序。 2个节点通过jgroups TCP通信。我配置了几个REPL_ASYNC。

问题：这些缓存之一有时会导致两个节点一次又一次地交换相同的消息，从而导致较高的cpu和内存使用率。停止此操作的唯一方法是停止两个节点之一。

更多详细信息，这是配置。

 org.infinispan.configuration.cache.Configuration replAsyncNoExpirationConfiguration = new ConfigurationBuilder()
                .clustering()
                    .cacheMode(CacheMode.REPL_ASYNC)
                .transaction()
                    .lockingMode(LockingMode.OPTIMISTIC)
                .transactionMode(TransactionMode.NON_TRANSACTIONAL)
                .statistics().enabled(cacheInfo.isstatsEnabled())
                .locking()
                    .concurrencyLevel(32)
                    .lockAcquisitionTimeout(15,TimeUnit.SECONDS)
                    .isolationLevel(IsolationLevel.READ_COMMITTED)
                .expiration()
                    .lifespan(-1) //entries do not expire
                    .maxIdle(-1) // even when they are idle for some time
                    .wakeUpInterval(-1) // disable the periodic eviction process
                .build();

这些缓存之一（名为formConfig）使我在两个节点之间发生异常通信，这是发生的情况：

使用jmeter生成仅针对节点1的流量负载
在一段时间内，节点2通过SingleRpcCommand从节点1接收到缓存条目，没有异常，即使formConfig缓存的行为正常
一段时间后，新的缓存条目将发送到formConfig缓存

这时，相同的消息似乎在两个节点之间不断跳动：

节点1发送条目mn-node1.company.acme-develop sending command to all: SingleRpcCommand{cacheName='formConfig',command=PutkeyvalueCommand{key=SimpleKey [form_config,MECHANICAL,DESIGN,et,7850]
节点2收到条目mn-node2.company.acme-develop received command from mn-node1.company.acme-develop: SingleRpcCommand{cacheName='formConfig',7850]
节点2将条目发送回节点1 mn-node2.company.acme-develop sending command to all: SingleRpcCommand{cacheName='formConfig',7850]
节点1收到条目mn-node1.company.acme-develop received command from mn-node2.company.acme-develop: SingleRpcCommand{cacheName='formConfig',7850],
节点1将条目发送到节点2，依此类推……

其他一些事情：

系统没有负载，jmeter仅并行运行几个用户
即使停止jmeter，循环也不会停止
formConfig是唯一具有这种行为的缓存。所有其他REPL_ASYNC缓存均正常工作。我仅停用了formConfig缓存，系统正常运行。
在机器上运行两个节点时，我无法重现该问题

这里有更多complete log file，包括来自两个节点的日志。

其他信息：

opendjdk 11热点
弹簧靴2.2.7
infinispan弹簧启动启动器2.2.4
使用JbossUserMarshaller

我怀疑

与事务配置有关的东西
或与缓存对象的序列化/反序列化有关的东西

解决方法

唯一可能发生这种情况的情况是SimpleKey具有不同的hashCode()。

日志中是否有例外？在对密钥进行序列化和反序列化之后，您是否可以检查hashCode()是否相同？

Infinispan集群式REPL_ASYNC缓存：命令在两个节点之间无限期反弹

如何解决Infinispan集群式REPL_ASYNC缓存：命令在两个节点之间无限期反弹

解决方法

相关推荐