千分尺中的计数器Thread安全吗

Question

我试图发布我的应用程序正在处理的事件数量。这是我在接收端的代码:

public void process(List<String> batch) {
    logger.info ("Processing batch of size " + batch.size())
    metrics.incrementCounter(MetricsType.CONSUMER_TOTAL_PROCESSED, batch.size)
}

类指标是：

public class Metrics {
    private static final Map<MetricsType, Counter> COUNTER_MAP = new ConcurrentHashMap<>();

    public Metrics(
        @Autowired MeterRegistry meterRegistry
    ) {
        COUNTER_MAP.put(
            MetricsType.CONSUMER_TOTAL_PROCESSED,
            Counter.builder("CONSUMER_TOTAL_PROCESSED").register(meterRegistry)
        );

        COUNTER_MAP.put(
            MetricsType.CONSUMER_DUPLICATE_PROCESSED,
            Counter.builder("CONSUMER_DUPLICATE_PROCESSED").register(meterRegistry)
        );
    }

    public void increment(MetricsType metricsType, int size) {
        COUNTER_MAP.get(metricsType).increment(size);
    }
}

enum < code > metric type 包含所有类型的计数器。

进程方法随时由 16 个线程调用。我面临的问题是打印计数的记录器，而grafana中报告的总计数相差甚远。

我必须在每次递增计数器时进行同步吗？

编辑 - 我所说的计数是关闭的，如果有两个大小为200的日志，那么grafana应该报告总计数器400。我通过采取2小时的时间范围来验证这一点，我从日志中提取所有大小并添加它们。

如果您无意中发现这两个源之间存在差异，请检查Grafana中的最大数据点数量，这就是我认为计数器可能不是线程安全的实际问题。

Answer 1

计数器单调递增。因此，如果之前的批次已经发生，那么新的批次将添加到之前的总数中。

您使用的是哪个后端？如果您使用的是 Prometheus，则可以将查询包装在增加函数中，以便可视化计数器增加的量。

（回答最初的问题：是的，计数器是线程安全的）

Answer 2

计数器是线程安全的，在内部它们使用一些原子数据结构进行计数。根据您的代码，我怀疑记录器打印的内容与您在grafana中看到的内容大相径庭，因为记录器打印的是当前批次的大小，而计数器打印的是所有批次大小的总和。