禁用Infinispan警告日志

Question

我在分布式模式下使用infispan，它工作得很好，唯一的问题是，它打印了大量的日志并破坏了日志文件。下面是打印的公共行。

WARN [jgroups-6,batch-pdcr-app-6c8fcd799c-fhmf8-35894] UDP: JGRP000012: discarded message from different cluster recon-infinispan (our cluster is ISPN). Sender was 021f21a7-4434-0509-f6bb-b3451f0c98d5 (received 33 identical messages from 021f21a7-4434-0509-f6bb-b3451f0c98d5 in the last 60012 ms)

如何禁用此日志记录？

下面是缓存配置。

         @Bean
         @Primary
            public EmbeddedCacheManager cacheManager() {
                return new DefaultCacheManager(getGlobalConfiguration());
            }
        
            private GlobalConfiguration getGlobalConfiguration() {
                GlobalConfigurationBuilder globalConfigurationBuilder = new GlobalConfigurationBuilder();
                globalConfigurationBuilder.transport().defaultTransport().initialClusterSize(1);
                return globalConfigurationBuilder.build();
            }
    
    
     @Bean
        public Cache<String, String> interfaceCache(DefaultCacheManager cacheManager) {
            return this.buildCache(ProducerConstants.BATCH_PRODUCER_INTERFACE_CACHE, cacheManager, interfaceCacheExpiringEvictingConfig(cacheManager));
        }
    
        private Configuration interfaceCacheExpiringEvictingConfig(DefaultCacheManager cacheManager) {
    
    
            ConfigurationBuilder confBuilder = new ConfigurationBuilder();
            confBuilder.expiration().lifespan(24, TimeUnit.HOURS);
            confBuilder.memory().maxCount(100).whenFull(EvictionStrategy.REMOVE);
            confBuilder.clustering().cacheMode(CacheMode.DIST_SYNC);
    
            return confBuilder.build();
        }

private <K, V> Cache<K, V> buildCache(String cacheName, DefaultCacheManager cacheManager, Configuration configuration) {

        cacheManager.defineConfiguration(cacheName, configuration);
        Cache<K, V> cache = cacheManager.getCache(cacheName);
        cache.addListener(new CacheListener());
        return cache;
    }

Answer 1

您有两个集群使用相同的端口和流量之间的冲突。我建议在其中一个集群中使用不同的端口。属性jgroups.bind.port和jgroups.mcast_port可用于配置JGroups端口。