问题标签 [symfony-messenger]

我正在使用 Symfony 5.2 和带有 sengrid 的 messenger 来发送邮件。

我想在执行特定操作时发送电子邮件。但是这个动作可以连续重复几次，我不想向我的用户发送垃圾邮件。我想在发送之前存储这些电子邮件，并每小时运行一次 CRON。如果电子邮件是为同一用户发送的，CRON 将分组为一封电子邮件。我想知道最好的方法来做到这一点。

我指定最简单的方法是在基础上创建一个专用表，但我想知道 symfony 是否没有更好的方法

PS：对不起我的英语

先感谢您。

所以正如标题所说，我在 Symfony 中的消息没有被处理。一点也不。甚至没有出现错误。

所以我的信使配置是完全默认的。但是我设置了多个总线，如下所示

我的输出bin/console debug:mess是：

我在课堂上注意到的：\Symfony\Component\Messenger\Handler\HandlersLocator空数组在构造函数中作为处理程序列表传递。

我在 5.2 版本中使用 symfony 和 symfony/messenger

和我的调度代理（如果重要）：

}

有没有办法在信使路由中使用 .env 变量？

例如，这个配置：

给我这个错误：

我的 config/messanger.yaml 看起来像：

命令的命令处理程序UpdateUser如下所示：

现在我从控制器发送这个命令：

你能告诉我为什么中间件上的自动刷新DoctrineTransactionMiddleware不起作用吗？我错过了什么？

在信使处理程序中，如果消息的处理时间比心跳时间长，则由于连接断开，您将无法确认消息。

处理程序中有没有办法手动保持连接处于活动状态？将消息发布到“ping”队列是否足够？

例子：

提前致谢

是否有可能防止某些消息（例如实现某个接口的消息）在被拒绝后（多次重试后）发送到失败传输？

在使用 RabbitMQ 和 Symfony Messenger 实现 AMQP 服务时，我感觉错过了一些东西。

从 RabbitMQ 的角度来看，消费者（也称为工作人员）从队列中消费。

从 Symfony Messenger 文档中，一个“传输”链接到一个消费者。这是设计使然，如命令所示bin/console messenger:consume transport。因此，对于每个“处理程序”，您必须配置一个专用传输，messenger.yaml以便能够分配特定数量的进程（例如通过 Supervisor 配置numprocs变量）。

如前所述，我找到了一种使用 2 种不同传输方式配置该用例的方法。然而，这对我来说看起来有点太复杂了：

没有其他方法可以实现这一目标吗？

我想使用 messenger 组件和 rabbitmq 提交一个带有异步方法的表单。提交此表格后，会向我发送一封电子邮件。但是当我实现rabbitmq时它不起作用。我肯定有配置问题。也许我必须在 services.yml 中添加一些东西？我不想使用码头工人。

.env 文件与 amqp 因为我想使用 rabbitmq

当我提交表单时输出给我这个结果

另外，Rabbitmq UI 出现在 webprofiler DOWN 上，没有转为 UP。我想不通。请帮帮我。

我正在尝试在没有 Symfony 框架的项目中使用 Symfony Messenger。

我想在我的控制器中使用它（php8）

我将控制器和总线放入 services.yml

但当然，我需要MessageBusInterface在MessengerCommandBus. 使用 Symfony 框架，我可以使用它来创建它，messenger.yml但我使用的是独立的组件，我没有它。在这种情况下我可以在哪里配置总线？我应该创建一个新的 MessengerBus，$commandBus = new MessageBus([])但$queryBus = new MessageBus([])它没有实现 MessageBusInterface 还是应该在另一个地方配置它？我无法理解有关 Messenger的文档（（

• 我正在使用Symfony 快速通道第 18.3 章
• 配置 Messenger 配置（config/packages/messenger.yaml）：

• Messenger 守护进程已启动
• 但是当我运行以下命令时，我收到以下错误消息：

• 我的配置有什么问题？