Hazelcast客户机指标没有值（总是0.0）

Question

    import org.springframework.cache.CacheManager;
    import com.hazelcast.client.HazelcastClient;
    import com.hazelcast.client.config.ClientConfig;
    import com.hazelcast.core.HazelcastInstance;
    import com.hazelcast.spring.cache.HazelcastCacheManager;
    
    @Configuration
    public class HazelcastCacheConfig {
    
        @Bean
        public ClientConfig config() {
            ClientConfig config = new ClientConfig();
            // set group and network config
            return config;
        }
    
        @Bean
        @DependsOn("config")
        public HazelcastInstance hazelcastInstance() {
            return HazelcastClient.newHazelcastClient(config());
        }
    
        @Bean
        @DependsOn("hazelcastInstance")
        public CacheManager cacheManager() {
            return new HazelcastCacheManager(hazelcastInstance());
        }
    }

我们的项目需要动态地创建缓存。因此，我实现了一个自定义的CacheResolver来创建和注册这些缓存及其相应的度量：

    import org.springframework.boot.actuate.metrics.cache.CacheMetricsRegistrar;
    import org.springframework.cache.Cache;
    import org.springframework.cache.CacheManager;
    import io.micrometer.core.instrument.binder.cache.HazelcastCacheMetrics;
    import io.micrometer.prometheus.PrometheusMeterRegistry;
    
    
    @Component
    public class CacheManagement implements CacheResolver {
    
        @Autowired
        CacheManager cacheManager;

        @Autowired
        CacheMetricsRegistrar cacheMetricsRegistrar;

        @Autowired
        PrometheusMeterRegistry meterRegistry;
    
        @Override
        public Collection<? extends Cache> resolveCaches(CacheOperationInvocationContext<?> context) {
            String cacheName = context.getMethod().getAnnotation(Cacheable.class).cacheNames()[0];
            Cache cache = cacheManager.getCache("some Name");

            // checks if cache already exists in io.micrometer.prometheus.PrometheusMeterRegistry
            if (!cacheRegistered(cache)) {
                if (cache.getNativeCache() instanceof IMap<?, ?>)
                    HazelcastCacheMetrics.monitor(meterRegistry, (IMap<?, ?>) cache.getNativeCache(), /*some tags*/);
                // same result with this
                // cacheMetricsRegistrar.bindCacheToRegistry(cache, /*some tags*/)
            }
        }
        return cache;
    }

    @Cacheable(
        cacheNames = "someGeneratedName",
        cacheResolver = "cacheManagement",
        keyGenerator = "cacheKeyGenerator",
        unless = /*..*/,
        condition = /*..*/
    )
    public Object someCacheableMethod(Object... someParameters) {
        // logic
    }

通过调试，我发现从未调用com.hazelcast.monitor.impl.LocalMapStatSimpl中的Sethits（long hits)方法。因此，当Prometheus scraping导致调用gethits()时，它总是返回0。

• 让Spring生成CacheManagerbean：相同的结果是，Spring在生成的CacheManagerbean中包装了一个HazelCastClientCacheManager.
• 在CacheManagement中注入JCacheCacheManagerbean。Spring仍然将HazelCastClientCacheManagerbean包装在JCacheCacheManager中，但是现在只导出了JCache缓存度量，而没有一个Hazelcast特定的度量（比如cache_partition_gets_total，我认为根据micrometer问题#586，cache_gets_total{result=“miss”}度量必须导出为cache_partition_gets_total{result=“miss”}的替代方法）。所有值仍为0.0

我的最后一个想法/想法是，缓存度量需要在Hazelcast成员上启用，但我找不到任何关于这方面的信息。

Answer 1

@Steve-McGarrett，默认情况下Hazelcast中的JCache统计数据是禁用的。您需要通过编程方式或将下面的配置添加到hazelcast.xml文件中来启用它：

<cache name="default">
  <statistics-enabled>false</statistics-enabled>
</cache>

请参见:http://docs.hazelcast.org/docs/latest/manual/html-single/index.html#jcache-declarative-configuration