使用CompositeMeter注册表忽略千分尺过滤器

Question

我使用Spring靴2.1.2。释放，我尝试将测微计与CompositeMeterRegistry结合使用。我的目标是将一些选定的米发布到ElasticSearch。下面的代码显示了我的示例配置。问题是，过滤器被完全忽略（因此所有指标都被发送到ElasticSearch），尽管我可以在日志中看到它已被处理（“过滤器对仪表的回复…”行）。

奇怪的是，如果我将MeterFilter定义为Spring bean，那么它将应用于所有注册表（但是，我希望它仅应用于“elasticMeter注册表”）。

这是一个示例配置类：

@Configuration
public class AppConfiguration {

    @Bean
    public ElasticConfig elasticConfig() {
        return new ElasticConfig() {
            @Override
            @Nullable
            public String get(final String k) {
                return null;
            }
        };
    }

    @Bean
    public MeterRegistry meterRegistry(final ElasticConfig elasticConfig) {
        final CompositeMeterRegistry registry = new CompositeMeterRegistry();
        registry.add(new SimpleMeterRegistry());
        registry.add(new JmxMeterRegistry(new JmxConfig() {
            @Override
            public Duration step() {
                return Duration.ofSeconds(10);
            }

            @Override
            @Nullable
            public String get(String k) {
                return null;
            }
        }, Clock.SYSTEM));

        final ElasticMeterRegistry elasticMeterRegistry = new ElasticMeterRegistry(elasticConfig, Clock.SYSTEM);
        elasticMeterRegistry.config().meterFilter(new MeterFilter() {
            @Override
            public MeterFilterReply accept(Meter.Id id) {
                final MeterFilterReply reply =
                        id.getName().startsWith("logback")
                                ? MeterFilterReply.NEUTRAL
                                : MeterFilterReply.DENY;
                log.info("filter reply of meter {}: {}", id.getName(), reply);
                return reply;
            }
        });
        registry.add(elasticMeterRegistry);

        return registry;
    }
}

因此，我希望ElasticSearch只接收“logback”指标，JMX接收所有指标。

更新时间：

我使用了过滤器并找到了“解决方案”，但我真的不明白上面的代码为什么不起作用。

这项工作：

elasticMeterRegistry.config().meterFilter(new MeterFilter() {
    @Override
    public MeterFilterReply accept(Meter.Id id) {
        final MeterFilterReply reply =
                id.getName().startsWith("logback")
                        ? MeterFilterReply.ACCEPT
                        : MeterFilterReply.DENY;
        log.info("filter reply of meter {}: {}", id.getName(), reply);
        return reply;
    }
});

不同之处在于：我返回ACCEPT而不是NEUTRAL。

奇怪的是，以下代码不起作用（ES获取所有指标）：

elasticMeterRegistry.config().meterFilter(
    MeterFilter.accept(id -> id.getName().startsWith("logback")));

但这是可行的：

elasticMeterRegistry.config().meterFilter(
    MeterFilter.accept(id -> id.getName().startsWith("logback")));
elasticMeterRegistry.config().meterFilter(
    MeterFilter.deny());

结论：

因此，过滤器似乎应该返回ACCEPT而不是NEUTRAL。但是对于不以“logback”开头的米，我的原始过滤器（使用NEUTRAL）返回DENY。那为什么这些指标会发布到ElasticSearch注册表？

有人能解释一下吗？

Answer 1

这实际上是一系列问题的组合。我只想指出几点。

对于您定义的计量注册bean，Spring Boot将自动配置弹性计量注册bean，因为没有弹性计量注册bean。不要自己创建一个CompositeMeterRegistry bean，只需定义一个自定义的ElasticMeterRegistry bean，该bean将应用所需的MeterFilter，并让Spring Boot为您创建一个（CompositeMeterRegistrybean）。

对于MeterFilterReply，ACCEPT将立即接受仪表，DENY将立即拒绝仪表，NEUTRAL将决定推迟到下一个过滤器。基本上米将被接受，除非有任何DENY。