15. 集成
15.1. 开放追踪
Spring Cloud Sleuth 与 OpenTracing 兼容。如果您在类路径上有 OpenTracing，我们会自动注册 OpenTracingTracer豆。 如果要禁用此功能，请将spring.sleuth.opentracing.enabled自false
15.2. 可运行和可调用
如果将逻辑包装在Runnable或Callable，您可以将这些类包装在其 Sleuth 代表中，如以下示例所示Runnable:
Runnable runnable = new Runnable() {
@Override
public void run() {
// do some work
}
@Override
public String toString() {
return "spanNameFromToStringMethod";
}
};
// Manual `TraceRunnable` creation with explicit "calculateTax" Span name
Runnable traceRunnable = new TraceRunnable(this.tracing, spanNamer, runnable,
"calculateTax");
// Wrapping `Runnable` with `Tracing`. That way the current span will be available
// in the thread of `Runnable`
Runnable traceRunnableFromTracer = this.tracing.currentTraceContext()
.wrap(runnable);以下示例显示了如何对Callable:
Callable<String> callable = new Callable<String>() {
@Override
public String call() throws Exception {
return someLogic();
}
@Override
public String toString() {
return "spanNameFromToStringMethod";
}
};
// Manual `TraceCallable` creation with explicit "calculateTax" Span name
Callable<String> traceCallable = new TraceCallable<>(this.tracing, spanNamer,
callable, "calculateTax");
// Wrapping `Callable` with `Tracing`. That way the current span will be available
// in the thread of `Callable`
Callable<String> traceCallableFromTracer = this.tracing.currentTraceContext()
.wrap(callable);这样，您就可以确保为每次执行创建和关闭一个新的跨度。
15.3. Spring Cloud 断路器
如果类路径上有 Spring Cloud CircuitBreaker，我们将包装传递的命令Supplier和后备Function在其跟踪表示中。为了禁用此检测集spring.sleuth.circuitbreaker.enabled自false.
15.4. 海斯特里克斯
15.4.1. 自定义并发策略
我们注册一个自定义HystrixConcurrencyStrategy叫TraceCallable那将所有Callable实例。该策略要么开始，要么继续一个跨度，具体取决于在调用 Hystrix 命令之前是否已经在进行跟踪。或者，您可以设置spring.sleuth.hystrix.strategy.passthrough自true如果您不想启动新的 span，则仅将跟踪上下文传播到 Hystrix 执行线程。要禁用自定义 Hystrix 并发策略，请将spring.sleuth.hystrix.strategy.enabled自false.
15.4.2. 手动命令设置
假设您有以下内容HystrixCommand:
HystrixCommand<String> hystrixCommand = new HystrixCommand<String>(setter) {
@Override
protected String run() throws Exception {
return someLogic();
}
};要传递跟踪信息，您必须将相同的逻辑包装在 Sleuth 版本的HystrixCommand，称为TraceCommand，如以下示例所示：
TraceCommand<String> traceCommand = new TraceCommand<String>(tracer, setter) {
@Override
public String doRun() throws Exception {
return someLogic();
}
};15.5. RxJava
我们注册一个自定义RxJavaSchedulersHook那将所有Action0实例，称为TraceAction. 挂钩开始或继续一个跨度，具体取决于在计划作之前是否已经在进行跟踪。禁用自定义RxJavaSchedulersHook，将spring.sleuth.rxjava.schedulers.hook.enabled自false.
您可以为不希望为其创建范围的线程名称定义正则表达式列表。为此，请在spring.sleuth.rxjava.schedulers.ignoredthreads财产。
| 响应式编程和 Sleuth 的建议方法是使用Reactor 支持。 |
15.6. HTTP 集成
可以通过设置spring.sleuth.web.enabled值等于false.
15.6.1. HTTP 过滤器
通过TracingFilter，则所有采样的传入请求都会导致创建 Span。该 Span 的名称为http:+ 请求发送到的路径。例如，如果请求发送到/this/that则名称将为http:/this/that. 您可以通过设置spring.sleuth.web.skipPattern财产。 如果您有ManagementServerProperties在类路径上，其值contextPath附加到提供的跳过模式。如果你想重用侦探的默认跳过模式，而只是附加你自己的跳过模式，请使用spring.sleuth.web.additionalSkipPattern.
默认情况下，所有 spring boot 执行器端点都会自动添加到跳过模式中。如果要禁用此行为，请设置spring.sleuth.web.ignore-auto-configured-skip-patterns自true.
要更改跟踪过滤器注册的顺序，请将spring.sleuth.web.filter-order财产。
若要禁用记录未捕获异常的筛选器，可以禁用spring.sleuth.web.exception-throwing-filter-enabled财产。
15.6.2. HandlerInterceptor
由于我们希望 span 名称精确，因此我们使用TraceHandlerInterceptor包装现有的HandlerInterceptor或直接添加到现有列表中HandlerInterceptors.
这TraceHandlerInterceptor将特殊请求属性添加到给定的HttpServletRequest.
如果TracingFilter看不到这个属性，它会创建一个”fallback“ span，这是在服务器端创建的附加 span，以便跟踪在 UI 中正确显示。
如果发生这种情况，则可能缺少仪器。
在这种情况下，请在 Spring Cloud Sleuth 中提交问题。
15.6.3. 异步 Servlet 支持
如果您的控制器返回Callable或WebAsyncTask，Spring Cloud Sleuth 继续现有的 span，而不是创建一个新的 span。
15.6.4. WebFlux 支持
通过TraceWebFilter，则所有采样的传入请求都会导致创建 Span。该 Span 的名称为http:+ 请求发送到的路径。例如，如果请求发送到/this/that，名称是http:/this/that.
您可以使用spring.sleuth.web.skipPattern财产。 如果您有ManagementServerProperties在类路径上，其值contextPath附加到提供的跳过模式。
如果你想重用 Sleuth 的默认跳过模式并附加你自己的跳过模式，请使用spring.sleuth.web.additionalSkipPattern.
要更改跟踪过滤器注册的顺序，请将spring.sleuth.web.filter-order财产。
15.6.5. Dubbo RPC 支持
通过与 Brave 的集成，Spring Cloud Sleuth 支持 Dubbo。
只需添加brave-instrumentation-dubboDependency：
<dependency>
<groupId>io.zipkin.brave</groupId>
<artifactId>brave-instrumentation-dubbo</artifactId>
</dependency>您还需要设置一个dubbo.properties文件，其中包含以下内容：
dubbo.provider.filter=tracing
dubbo.consumer.filter=tracing15.7. HTTP 客户端集成
15.7.1. 同步休息模板
我们注入一个RestTemplate拦截器，以确保将所有跟踪信息传递给请求。
每次进行呼叫时，都会创建一个新的 Span。
收到响应后，它将关闭。
阻止同步RestTemplate功能， 设置spring.sleuth.web.client.enabled自false.
您必须注册RestTemplate作为 bean，以便注入拦截器。
如果您创建RestTemplate实例与new关键字，则检测不起作用。 |
15.7.2. 异步休息模板
从侦探开始2.0.0，我们不再注册AsyncRestTemplate类型。
由您来创造这样的豆子。
然后我们对其进行检测。 |
要阻止AsyncRestTemplate功能， 设置spring.sleuth.web.async.client.enabled自false.
禁用创建默认值TraceAsyncClientHttpRequestFactoryWrapper设置spring.sleuth.web.async.client.factory.enabled自false.
如果您不想创建AsyncRestClient完全，设置spring.sleuth.web.async.client.template.enabled自false.
多个异步 Rest 模板
有时你需要使用异步 Rest 模板的多个实现。
在以下代码段中，您可以看到如何设置此类自定义的示例AsyncRestTemplate:
@Configuration
@EnableAutoConfiguration
static class Config {
@Bean(name = "customAsyncRestTemplate")
public AsyncRestTemplate traceAsyncRestTemplate() {
return new AsyncRestTemplate(asyncClientFactory(),
clientHttpRequestFactory());
}
private ClientHttpRequestFactory clientHttpRequestFactory() {
ClientHttpRequestFactory clientHttpRequestFactory = new CustomClientHttpRequestFactory();
// CUSTOMIZE HERE
return clientHttpRequestFactory;
}
private AsyncClientHttpRequestFactory asyncClientFactory() {
AsyncClientHttpRequestFactory factory = new CustomAsyncClientHttpRequestFactory();
// CUSTOMIZE HERE
return factory;
}
}15.7.3.WebClient
我们注入一个ExchangeFilterFunction创建跨度的实现，并通过成功时和错误时回调来关闭客户端跨度。
要阻止此功能，请将spring.sleuth.web.client.enabled自false.
您必须注册WebClient或WebClient.Builder作为 bean，以便应用跟踪检测。
如果您手动创建WebClient或WebClient.Builder，则仪器不起作用。 |
15.7.4. 特拉弗森
如果使用 Traverson 库，则可以注入RestTemplate作为 Bean 放入 Traverson 对象中。
因为RestTemplate已经被拦截，则可以在客户端中获得对跟踪的完全支持。以下伪代码显示了如何做到这一点：
@Autowired RestTemplate restTemplate;
Traverson traverson = new Traverson(URI.create("https://some/address"),
MediaType.APPLICATION_JSON, MediaType.APPLICATION_JSON_UTF8).setRestOperations(restTemplate);
// use Traverson15.7.5. 阿帕奇HttpClientBuilder和HttpAsyncClientBuilder
我们检测HttpClientBuilder和HttpAsyncClientBuilder因此 跟踪上下文将注入到发送的请求中。
要阻止这些功能，请将spring.sleuth.web.client.enabled自false.
15.7.6. 内蒂HttpClient
我们检测 Netty 的HttpClient.
要阻止此功能，请将spring.sleuth.web.client.enabled自false.
您必须注册HttpClient作为 bean，以便进行检测。如果您创建HttpClient实例与new关键字，则检测不起作用。 |
15.7.7.UserInfoRestTemplateCustomizer
我们检测 Spring Security 的UserInfoRestTemplateCustomizer.
要阻止此功能，请将spring.sleuth.web.client.enabled自false.
15.8. 假装
默认情况下，Spring Cloud Sleuth 通过TraceFeignClientAutoConfiguration. 您可以通过设置spring.sleuth.feign.enabled自false. 如果这样做，则不会发生与 Feign 相关的检测。
部分 Feign 检测是通过FeignBeanPostProcessor. 您可以通过设置spring.sleuth.feign.processor.enabled自false. 如果将其设置为false，Spring Cloud Sleuth 不会检测您的任何自定义 Feign 组件。但是，所有默认检测仍然存在。
15.9. gRPC
Spring Cloud Sleuth 通过TraceGrpcAutoConfiguration. 您可以通过设置spring.sleuth.grpc.enabled自false.
15.9.1. 变体 1
依赖
| gRPC 集成依赖于两个外部库来检测客户端和服务器，并且这两个库都必须位于类路径上才能启用检测。 |
Maven：
<dependency>
<groupId>io.github.lognet</groupId>
<artifactId>grpc-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>io.zipkin.brave</groupId>
<artifactId>brave-instrumentation-grpc</artifactId>
</dependency>Gradle：
compile("io.github.lognet:grpc-spring-boot-starter")
compile("io.zipkin.brave:brave-instrumentation-grpc")服务器检测
Spring Cloud Sleuth 利用 grpc-spring-boot-starter 将 Brave 的 gRPC 服务器拦截器注册到所有带有@GRpcService.
客户端检测
gRPC 客户端利用ManagedChannelBuilder构造一个ManagedChannel用于与 gRPC 服务器通信。本地人ManagedChannelBuilder提供静态方法作为构造ManagedChannel但是，此机制不受 Spring 应用程序上下文的影响。
Spring Cloud Sleuth 提供了一个SpringAwareManagedChannelBuilder可以通过 Spring 应用程序上下文进行自定义并由 gRPC 客户端注入。创建时必须使用此构建器ManagedChannel实例。
|
侦探创建了一个TracingManagedChannelBuilderCustomizer将 Brave 的客户端拦截器注入到SpringAwareManagedChannelBuilder.
15.9.2. 变体 2
Grpc Spring Boot Starter 会自动检测 Spring Cloud Sleuth 的存在和 brave 的 gRPC 检测，并注册必要的客户端和/或服务器工具。
15.10. 异步通信
15.10.1.@Async带注释的方法
在 Spring Cloud Sleuth 中，我们检测异步相关组件，以便跟踪信息在线程之间传递。
您可以通过将spring.sleuth.async.enabled自false.
如果使用@Async，我们自动修改现有 Span，如下所示：
-
如果该方法用
@SpanName，则注释的值是 Span 的名称。 -
如果该方法未使用
@SpanName，则 Span 名称是带注释的方法名称。 -
span 使用方法的类名和方法名进行标记。
由于我们正在修改现有的 span，如果您想保留其原始名称（例如，通过接收 HTTP 请求创建的 span）
你应该把你的@Async带有 annotated 的方法，其中包含@NewSpan注释或手动创建新跨度。
15.10.2.@Scheduled带注释的方法
在 Spring Cloud Sleuth 中，我们检测计划的方法执行，以便跟踪信息在线程之间传递。
您可以通过将spring.sleuth.scheduled.enabled自false.
如果使用@Scheduled，我们会自动创建一个具有以下特征的新跨度：
-
span 名称是带注释的方法名称。
-
span 使用方法的类名和方法名进行标记。
如果您想跳过某些跨度创建@ScheduledCommentted 类，您可以将spring.sleuth.scheduled.skipPattern使用与@Scheduled带注释的类。
如果您使用spring-cloud-sleuth-stream和spring-cloud-netflix-hystrix-stream一起，为每个 Hystrix 指标创建一个跨度并发送到 Zipkin。
这种行为可能会很烦人。这就是为什么默认情况下，spring.sleuth.scheduled.skipPattern=org.springframework.cloud.netflix.hystrix.stream.HystrixStreamTask.
15.10.3. Executor、ExecutorService 和 ScheduledExecutorService
我们提供LazyTraceExecutor,TraceableExecutorService和TraceableScheduledExecutorService.这些实现在每次提交、调用或计划新任务时都会创建跨度。
以下示例演示如何使用TraceableExecutorService使用CompletableFuture:
CompletableFuture<Long> completableFuture = CompletableFuture.supplyAsync(() -> {
// perform some logic
return 1_000_000L;
}, new TraceableExecutorService(beanFactory, executorService,
// 'calculateTax' explicitly names the span - this param is optional
"calculateTax"));侦探不适用于parallelStream()开箱即用。
如果要通过流传播跟踪信息，则必须将该方法supplyAsync(...)，如前所述。 |
如果有实现Executor您想要的界面
要从 SPAN 创建中排除，您可以使用spring.sleuth.async.ignored-beans属性，您可以在其中提供 bean 名称列表。
执行程序的定制
有时，您需要设置AsyncExecutor.
以下示例演示如何设置此类自定义Executor:
@Configuration
@EnableAutoConfiguration
@EnableAsync
// add the infrastructure role to ensure that the bean gets auto-proxied
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
static class CustomExecutorConfig extends AsyncConfigurerSupport {
@Autowired
BeanFactory beanFactory;
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// CUSTOMIZE HERE
executor.setCorePoolSize(7);
executor.setMaxPoolSize(42);
executor.setQueueCapacity(11);
executor.setThreadNamePrefix("MyExecutor-");
// DON'T FORGET TO INITIALIZE
executor.initialize();
return new LazyTraceExecutor(this.beanFactory, executor);
}
}为确保您的配置得到后处理，请记住
添加@Role(BeanDefinition.ROLE_INFRASTRUCTURE)在您的@Configuration类 |
15.11. 消息传递
可以通过设置spring.sleuth.messaging.enabled值等于false.
15.11.1. Spring Integration 和 Spring Cloud Stream
Spring Cloud Sleuth 与 Spring Integration 集成。
它为发布和订阅事件创建跨度。
要禁用 Spring Integration 检测，请将spring.sleuth.integration.enabled自false.
您可以提供spring.sleuth.integration.patternspattern 以显式提供要包括用于跟踪的通道的名称。
默认情况下，所有通道hystrixStreamOutput频道都包括在内。
使用Executor构建 Spring IntegrationIntegrationFlow，则必须使用Executor.
使用TraceableExecutorService导致跨度关闭不当。 |
如果要自定义从消息标头读取和写入跟踪上下文的方式， 注册以下类型的 bean 就足够了：
-
Propagation.Setter<MessageHeaderAccessor, String>- 用于将标题写入邮件 -
Propagation.Getter<MessageHeaderAccessor, String>- 用于从邮件中读取标题
15.11.2. 春兔Mq
我们检测RabbitTemplate以便注入跟踪标头
进入消息。
要阻止此功能，请将spring.sleuth.messaging.rabbit.enabled自false.
15.11.3. Spring的卡夫卡
我们检测 Spring Kafka 的ProducerFactory和ConsumerFactory以便将跟踪标头注入到创建的 Spring Kafka 的Producer和Consumer.
要阻止此功能，请将spring.sleuth.messaging.kafka.enabled自false.
15.11.4. Spring Kafka 流
我们检测KafkaStreams KafkaClientSupplier以便跟踪标头被注入到Producer和Consumer`s. A `KafkaStreamsTracing豆 允许通过额外的TransformerSupplier和ProcessorSupplier方法。
要阻止此功能，请将spring.sleuth.messaging.kafka.streams.enabled自false.
15.11.5. 弹簧 JMS
我们检测JmsTemplate以便将跟踪标头注入到消息中。我们还支持@JmsListener消费者端的带注释的方法。
要阻止此功能，请将spring.sleuth.messaging.jms.enabled自false.
| 我们不支持 JMS 的包传 |
15.11.6. Spring Cloud AWS 消息传递 SQS
我们仪器@SqsListener由org.springframework.cloud:spring-cloud-aws-messaging以便从消息中提取跟踪标头，并将跟踪放入上下文中。
要阻止此功能，请将spring.sleuth.messaging.sqs.enabled自false.
15.12. 祖尔
我们通过使用跟踪信息丰富功能区请求来检测 Zuul 功能区集成。
要禁用 Zuul 支持，请将spring.sleuth.zuul.enabled属性设置为false.
15.13. Redis（Redis）
我们设置tracing属性到 LettcueClientResources实例启用 Brave 跟踪内置于 Lettuce 。
要禁用 Redis 支持，请将spring.sleuth.redis.enabled属性设置为false.
15.14. Quartz
我们通过将 Job/Trigger 监听器添加到 Quartz Scheduler 来检测 Quartz 作业。
要关闭此功能，请将spring.sleuth.quartz.enabled属性设置为false.
15.15. 项目反应堆
15.15.1. 来自 Spring Cloud Sleuth 2.2.8（含）
通过新的 Reactor 队列包装机制 （Reactor 3.3.14），我们正在检测 Reactor 切换线程的方式。您应该观察到性能的显着提高。要启用此功能，您必须将spring.sleuth.reactor.decorate-queues选项设置为true.
15.15.2. 到 Spring Cloud Sleuth 2.2.8（独占）
对于依赖 Project Reactor 的项目，例如 Spring Cloud Gateway，我们建议将spring.sleuth.reactor.decorate-on-each选项设置为false.这样，与标准仪表机制相比，应观察到更高的性能提升。这个选项的作用是它会包装装饰onLast运算符而不是onEach这将导致创建更少的对象。这样做的缺点是，当 Project Reactor 更改线程时，跟踪传播将继续而不会出现问题，但是任何依赖于ThreadLocal例如，MDC 条目可能存在错误。