README

用于在 Laminas 和 Mezzio 应用程序中使用 Symfony Messenger 的工厂（例如 zend-framework 和 zend-expressive）

使用方法

您需要将控制台命令添加到您的应用程序中。以下命令服务已经为您配置好了：

• Symfony\Component\Messenger\Command\ConsumeMessagesCommand
• Symfony\Component\Messenger\Command\SetupTransportsCommand
• Symfony\Component\Messenger\Command\FailedMessagesRemoveCommand
• Symfony\Component\Messenger\Command\FailedMessagesRetryCommand
• Symfony\Component\Messenger\Command\FailedMessagesShowCommand
• Symfony\Component\Messenger\Command\StopWorkersCommand（见下文注释）

要使用 Symfony\Component\Messenger\Command\StopWorkersCommand 命令，您应该设置一个 CacheItemPoolInterface 实现（见下文）。

已为您配置了默认的消息总线，服务名称为：messenger.bus.default。您可以阅读 Symfony 文档 了解如何使用它。

配置

以下是一个配置示例

use TMV\Laminas\Messenger\Factory;
use Symfony\Component\Messenger;

return [
    'dependencies' => [
        'factories' => [
            'messenger.bus.foo' => [Factory\MessageBusFactory::class, 'messenger.bus.foo'], // the name must be the same as the bus configuration key
            'messenger.transport.async' => [Factory\Transport\TransportFactory::class, 'messenger.transport.async'], // the name must be the same as the transport configuration key
        ],
    ],
    'messenger' => [
        'failure_transport' => null, // your failure transport service name (optional)
        'logger' => null, // your custom logger service name (optional)
        'default_serializer' => SFMessenger\Transport\Serialization\PhpSerializer::class, // default messenger serializer, it should be a service name
        'cache_pool_for_restart_signal' => null, // CacheItemPoolInterface service name implementation if you want to use stop workers command
        'transport_factories' => [
            // here you can add your custom transport factories services
        ],
        'subscribers' => [], // Subscribers (service name) to use with the default event dispatcher factory
        'buses' => [
            'messenger.bus.foo' => [ // bus service name, it should be registered as a service with the same name
                'default_middleware' => true, // if you want to include default middleware (default: true)
                'middleware' => [ // your custom middleware service names
                    My\FooMiddleware::class,
                ],
                'allow_no_handler' => false, // allow no handlers (default: false)
                'handlers' => [ // your handlers
                    My\FooMessageType::class => [
                        My\FooMessageHandler::class,
                    ],
                ],
                'routes' => [
                    My\FooMessageType::class => ['messenger.transport.async'], // route message types to this transport
                ],
            ],
        ],
        'transports' => [
            'messenger.transport.async' => [
                'dsn' => 'amqp://guest:guest@rabbitmq:5672',
                'serializer' => Messenger\Transport\Serialization\PhpSerializer::class, // custom serializer service
                'options' => [
                    'exchange' => [
                        'name' => 'messenger_events',
                    ],
                    'queues' => [
                        'messenger_events' => [],
                    ],
                ],
                'retry_strategy' => [
                    'max_retries' => 3,
                    'delay' => 1000,
                    'multiplier' => 2,
                    'max_delay' => 0,
                ],
            ],
        ],
    ],
];

Doctrine 辅助工具

中间件

有一些中间件可供 Doctrine 使用

TMV\Laminas\Messenger\Middleware\DoctrineCloseConnectionMiddleware

在工作器消费每条消息时关闭连接。

TMV\Laminas\Messenger\Middleware\DoctrinePingConnectionMiddleware

在处理工作器上的消息之前，ping 以检查连接是否打开或尝试重新连接。

TMV\Laminas\Messenger\Middleware\DoctrineTransactionMiddleware

对于每条消息，将消息处理器包裹在事务中。

订阅者

TMV\Laminas\Messenger\Subscriber\DoctrineClearEntityManagerWorkerSubscriber

此订阅者在工作器处理完消息后清除 EntityManager。