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