如何用Micrometer计量外部计数器？以Redis Streams entries-read为例

针对你遇到的Redis Streams entries-read指标统计需求，这里有两种合适的解决方案：

1. 使用Gauge直接暴露当前值 #

Gauge是最直接的选择，它可以定期采集并上报entries-read的当前数值，完全适配外部系统提供的计数器场景。

• 注意要点：
  • 配置合理的采样间隔：避免过于频繁调用XINFO GROUPS给Redis带来压力，同时保证指标不会滞后太多（比如10-30秒的间隔通常足够）。
  • 确保采集逻辑线程安全：如果多线程采集，要做好同步或者使用线程安全的Redis客户端。

2. 用FunctionCounter保留计数器递增语义 #

如果你希望指标更贴合Micrometer中Counter的“单调递增”语义（毕竟entries-read本身是只会增长的计数器），FunctionCounter是更优的选择：

• 它会定期获取entries-read的当前值，自动计算与上次采样的差值，将增量累加到内部的Counter中上报。这样监控系统可以直接用速率函数（比如Prometheus的rate()）计算每秒读取的条目数。
• 示例代码：

// 实现获取entries-read的逻辑
Supplier<Long> entriesReadProvider = () -> {
    // 调用Redis客户端执行XINFO GROUPS，解析返回结果中的entries-read字段
    return fetchEntriesReadFromRedis("your-stream", "your-group");
};

// 注册FunctionCounter到MeterRegistry
FunctionCounter.builder("redis.stream.group.entries.read", entriesReadProvider)
               .tags("stream", "your-stream", "group", "your-group")
               .description("Logical read counter of the last entry delivered to the Redis Stream group's consumers")
               .register(yourMeterRegistry);

额外提示 #

• 给指标添加必要的标签（如流名称、消费组名称），方便后续按维度拆分分析。
• 可以对Redis查询结果做短期缓存，进一步降低对Redis的请求频率。

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