Symfony MessageHandler 计算一条消息被发送了多少次

Question

我正在使用 Symfony Messenger，我想在处理程序中继续发送消息，直到它被发送多次。

我怎样才能跟踪它？

到目前为止，这是我的处理程序类的代码：

class RetryTestHandler implements MessageHandlerInterface

{

    /**

    * @var EntityManagerInterface

    */

    private $entityManager;

    /**

     * @var MessageBusInterface

     */

    private $bus;

    public function __construct(MessageBusInterface $bus, EntityManagerInterface $entityManager)

    {

        $this->entityManager = $entityManager;

        $this->bus = $bus;

    }

    public function __invoke(RetryTest $message)

    {

        // TODO: Keep dispatching message until it has been dispatched 10 times?

        $this->bus->dispatch(new RetryTest("This is a test!"), [

            new DelayStamp(5000)

        ]);

    }

}

Answer 1

要将元数据添加到消息中，您可以使用 stamps。您以后可以在自己的自定义中间件中使用它。例如，对于这个自定义StampInterface实现类：class LoopCount implements StampInterface {    private int $count;     public function __construct($count) {        $this->count = $count;    }    public function getCount(): int {        return $this->count;    } }然后创建您自己的中间件来检查此标记并在处理后重新发送：class ResendingMiddleware implements MiddlewareInterface{     private $bus;     public function __construct(MessageBusInterface $bus) {           $this->bus = $bus;    }    public function handle(Envelope $envelope, StackInterface $stack): Envelope    {        $envelope = $stack->next()->handle($envelope, $stack);        if (null !== $stamp = $envelope->last(LoopCount::class)) {            $count = $stamp->getCount();        } else {            return $envelope;        }        // Stop dispatching        if ($count > 9) {            return $envelope;        }        $this->bus->dispatch(new RetryTest("Dit is een test"), [            new DelayStamp(5000),            new LoopCount($count + 1)        ]);        return $envelope;    }如果它被处理超过 9 次，则不做任何事情来使用消息。您还需要将中间件添加到配置中：framework:    messenger:        buses:            messenger.bus.default:                middleware:                    # service ids that implement Symfony\Component\Messenger\Middleware\MiddlewareInterface                    - 'App\Middleware\ResendingMiddleware'我匆忙写了这篇文章，现在无法测试，但 base 应该可以帮助你朝着正确的方向前进。测试和调试，你会得到它的工作。我稍后会回到这个问题上，看看是否有遗漏的东西