spring-cloud-sleuth 与 spring-amqp 的集成

Question

我只是在迈出第一步，spring-cloud-sleuth它适用于各种 http 调用。

现在我也在尝试覆盖消息传递部分。我看到它spring-cloud-sleuth与spring-integration开箱即用的集成。我目前只使用spring-amqp. 有没有办法让这个工作。有没有人有一些见解甚至代码示例？

Answer 1

目前我们仅通过 spring-integration 直接支持 AMQP。为了支持 AMQP，您必须确保所有发送的消息都设置了正确的标头，当您取回它们时，您必须将这些标头放入本地上下文中。将 Span（跟踪）信息注入到消息中，例如在这里完成 - https://github.com/spring-cloud/spring-cloud-sleuth/blob/v1.3.5.RELEASE/spring-cloud-sleuth-core/src /main/java/org/springframework/cloud/sleuth/instrument/messaging/MessagingSpanTextMapInjector.java并从消息中提取跟踪数据在这里https://github.com/spring-cloud/spring-cloud-sleuth/blob/v1 .3.5.RELEASE/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/MessagingSpanTextMapExtractor.java. 在此方法中，您将提取的 Span 设置为上下文https://github.com/spring-cloud/spring-cloud-sleuth/blob/v1.3.5.RELEASE/spring-cloud-sleuth-core/src/ main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceChannelInterceptor.java#L71

更新：

使用 Sleuth 2.0.x（Finchley 发行版），如果您有一个 rabbit 模板类型的 bean（请参阅此处），它应该是开箱即用的。不需要额外的代码。