Shopware 6.5消息队列延迟失效问题及更优替代方案咨询

问题背景 #

在Shopware 6.4中，订阅者向消息队列发送带延迟参数的消息时，延迟会被正常识别并到期自动执行；但升级到Shopware 6.5后，消息会被立即处理，延迟完全失效。查看Bus的dispatch函数发现，虽然该函数声明接收相关参数，但内部并未做延迟处理：

public function dispatch($message, array $stamps = []): Envelope
{
    $envelope = $message instanceof Envelope ? $message : new Envelope($message);
    $this->envelopes[] = $envelope;

    return $envelope;
}

当前临时方案是用定时任务配合自定义字段处理，但不够简洁，以下是更优的替代方案：

方案1：直接使用Symfony DelayStamp（官方标准做法） #

Shopware 6.5基于Symfony Messenger实现消息队列，直接给消息添加DelayStamp即可实现延迟，无需依赖Bus的原有延迟参数：

use Symfony\Component\Messenger\Stamp\DelayStamp;

// 实例化你的自定义消息
$customMessage = new YourCustomMessage();
// 添加延迟标记：示例为延迟5分钟（单位：毫秒）
$stamps = [new DelayStamp(300000)];

// 发送带延迟的消息
$this->bus->dispatch($customMessage, $stamps);

Symfony Messenger会自动识别该Stamp，将消息延后到指定时间再处理，这是最简洁且符合官方规范的方式。

方案2：自定义Bus装饰器兼容原有调用 #

如果想保留原有通过delay参数传递延迟的调用方式，可以实现一个Bus装饰器，自动将delay参数转换为DelayStamp：

1. 实现装饰器类 #

use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Component\Messenger\Stamp\DelayStamp;

class DelayedMessageBusDecorator implements MessageBusInterface
{
    public function __construct(private MessageBusInterface $innerBus) {}

    public function dispatch($message, array $stamps = []): Envelope
    {
        // 检查是否传入delay参数（可根据你的实际调用逻辑调整判断方式）
        if (isset($stamps['delay']) && is_int($stamps['delay'])) {
            $stamps[] = new DelayStamp($stamps['delay']);
            unset($stamps['delay']);
        }

        return $this->innerBus->dispatch($message, $stamps);
    }
}

2. 注册装饰器 #

在插件的services.xml中注册该装饰器，替换默认的消息Bus：

<service id="YourPluginNamespace\Bus\DelayedMessageBusDecorator" decorates="messenger.bus.default">
    <argument type="service" id="YourPluginNamespace\Bus\DelayedMessageBusDecorator.inner"/>
</service>

这样原有调用代码无需修改，Bus会自动处理延迟参数。

方案3：确保消息队列传输层支持延迟 #

不同的消息队列传输组件需要开启延迟支持：

• Redis传输：确保Redis服务器版本支持，且Symfony配置正确
• RabbitMQ传输：需要安装rabbitmq_delayed_message_exchange插件，并在配置中启用延迟交换器
• Doctrine传输：默认支持延迟，确保messenger_messages表存在delayed_until字段（Shopware 6.5初始化时已自动创建）

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