记录源应用程序错误通道的Spring Sleuth Span Id

Question

我有一个使用RabbitMQ事件总线和使用spring cloud stream的应用程序的系统设置。为了帮助通过系统跟踪消息，我还使用了spring cloud sleuth。

我的问题涉及errorChannel流/绑定。我没有在配置中使用错误绑定（参考此）。相反，我有一个流设置来监听errorChannel，它在消息中添加一个额外的头，然后将其发送到错误目标。它看起来类似于以下内容（用Groovy编写）：

IntegrationFlows
  .from('errorChannel')
  .log()
  .handle(MessagingException, {e, h -> 
      def message = MessageBuilder.withPayload(e).copyHeaders(h).setHeader('name', 'myApp').build()
      errorSource.channel().send(message)
  .channel('nullChannel')
  .get()

其中，errorSource的通道被声明为输出。

日志行输出类似于：

<代码>信息[myApp，12344321，false]日志处理程序：ErrorMessage[…]

但是，当我从错误目标收到消息时，X-B3-家长SPANId标头中的值与上面日志消息中的跨度ID（4321值）或源应用程序中记录的任何其他跨度ID不匹配。

我能看到匹配的唯一方法是如果我将org.springframework.cloud的日志记录增加到DEBUG，即使这样，它也是TracingChannelInterceptor的日志行（尽管该实例看起来像是属于errorChannel的拦截器列表，所以我觉得我很接近了）。我宁愿不打开DEBUG，因为它显然会变得非常嘈杂。

在所有这些之后，问题是我是否可以在错误通道或绑定本身上设置任何日志记录，以输出一些带有span id的日志行，该span id与放入X-B3-ParentSpanId标题中的内容相匹配？其目的是获取并保存该span id，以便稍后在检查日志时可以使用它直接转到源应用程序。

我们也在保存跟踪id，我认为这很好（并且与源应用程序的跟踪id相匹配），但将跟踪id和span id结合在一起会很有帮助。




Answer 1

MessaginException具有failedMessage属性；您应该在其标题中找到所需的内容。