Почему у получателя в RabbitMQ нужно указывать имя очереди?

Question

[beduin01]

Изучаю примеры RabbitMQ. Вот мы создали exchange с типом fanout. К нему прибиндили очеред(ь\и).

Теперь по идее в получателе нам нужно указать только имя обменника и мы сможем получать данные из всех очередей т.к. тип fanout.

Однако в примере почему-то создается новая очередь со случайным именем. И в нее все получается. Где логика? Почему мы не можем просто получать данные из очередей созданных ранее?

Вот сам кусок кода получателя:

channel.exchange_declare(exchange='logs',
                         exchange_type='fanout')

result = channel.queue_declare(exclusive=True)
queue_name = result.method.queue

channel.queue_bind(exchange='logs',
                   queue=queue_name)

Comments

[Сергей]

Путь сообщения выглядит так:
Паблишер -> Обменник -> Очередь -> Потребитель
Не может потребитель "забрать" сообщение из обменника, обменник это простой маршрутизатор, он ничего не хранит, и не агрегирует сообщения из связанных с ним очередей

[beduin01]

Сергей, но очереди в нем же создаются. если я в нем создал очереди с именами test1 test2 test3 то я смогу из них данные забрать по тем же именам?

[Сергей]

beduin01, очереди не принадлежат какому-то обменнику, они просто связываются с ним, чтобы получать сообщения по какому-то критерию. Очередь может быть связана с несколькими обменниками или вообще не с одним. Очереди и обменники живут параллельно, они служат разным целям.

[beduin01]

Сергей, а зачем нужен routing_key ? Чтобы отправить сообщение в очередь с определенным именем?

Если очередь не связана ни с одним обменником, как туда данные попадают?

[Сергей]

beduin01, я бы сказал, чтобы получить нужное сообщение, так как очередь "подписывается", а не обменник подписывает очередь. Для fanout RK не имеет значения, для него главное наличие связи.

Без обменника в очередь нельзя отправить данные, но есть такая штука как default exchange (при публикации это пустая строка вместо имени), каждая очередь при своём создании делает биндинг к этому обменнику, где в качестве ключа связи идёт имя этой очереди.