在Spring Boot 2中为测微器定制Cloudwatch MeterRegistry

素材狗 2022-01-01 12:06:18 文章分类：Java问题点击数：4次

文章标签

Custom Cloudwatch MeterRegistry for Micrometer in Spring Boot 2(在Spring Boot 2中为测微器定制Cloudwatch MeterRegistry)

本文介绍了在Spring Boot 2中为测微器定制Cloudwatch MeterRegistry的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！

问题描述

我们希望向Cloudwatch发送致动器指标。使用提供的微米CloudWatch MeterRegistry解决方案对我们的项目如何设置做出了许多假设，例如，您需要依赖云AWS，而云AWS又做出了更多的假设。我们想要编写一个更轻量级的实现，只需要注入一个CloudWatchAsyncClient，并且不会对我们的项目做任何其他假设。

然而，我不确定是如何做到的。有没有关于如何使自定义实现成为必须依赖于可用的指标注册表的示例？

到目前为止，我已经做了一些实验：

public interface CloudWatchConfig extends StepRegistryConfig {
    int MAX_BATCH_SIZE = 20;

    @Override
    default String prefix() {
        return "cloudwatch";
    }

    default String namespace() {
        String v = get(prefix() + ".namespace");
        if (v == null)
            throw new MissingRequiredConfigurationException("namespace must be set to report metrics to CloudWatch");
        return v;
    }

    @Override
    default int batchSize() {
        String v = get(prefix() + ".batchSize");
        if (v == null) {
            return MAX_BATCH_SIZE;
        }
        int vInt = Integer.parseInt(v);
        if (vInt > MAX_BATCH_SIZE)
            throw new InvalidConfigurationException("batchSize must be <= " + MAX_BATCH_SIZE);

        return vInt;
    }
}

@Service
@Log
public class CloudWatchMeterRegistry extends StepMeterRegistry {

    public CloudWatchMeterRegistry(CloudWatchConfig config, Clock clock) {
        super(config, clock);
    }

    @Override
    protected void publish() {
        getMeters().stream().forEach(a -> {
            log.warning(a.getId().toString());
        });
    }

    @Override
    protected TimeUnit getBaseTimeUnit() {
        return TimeUnit.MILLISECONDS;
    }
}

@Configuration
public class MetricsPublisherConfig {
    @Bean
    public CloudWatchConfig cloudWatchConfig() {
        return new CloudWatchConfig() {
            @Override
            public String get(String key) {
                switch (key) {
                    case "cloudwatch.step":
                        return props.getStep();
                    default:
                        return "testtest";
                }

            }
        };
    }
}