在为Symfony2使用RabbitMQ包时，防止在RabbitMQ中创建多个连接

Question

我将RabbitMQ包用于Symfony2 web框架。我的问题是，在TERMINAL中运行多个workers后，如何避免创建多个连接（以防止使代理过载）？在下面的示例中，我运行了两个workers，结果有两个connections/channel。

config.yml

old_sound_rabbit_mq:
    connections:
        default:
            host:     127.0.0.1
            port:     5672
            user:     guest
            password: guest
            vhost:    /
            lazy:     true
    producers:
        order_create_bmw:
            connection:       default
            exchange_options: { name: order_create_ex, type: direct }
            queue_options:
                name: order_create_bmw_qu
                routing_keys:
                    - bmw
    consumers:
        order_create_bmw:
            connection:       default
            exchange_options: { name: order_create_ex, type: direct }
            queue_options:
                name: order_create_bmw_qu
                routing_keys:
                    - bmw
            callback:         application_frontend.consumer.order_create_bmw

services.yml

services:
    application_frontend.producer.order_create_bmw:
        class: Application\FrontendBundle\Producer\OrderCreateBmwProducer
        arguments:
            - @old_sound_rabbit_mq.order_create_bmw_producer

namespace Application\FrontendBundle\Producer;

use Application\FrontendBundle\Entity\Order;
use OldSound\RabbitMqBundle\RabbitMq\ProducerInterface;

class OrderCreateBmwProducer
{
    private $producer;

    public function __construct(ProducerInterface $producer)
    {
        $this->producer = $producer;
    }

    public function add(Order $order)
    {
        $message = [
            'order_id' => $order->getId(),
            'car_model' => $order->getCarModel(),
            'timestamp' => date('Y-m-d H:i:s')
        ];

        $this->producer->publish(json_encode($message), 'bmw');
    }
}

$ app/console rabbitmq:consumer order_create_bmw
$ app/console rabbitmq:consumer order_create_bmw

Answer 1

每个连接到rabbitmq的客户机（无论发布者还是订阅者）都将创建一个连接。除了使用更少的客户端，我想不出任何其他方法来实现这一点。我也想不出这样做的理由：）如果是性能，那么实际上拥有更多的订阅者将有助于“清空”交换（和队列）。