spring-cloud-sleuth与spring-amqp集成

Question

我只是在spring-cloud-sleuth的第一步，它可以很好地处理各种http调用。

现在我正试着着眼于涵盖消息部分。我看到spring-cloud-sleuth与spring-integration集成在一起。我目前只使用spring-amqp。有没有办法让这个工作。有没有人有一些见解，甚至代码样本？

Answer 1

目前我们只通过弹簧整合直接支持AMQP。为了支持AMQP，您必须确保发送的所有消息都设置了正确的标题，并且当您收回标题时，必须将这些标题放入本地环境中。例如在这里完成向消息注入Span（跟踪）信息 - https://github.com/spring-cloud/spring-cloud-sleuth/blob/master/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/MessagingSpanInjector.java并从消息中提取跟踪数据在这里是https://github.com/spring-cloud/spring-cloud-sleuth/blob/master/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/MessagingSpanExtractor.java。在这种方法中，您将提取的跨度设置为上下文https://github.com/spring-cloud/spring-cloud-sleuth/blob/master/spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceChannelInterceptor.java#L71