如何将生产者作为服务注入 RabbitMQBundle 消费者?
How to inject a producer as a service into a RabbitMQBundle consumer?
我必须修改一个用 Symfony 和 RabbitMQ 开发的 php 系统作为队列系统。我没有直接使用 PHP 的 RabbitMQ 绑定,而是 Symfony 的 RabbitMQBundle。
我的问题是我不知道如何发布来自消费者的消息。是的,我知道,消费者旨在消费消息,而不是发布消息。但是我有一个多步骤的工作流程,我需要在处理完之前的一些消息后发布新消息。
Symfony 的 "magic" 让我无法发现一切是如何连接的。我一直在阅读有关服务的信息,但据我所知,"producers" 并未在任何地方声明为服务,在我的特殊情况下,我没有为每个人使用特定的 类,而只是将名称绑定到 RabbitMq 交换器。
在我的控制器中很容易调用这些生产者,我只需要输入类似
的内容
$this->get('old_sound_rabbit_mq.my_own_producer')->publish($whatever);
但在消费者中,我必须显式注入每个依赖项,但我不知道如何注入生产者。
我的生产者在rabbitmqbundle设置中的声明是这样的:
my_own:
connection: default
exchange_options: {name: 'my-own-channel', type: direct}
我的消费者服务在 services.yml 文件中的声明类似于:
my_own_service:
class: MyOwnBundleBundle\Consumers\MyOwnConsumer
arguments: ["@logger", "@doctrine_mongodb", "%variable1%", "%variable2%"]
tags:
- { name: monolog.logger, channel: my_own_channel }
感谢您的宝贵时间。
您可以在您的消费者中注入 rabbitmq 生产者并照常使用它。例如,您可以按如下方式更改消费者服务配置(请参阅最后一个参数):
my_own_service:
class: MyOwnBundleBundle\Consumers\MyOwnConsumer
arguments: ["@logger", "@doctrine_mongodb", "%variable1%", "%variable2%", "@old_sound_rabbit_mq.another_producer"]
tags:
- { name: monolog.logger, channel: my_own_channel }
并更改服务的构造函数以接受新参数:
protected $producer;
public function __construct($logger, $doctrine, $var1,$var2, $producer)
{
...
$this->producer=$producer;
}
因此将其用作:
public function execute(AMQPMessage $msg)
{
....
$mesassage = ....
$this->producer-> publish($message);
}
希望对您有所帮助
我必须修改一个用 Symfony 和 RabbitMQ 开发的 php 系统作为队列系统。我没有直接使用 PHP 的 RabbitMQ 绑定,而是 Symfony 的 RabbitMQBundle。
我的问题是我不知道如何发布来自消费者的消息。是的,我知道,消费者旨在消费消息,而不是发布消息。但是我有一个多步骤的工作流程,我需要在处理完之前的一些消息后发布新消息。
Symfony 的 "magic" 让我无法发现一切是如何连接的。我一直在阅读有关服务的信息,但据我所知,"producers" 并未在任何地方声明为服务,在我的特殊情况下,我没有为每个人使用特定的 类,而只是将名称绑定到 RabbitMq 交换器。
在我的控制器中很容易调用这些生产者,我只需要输入类似
的内容$this->get('old_sound_rabbit_mq.my_own_producer')->publish($whatever);
但在消费者中,我必须显式注入每个依赖项,但我不知道如何注入生产者。
我的生产者在rabbitmqbundle设置中的声明是这样的:
my_own:
connection: default
exchange_options: {name: 'my-own-channel', type: direct}
我的消费者服务在 services.yml 文件中的声明类似于:
my_own_service:
class: MyOwnBundleBundle\Consumers\MyOwnConsumer
arguments: ["@logger", "@doctrine_mongodb", "%variable1%", "%variable2%"]
tags:
- { name: monolog.logger, channel: my_own_channel }
感谢您的宝贵时间。
您可以在您的消费者中注入 rabbitmq 生产者并照常使用它。例如,您可以按如下方式更改消费者服务配置(请参阅最后一个参数):
my_own_service:
class: MyOwnBundleBundle\Consumers\MyOwnConsumer
arguments: ["@logger", "@doctrine_mongodb", "%variable1%", "%variable2%", "@old_sound_rabbit_mq.another_producer"]
tags:
- { name: monolog.logger, channel: my_own_channel }
并更改服务的构造函数以接受新参数:
protected $producer;
public function __construct($logger, $doctrine, $var1,$var2, $producer)
{
...
$this->producer=$producer;
}
因此将其用作:
public function execute(AMQPMessage $msg)
{
....
$mesassage = ....
$this->producer-> publish($message);
}
希望对您有所帮助