Spring Sleuth未将traceid和spanid填充到RabbitHandler

Question

我们想把spring sleuth和spring-amqp (rabbitmq)一起使用。所以我们在发布者网站上通过

amqpTemplate.convertAndSend("exchange", "key", myEvent)

并期望将tracid和spanic与兔子消息一起发送并填充在接收方/侦听器站点上，因此它也将记录在侦听器站点上。

@RabbitHandler
public void on(MyEvent event) {
  LOGGER.warn("got a message...");
  ...
}

根据这篇文章，我希望这是开箱即用的。

如果我直接检查RabbitMQ消息(通过trace ),那么我可以看到消息中没有该信息，因此很可能是发件人站点有问题...

我想到的一件事是，我们配置了一个Jackson2JsonMessageConverter来允许json有效负载：

@Bean
public Jackson2JsonMessageConverter jacksonConverter(ObjectMapper objectMapper) {
    return new Jackson2JsonMessageConverter(objectMapper);
}

顺便说一句。log4j模式使用< code>%X进行配置，并打印可用的信息:

<PatternLayout pattern="%d{HH:mm:ss.SSS} %X [%thread] %-5level %logger{36} - %msg%n" />

我错过了什么？

Answer 1

你错过了这句话的最后一段

通过消息传递技术（如Apache Kafka或RabbitMQ）（或任何其他Spring Cloud Stream绑定器）请求

Sleuth不能与< code>RabbitHandler一起使用。就消息传递而言，它只适用于Spring Integration和Spring Cloud Stream。