Привет, я создаю три сервера RabbitMQ, работающих в кластере на EC2.
Я хочу масштабировать базу кластера RabbitMQ на основе использования ЦП, но когда я публикую сообщение, только один сервер использует ЦП, а другой сервер RabbitMQ не использует ЦП.
так как я могу распределить нагрузку по кластеру RabbitMQ
Кластеры RabbitMQ предназначены для повышения масштабируемости, но система не является полностью автоматической.
Когда вы объявляете очередь на узле в кластере, очередь создается только на этом одном узле. Таким образом, если у вас есть одна очередь, независимо от того, на каком узле вы публикуете сообщение, оно окажется на узле, где находится очередь.
Чтобы правильно использовать кластеры RabbitMQ, вам необходимо убедиться, что вы делаете следующие вещи:
Кроме того, взгляните на Очереди высокой доступности. Они похожи на обычные очереди, но содержимое очереди зеркально отражается на нескольких узлах. Таким образом, в вашем случае вы будете публиковать на одном узле, RabbitMQ будет отражать публикации на другом узле, а потребители смогут подключаться к любому узлу, не беспокоясь о том, что кластер застопорится внутренними переносами.
Это не совсем так. Ознакомьтесь с документацией по этому вопросу.
Сообщения, опубликованные в очереди, реплицируются на все зеркала. Потребители подключаются к мастеру независимо от того, к какому узлу они подключаются, а зеркала отбрасывают сообщения, которые были подтверждены мастером. Таким образом, зеркалирование очередей повышает доступность, но не распределяет нагрузку между узлами (каждый из участвующих узлов выполняет всю работу).
