RabbitMQ Work-Queue для обмена сообщениями FanOut

Question

Я пытаюсь масштабировать систему обмена сообщениями RabbitMQ. Текущая система очень проста - производитель отправляет сообщение об обмене разветвлением, а сообщение обрабатывается несколькими потребителями - классическая маршрутизация разветвления.

У меня есть несколько потребителей из разных типов (например, один, который печатает на экран, тот, который записывается в файл, тот, который сохраняется в DB, ​​...). Мой вызов - я не уверен, что лучший способ масштабировать потребителей. Если я добавлю других пользователей из одного типа - я получу двойные записи или двойные записи в БД. ... (подумайте о двух потребителях БД, потребляющих один и тот же обмен разветвлений).

Я думаю, что я могу создать потребителя, который публикует в рабочей очереди, но мне интересно, есть ли лучшее «встроенное» решение в rabbitmq.

заранее спасибо, ZF

Answer 1

Если вам необходимо масштабировать потребитель, чтобы потребить быстрее все сообщения, приходящие от обмена ветвления, нужна конкурентоспособные потребляя; поэтому вам нужно больше потребителей, прикрепленных к одной очереди, связанной с обменом разветвлением.
Таким образом, каждый потребитель будет потреблять пакет сообщений отдельно от других. Количество сообщений внутри партии определяется с помощью свойства count prefetch (http://www.rabbitmq.com/consumer-prefetch.html).
Таким образом, в вашем случае вы должны иметь возможность масштабировать пользователей, избегая двойных журналов и двойных записей в БД.