Блог

Версии:

• Пружинная загрузка: 2.3.12.РЕЛИЗ
• Весеннее облако: Хокстон.SR12
• Стартовый сыщик SpringCloud: 3.0.3
• Верблюд: 3.4.6

Я хочу добавить Sleuth в уже существующий проект, который теперь использует ActiveMQ, ранее он был jusing JMS. Когда я это делаю, значения из сообщения ActiceMQ блокируются/удаляются и (одно из них — «имя файла», которое является ключевым значением для запросов S2). Другие значения JMS, похоже, все еще проходят нормально.

Мне нужно понять, почему значения, отличные от JMS, блокируются/удаляются (я не могу найти никакой информации о том, что могло бы привести к этому), чтобы предотвратить ошибки.

Я знаю, что могу отменить поиск для JMS, spring.sleuth.messaging.jms.enabled=true но, продвигаясь вперед, я хотел бы иметь возможность отслеживать код ActiveMQ/JMS, так что обходной путь не особенно привлекателен.

Поскольку это код перед выходом, я также хотел бы избежать необходимости его переписывать, если это вообще возможно.

Кто-нибудь заставил SPring Cloud Sleuth работать с ActiveMQ/JMS и, возможно, может указать, где что-то идет не так?

Редактировать:

Основываясь на первоначальном ответе Марчина, мы обнаружили, что следующая версия компилируется и выполняется, хотя значительные проблемы сохраняются:

• Пружинный ботинок: 2.4.8
• Весеннее облако: 2020.0.3
• Верблюд: 3.7.5

Без Сыщика

Подробности сообщения ActiveMQ:

Сообщение журнала («имя файла», «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}
 

С Сыщиком

Подробности сообщения ActiveMQ:

Сообщение журнала (отсутствуют»имя файла», «Тег camelawss3» и т. Д.):

 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=#amazonS3Clientamp;fileName=${header.filename}amp;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 */
    }
}
 

Вы используете неправильные версии Boot, Cloud и Sleuth. Чтобы использовать Sleuth 3.0.x, вам необходимо использовать Cloud 2020.0.x и загрузить 2.4.x или 2.5.x.