Infinispan@CacheEntryExpired侦听器-事件触发两次

Question

我通过infinispan缓存添加了CacheEntryExpired侦听器的n实现。addListener（）方法。

侦听器事件在条目过期时激发。问题是，每次事件触发两次。

我验证（使用调试器和cache.getListeners（））缓存不包含我的同一个侦听器的两个实例。getListeners的结果是：

     (java.util.Collections$UnmodifiableSet<E>) [org.infinispan.iteration.impl.LocalEntryRetriever$PartitionListener@666SAT, my.supercool.package.MyExpirationEventListenerImpl@666TAN]

所以只有一个听众。侦听器实现接口：

@Listener
public interface TokenExpirationEventListener<T> {

@CacheEntryExpired
   public void entryExpired(CacheEntryExpiredEvent<String, T> event);       
}

一个实现看起来像：

@Override
@CacheEntryExpired
public void entryExpired(CacheEntryExpiredEvent<String, T> event) {
    CODE
}

但是从接口中删除@CacheEntryExpired和@Listener注释（只是尝试）并不会导致事件只发生一次。

有什么我做错了，我得到两个事件在每个条目过期事件？

infinispan版本为8.2.0。最终的

EDIT2：我能够追踪所有导致问题的配置。允许重现错误的代码是：

import java.util.concurrent.TimeUnit;

import org.infinispan.Cache;
import org.infinispan.configuration.cache.CacheMode;
import org.infinispan.configuration.cache.ClusteringConfigurationBuilder;
import org.infinispan.configuration.cache.Configuration;
import org.infinispan.configuration.cache.ConfigurationBuilder;
import org.infinispan.configuration.global.GlobalConfigurationBuilder;
import org.infinispan.configuration.global.TransportConfigurationBuilder;
import org.infinispan.manager.DefaultCacheManager;
import org.infinispan.notifications.Listener;
import org.infinispan.notifications.cachelistener.annotation.CacheEntryExpired;
import org.infinispan.notifications.cachelistener.event.CacheEntryExpiredEvent;

@Listener
public class TestMain { 

private Cache<String, String> cache;

public static void main(String[] args) throws Exception {
    new TestMain().test();
}

private void test() throws Exception{
    configureInfinispan();

    cache.put("test", "test", 10, TimeUnit.SECONDS);
    cache.put("test2", "test", 10, TimeUnit.SECONDS);       
    while(true){
        Thread.sleep(100);          
    }
}



public void configureInfinispan(){
    DefaultCacheManager defaultCacheManager = configureCachaManager();//globalConfigurationBuilder.build(), defaultConfigurationBuilder.build(), /*startNow*/ true)

    Configuration conf = defaultCacheManager.getDefaultCacheConfiguration();
    ConfigurationBuilder cacheConfigBuilder = new ConfigurationBuilder().read(conf);
    cacheConfigBuilder.expiration().enableReaper().wakeUpInterval(5, TimeUnit.SECONDS); //to speed test results


    duplicationReason2(cacheConfigBuilder);
    defaultCacheManager.defineConfiguration("testCache", cacheConfigBuilder.build());

    cache = defaultCacheManager.getCache("testCache");
    cache.addListener(new TestMain());
    System.out.println("conf");
}

public DefaultCacheManager configureCachaManager(){
    GlobalConfigurationBuilder globalConfigurationBuilder = new GlobalConfigurationBuilder();
    ConfigurationBuilder defaultConfigurationBuilder = new ConfigurationBuilder();
    duplicationReason1(defaultConfigurationBuilder, globalConfigurationBuilder);

    return new DefaultCacheManager(globalConfigurationBuilder.build(), defaultConfigurationBuilder.build(), true);
}

@CacheEntryExpired
public void entryExpired(CacheEntryExpiredEvent<String, String> event) {
    System.out.println("Expired:" + event.getKey());
}

private void duplicationReason2(ConfigurationBuilder configurationBuilder) {
    configurationBuilder.persistence() //enable persistence
            .passivation(false)
            .addSingleFileStore()
            .location("C:/test/infinispan")
            // Disable writing anything to the file except when we do shutdown
            .maxEntries(0)
            .shared(false)
            .fetchPersistentState(true)
            .async() //write-behind
            .enable() //write-behind
            .threadPoolSize(Runtime.getRuntime().availableProcessors()) //writing threads
            .preload(true); //load data from file on startup
}

private void duplicationReason1(ConfigurationBuilder configurationBuilder, GlobalConfigurationBuilder globalConfigurationBuilder){
    configureCacheOperationalMode(configurationBuilder);
    configureTransport(globalConfigurationBuilder);
}

private void configureCacheOperationalMode(ConfigurationBuilder configurationBuilder) {
    ClusteringConfigurationBuilder clusteringConfigurationBuilder = configurationBuilder.clustering();
    clusteringConfigurationBuilder.cacheMode(CacheMode.REPL_ASYNC);
}

private void configureTransport(GlobalConfigurationBuilder globalConfigurationBuilder) {
    TransportConfigurationBuilder transportConfigurationBuilder = globalConfigurationBuilder.transport().defaultTransport();
    transportConfigurationBuilder.addProperty("configurationFile", "default-configs/default-jgroups-udp.xml");
}

}

运行此操作将导致事件打印两次（不幸的是，您需要在之后自行终止主线程）。

有两种方法共同导致这种情况。评论其中一个并保留第二个会导致事件触发一次。

这些方法被命名为重复Reason1和重复Reason2。

也许在配置中有一些我不理解的地方？

Answer 1

好的，我可以看到你添加的测试用例是怎么回事，谢谢！

这是集群缓存atm中的一个错误。我登录[1]进行了调查，如果您想要更新，您应该关注。

虽然我们可以修复重复的问题，但您仍然可能会出现其他重复的情况，因此您应该仍然能够处理它们。在[2]的“并发过期访问”下可以找到生成副本的示例。因此，您通常应该忽略具有空值的过期事件。

[1] https://issues.jboss.org/browse/ISPN-6405 [2] http://blog.infinispan.org/2015/10/expiration-enhancements.html