В моем приложении есть очередь, которая потенциально может стать очень большой. Что, если я обнаружу, что на моей машине больше нет места? Как я могу разделить свою очередь на несколько машин? Может быть, философия RabbitMQ отличается, и мне следует создать несколько очередей вместо одной большой очереди?
Лучший, Флавио
Как вы можете прочитать в ветке списка рассылки RabbitMQ http://rabbitmq.1065348.n5.nabble.com/RabbitMQ-scalability-design-question-td28323.html, решение, которое я придумал, заключается в реализации шаблона конкурирующих потребителей (много потребителей в очереди), который при обнаружении специальное сообщение (с включенным стоп-флажком) отправляет STOP-сообщение в топик-обмен.
Это стоп-сообщение получает «главный» потребитель для этой очереди, который начинает опрашивать Zookeeper (через куратора) до тех пор, пока все дочерние элементы определенного zkNode не будут удалены (в данном случае с использованием Zookpeer в качестве реестра потребителей очередей). Когда все потребители завершили фазу остановки, «главный» потребитель выполняет некоторую задачу и повторно включает потребителей исходной очереди, отправляя сообщение RESTART в обмен темами (где каждый потребитель прослушивает выделенную очередь).
Я надеюсь, что это может помочь (или «вдохновить») кого-то еще.
RabbimMQ обеспечивает кластеризацию и функции высокой доступности прямо из коробки, вам просто нужно настроить их в соответствии со своими потребностями.
На самом деле AMQP может хранить сообщения любого размера, но в большинстве случаев сообщения имеют размер до 32 КБ в 99%, я думаю. Вы можете рассчитать оценочное использование ресурсов (мин./макс./среднее) и принять дальнейшее решение о кластеризации или отказе от кластеризации.
