Блог

Я использую поток Spring Cloud с функцией Spring cloud с реактивным подходом. Мой связующий файл — RabbitMQ. По определению свойство maxAttempts — это количество раз, когда сообщение может быть обработано (это то, что я интерпретирую) из: https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/3.0.6.RELEASE/reference/html/spring-cloud-stream.html#_consumer_properties

maxAttempts: если обработка завершается неудачей, количество попыток обработать сообщение (включая первую). Установите значение 1, чтобы отключить повторную попытку. По умолчанию: 3.

Проблема в том, что мое приложение с этой конфигурацией (по умолчанию) всегда обрабатывало сообщение 4 раза. И теперь я хочу отключить повторную попытку, поэтому я устанавливаю max-attempts = 1, и сообщение всегда обрабатывается 2 раза. Я уже пытался установить spring.cloud.stream.rabbit.bindings.input.consumer.requeue-rejected=false значение по умолчанию, хотя.

Есть какие-либо подсказки о том, как я могу обработать свое сообщение только один раз?

Спасибо.

Хокстон.SR1 очень старый

Я могу понять, почему он был повторен с этими версиями; Я обновил ваш пример до последних версий, и теперь он поставляется только один раз…

     <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.3.RELEASE</version>
        <relativePath /> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>retry-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>retry-demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>11</java.version>
        <spring-cloud.version>Hoxton.SR8</spring-cloud.version>
    </properties>
  

Я не знаю, в какой версии это было исправлено.