Spring Boot中Metrics.counter.count()返回0及重启计数持久化问题

一、日志打印count()始终为0.0的原因及解决 #

原因 #

Metrics.counter("registration.upsigned")默认使用SimpleMeterRegistry（内存注册表），而你配置的InfluxDB对应独立的InfluxMeterRegistry实例。你调用increment()操作的是Influx注册表中的计数器，但日志中通过Metrics.counter获取的是从未被操作过的Simple注册表计数器，因此返回0。

解决步骤 #

1. 注入正确的MeterRegistry实例
   直接使用Spring容器中配置好的InfluxMeterRegistry（通过@Autowired注入即可），确保全应用操作同一个计数器实例：

   @Autowired
   private MeterRegistry meterRegistry;
   
   // 业务逻辑中使用
   Counter counter = meterRegistry.counter("registration.upsigned");
   counter.increment();
   // 此时打印count()将得到正确值
   log.info("Current count: {}", counter.count());
   

2. 全局复用计数器Bean
   可以将计数器定义为Bean，避免重复创建：

   @Bean
   public Counter registrationUpsignedCounter(MeterRegistry meterRegistry) {
       return meterRegistry.counter("registration.upsigned");
   }
   

   后续在需要的地方直接注入该Bean即可。

二、实现计数器持续递增、重启不丢失的方案 #

Micrometer默认计数器是内存态的，重启后会重置，需结合持久化存储实现。推荐两种方案：

方案1：基于Redis持久化（推荐） #

利用Redis的原子递增操作保证计数准确性，重启后直接读取Redis中的历史值。

1. 引入Redis依赖

   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-data-redis</artifactId>
   </dependency>
   

2. 实现持久化计数器服务

   @Service
   public class PersistentCounterService {
       private final StringRedisTemplate redisTemplate;
       private static final String COUNTER_KEY = "registration:upsigned:count";
   
       public PersistentCounterService(StringRedisTemplate redisTemplate) {
           this.redisTemplate = redisTemplate;
       }
   
       // 递增计数
       public void increment() {
           redisTemplate.opsForValue().increment(COUNTER_KEY);
       }
   
       // 获取当前计数
       public double getCount() {
           String value = redisTemplate.opsForValue().get(COUNTER_KEY);
           return value != null ? Double.parseDouble(value) : 0.0;
       }
   }
   

3. 注册FunctionCounter到Micrometer
   通过FunctionCounter将Redis中的计数暴露给Micrometer，推送到InfluxDB：

   @Bean
   public FunctionCounter registrationUpsignedCounter(PersistentCounterService counterService, MeterRegistry meterRegistry) {
       return FunctionCounter.builder("registration.upsigned", counterService, PersistentCounterService::getCount)
               .description("Total number of unsigned registrations")
               .register(meterRegistry);
   }
   

4. 业务中使用

   @Autowired
   private PersistentCounterService counterService;
   
   // 触发计数递增
   counterService.increment();
   // 获取并打印当前计数
   log.info("Current count: {}", counterService.getCount());
   

方案2：基于InfluxDB历史数据初始化 #

应用启动时从InfluxDB查询该计数器的历史累计值，初始化当前计数器：

1. 注入InfluxDB客户端

   @Autowired
   private InfluxDBClient influxDBClient;
   

2. 查询历史累计值

   private double getHistoricalCount() {
       String query = "SELECT sum(\"count\") FROM \"registration.upsigned\" WHERE time > now() - 365d";
       QueryResult result = influxDBClient.getQueryApi().query(query);
       
       // 解析查询结果，返回累计值（无数据则返回0）
       if (!result.getResults().isEmpty() && !result.getResults().get(0).getSeries().isEmpty()) {
           List<List<Object>> values = result.getResults().get(0).getSeries().get(0).getValues();
           if (!values.isEmpty()) {
               Object value = values.get(0).get(1);
               return value != null ? ((Number) value).doubleValue() : 0.0;
           }
       }
       return 0.0;
   }
   

3. 启动时初始化计数器
   由于Micrometer原生Counter不支持直接设置初始值，使用FunctionCounter关联查询到的历史值：

   @EventListener(ApplicationReadyEvent.class)
   public void initCounter(MeterRegistry meterRegistry) {
       double historicalCount = getHistoricalCount();
       // 用AtomicDouble存储当前计数，结合FunctionCounter暴露给Micrometer
       AtomicDouble counterValue = new AtomicDouble(historicalCount);
       
       FunctionCounter.builder("registration.upsigned", counterValue, AtomicDouble::get)
               .register(meterRegistry);
       
       // 业务中递增时调用counterValue.incrementAndGet()
   }
   

内容的提问来源于stack exchange，提问作者Grim