如何在Spring Sleuth/Brave中编写自定义跟踪发送器

Question

我的公司有定制的分布式追踪解决方案。我已经为它准备好了Java客户机/代理库，它能够向服务器发送跟踪/跨度。

然而，我想将其与Spring Boot Sleuth/Brave集成，以便从Brave实现某种桥接，因此Brave将使用我的客户机/代理库发送跟踪/跨度。

如何在Brave中定制仅发送部分？

另一种方法是从头开始实现所有Sleuth api接口（Tracer、Span、TraceContext等），这是一项巨大的任务。

我想使用勇敢的实现，只是为了注入某种桥/适配器，它将使用我的定制客户机/代理。

Answer 1

我不建议实现所有的Sleuth接口，在这种情况下，您正在编写跟踪库（您正在重写Brave）。

您可以实现zipkin2。记者发送方接口并从中创建一个@Bean，下面是一个示例：

public class SoutSender extends Sender {
    @Override
    public Encoding encoding() {
        return JSON;
    }

    @Override
    public int messageMaxBytes() {
        return 500 * 1024; //500 KiB
    }

    @Override
    public int messageSizeInBytes(List<byte[]> encodedSpans) {
        return encodedSpans.stream()
                .mapToInt(encodedSpan -> encodedSpan.length)
                .sum();
    }

    @Override
    public Call<Void> sendSpans(List<byte[]> encodedSpans) {
        encodedSpans.stream()
                .map(String::new)
                .forEach(System.out::println);

        return Call.create(null);
    }
}

你需要创建一个报告程序

@Bean
Reporter<Span> soutReporter(SoutSender soutSender) {
    return AsyncReporter.create(soutSender);
}

@Bean
Sender soutSender(SoutSender sender) {
    return new SoutSender();
}

这将注册一个额外的报告者，如果您只想保留自己的报告者，而不想向zipkin和您自己的系统报告，您需要相应地命名bean，请参阅文档：https://docs.spring.io/spring-cloud-sleuth/docs/current/reference/html/project-features.html#overriding-zipkin的自动配置