我有一个队列来发送消息。当使用者从该队列中接收到一条消息时,它将对其进行处理并生成大量需要发送到另一个队列的特定消息。然后,我将有许多消费者处理这些消息。
这是正确的方法吗?如果是,我是否仅将这个回调类同时定义为使用者和生产者?我正在使用RabbitMqBundle进行symfony。
这听起来很正常。
生产者和消费者是不同的类。当您使用RabbitMqBundle时,捆绑软件会自动生成生产者服务,您可以将其注入到其他类中。消费者。 (https://github.com/php-amqplib/RabbitMqBundle#producer)生产者的服务名称将以old_sound_rabbit_mq开头。[PRODUCER_NAME]。