Spring可能会导致ActiveMQ/JMS消息头丢失

Question

版本：

• SpringBoot： 2.3.12。发布
• SpringCloud：Hoxton。SR12
• SpringCloud Starter Sleuth： 3.0.3
• 骆驼： 3.4.6

我想将Sleuth添加到一个预先存在的项目中，该项目现在使用ActiveMQ，以前它使用JMS。当我这样做时，ActiceMQ消息中的值会被阻止/删除（其中一个是“filename”，它是S2请求的键值）。其他JMS值似乎仍然通过OK。

我需要理解为什么非JMS值会被阻止/删除（我找不到任何关于导致这种情况发生的原因的信息），以防止错误发生。

我知道我可以用spring解除JMS的Sleuth。侦探。信息。jms。enabled=true但向前看，我希望能够跟踪ActiveMQ/JMS代码，这样解决方案就不会特别吸引人了。

由于这是预先退出的代码，我还希望尽可能避免重新编写它。

有没有人让SpringCloudSleuth与ActiveMQ/JMS合作，并指出哪里出了问题？

编辑：

根据Marcin的初始响应，我们发现以下版本

• SpringBoot： 2.4.8
• SpringCloud： 2020.0.3
• 骆驼： 3.7.5

没有侦探

日志消息（文件名，CamelAwsS3Etag等）：

2021-08-16 10:10:37.889  INFO [MyApp,,] 28775 --- [umer[taskQueue]] taskQueueConsumer: ***HEADERS IN***: {CamelAwsS3ETag=39d029a87fa4c6aaee5f1de643d9f3f6, Content-Type=application/json, filename=_bl001/group0/_bl001-group0-1629104686042.zip, JMSCorrelationID=null, JMSCorrelationIDAsBytes=null, JMSDeliveryMode=2, JMSDestination=queue://taskQueue, JMSExpiration=0, JMSMessageID=ID:server-44053-1629104652998-1:3:1:1:1, JMSPriority=4, JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1629104686350, JMSType=null, JMSXGroupID=_bl001-group0, JMSXGroupSeq=0, JMSXUserID=null}

和侦探在一起

日志消息（“文件名”、“CamelAwsS3Etag”等缺失）：

2021-08-16 10:24:33.821  INFO [MyApp,,] 31553 --- [umer[taskQueue]] taskQueueConsumer: ***HEADERS IN***: {JMSCorrelationID=null, JMSCorrelationIDAsBytes=null, JMSDeliveryMode=2, JMSDestination=queue://taskQueue, JMSExpiration=0, JMSMessageID=ID:server-42561-1629105658959-1:3:1:1:1, JMSPriority=4, JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1629105675306, JMSType=null, JMSXGroupID=_bl000-group1, JMSXGroupSeq=0, JMSXUserID=null}

示例Java代码

@Component
public class MyAppCoreRouter extends RouteBuilder {

    /* Other code */

    @Override
    public void configure() {
        from("activemq:queue:taskQueue?concurrentConsumers=" + taskNumberOfConcurrentConsumers)
                .log("***HEADERS IN***: ${headers}")
                .routeId("taskQueueConsumer")
                .threads(taskNumberOfConcurrentConsumers)
                .pollEnrich().simple("aws-s3://myapp-task?amazonS3Client=#amazonS3Client&fileName=${header.filename}&operation=getObject")
                .choice()
                .when(header(S3Constants.KEY).endsWith(".zip"))
                .to("file://" + taskLocalUnCompressedEndpoint + "?fileName=${header.CamelAwsS3ETag}/${header.CamelAwsS3Key}")
                .process(exchange -> {
                    String camelAwsS3ETag = exchange.getIn().getHeader("CamelAwsS3ETag", String.class);
                    String camelAwsS3Key = exchange.getIn().getHeader("CamelAwsS3Key", String.class);
                    File uniqueDir = new File(taskLocalUnCompressedEndpoint, camelAwsS3ETag);
                    File taskZip = new File(uniqueDir, camelAwsS3Key);
                    new ZipFile(taskZip).extractAll(uniqueDir.getAbsolutePath());
                })
                .setHeader("resourceDirectory", simple(taskLocalUnCompressedEndpoint + "/${header.CamelAwsS3ETag}")).setHeader("schedule.time", simple("${date:now}"))
                .removeHeader("CamelAwsS3Headers")
                .log(LoggingLevel.DEBUG, "Processing batch job ${headers}")
                .to("spring-batch:importMyAppRecordJob")
                .endChoice()
                .otherwise()
                .log(LoggingLevel.WARN, "Unexpected file type, filtering file name ${header.CamelAwsS3Key} ")
                .end();

        /* Other code */
    }
}

Answer 1

您使用了错误的Boot、Cloud和Sleuth版本。使用Sleuth 3.0。x您需要使用云2020.0。x和Boot 2.4。x或2.5。十、