Symfony Messenger为何在拒绝消息前重复发送一次？

当消息没有对应处理器时，Symfony Messenger会触发重试机制，这是导致send和reject先后执行的核心原因：

1. 当NoHandlerForMessageException抛出后，默认重试策略会启动，首先调用Transport的send方法，将消息重新投递回原队列，用于后续重试尝试；
2. 完成重投递后，再调用reject方法，标记原始消息为已拒绝，从原队列中移除。

这个流程和max_retries设置无关——哪怕max_retries设为0，只要重试策略中没有排除该异常，就会执行"重投递+拒绝原消息"的操作。

要避免无处理器消息触发send操作，需要配置重试策略，明确排除NoHandlerForMessageException的重试逻辑：

方案1：针对Transport配置重试过滤 #

修改messenger.yml中ingest Transport的重试策略，添加when条件，排除无处理器异常：

framework:
    messenger:
        transports:
             ingest:
                dsn: '%env(MESSENGER_TRANSPORT_DSN_INGEST)%'
                retry_strategy:
                  max_retries: 5
                  delay: 1000
                  multiplier: 2
                  max_delay: 0
                  # 仅当异常不是无处理器类型时才重试
                  when: '!instanceof Symfony\Component\Messenger\Exception\NoHandlerForMessageException'
        routing:
             'App\Message\IngestMessage': ingest

方案2：全局配置无处理器消息直接拒绝 #

使用RejectNoHandlerMiddleware，让无处理器消息直接被拒绝，不进入重试流程：

framework:
    messenger:
        buses:
            messenger.bus.default:
                middleware:
                    - Symfony\Component\Messenger\Middleware\RejectNoHandlerMiddleware:
                        reject_after_retries: 0
        # 可选：将拒绝的消息转到失败队列
        failure_transport: failed
        transports:
             failed: 'doctrine://default?queue_name=failed'
             ingest:
                dsn: '%env(MESSENGER_TRANSPORT_DSN_INGEST)%'
                retry_strategy:
                  max_retries: 5
                  delay: 1000
                  multiplier: 2
                  max_delay: 0
        routing:
             'App\Message\IngestMessage': ingest

配置完成后，无处理器的消息会直接触发reject，不再执行send操作，避免重复投递。

内容的提问来源于stack exchange，提问作者itinance