我们的 symfony 应用原本使用的是一个自定义的消息队列系统，性能表现却差强人意。随着用户数量的增长，消息积压问题日益严重，导致系统响应速度缓慢，用户体验极差。我们尝试了多种优化方案，但收效甚微。瓶颈主要在于消息的生产和消费效率。这时，我开始寻找更专业的消息队列解决方案，并最终选择了 enqueue。
Enqueue 是一个灵活且强大的 php 消息队列库，支持多种消息中间件，例如 rabbitmq、redis 等。然而，直接使用 Enqueue 需要编写大量的代码来处理消息的发送和接收，这增加了开发成本。幸运的是，Enqueue 提供了与 Symfony Messenger 的适配器——enqueue/messenger-adapter。它允许我们利用 Symfony Messenger 的简洁 API 来操作 Enqueue，从而简化开发流程，并充分利用 Enqueue 的高性能特性。
使用 composer 安装 enqueue/messenger-adapter 非常简单：
composer require sroze/messenger-enqueue-transport
接下来，我们需要在 Symfony 的 messenger.yaml 配置文件中配置 Enqueue 传输器。假设我们使用 RabbitMQ，配置如下：
framework:</p><pre class="brush:php;toolbar:false">messenger: transports: amqp: enqueue://default?queue[name]=my_queue # 指定队列名称 routing: 'AppMessageMyMessage': amqp # 将消息路由到 amqp 传输器
这里，enqueue://default 指向 Enqueue 的默认配置，你可能需要在 .env 文件中配置 ENQUEUE_DSN 来指定 RabbitMQ 的连接信息，例如：
ENQUEUE_DSN=amqp://guest:guest@localhost:5672/%2f
完成配置后，我们就可以像使用 Symfony Messenger 的其他传输器一样使用 amqp 传输器了。消息的发送和消费变得异常简单，极大地提高了开发效率。 值得一提的是，enqueue/messenger-adapter 还提供了许多高级功能，例如自定义消息配置、设置消息优先级、延迟消息等，这使得我们可以根据实际需求进行精细化的控制。 例如，我们可以通过 TransportConfiguration 来设置消息的延迟：
use SymfonyComponentMessengerEnvelope;
use EnqueueMessengerAdapterEnvelopeItemTransportConfiguration;
$transportConfig = (new TransportConfiguration())->setDeliveryDelay(5000); // 延迟5秒
$bus->dispatch((new Envelope($message))->with($transportConfig));
在实际应用中，集成 Enqueue/Messenger Adapter 后，我们的消息处理效率得到了显著提升。消息积压问题得到了有效缓解，系统响应速度也大幅提高。 通过 Composer 简洁的依赖管理，以及 Enqueue/Messenger Adapter 的高效集成，我们轻松地构建了一个高性能的消息处理系统，提升了整体应用的稳定性和可靠性。 如果你也面临类似的挑战，我强烈推荐你尝试一下 Enqueue/Messenger Adapter。 它不仅能提升你的开发效率，还能显著改善应用的性能。 这让我对 Composer 的强大功能和 Enqueue 的高效性能有了更深刻的理解。 如果你想了解更多关于 Composer 的知识，可以参考这个 Composer 在线学习地址：学习地址。
