С какими брокерами сообщений (message queues) вы работали?

Тип вопроса: Брокеры сообщений Вероятность: 10% Категория: Java Разработчик

Ответ

Работал с несколькими популярными брокерами сообщений, каждый из которых решает разные задачи:

1. RabbitMQ (AMQP)

  • Модель: Классический брокер сообщений, реализующий протокол AMQP. Использует концепции exchanges (маршрутизаторы), queues и bindings.
  • Ключевые особенности: Гарантированная доставка (acknowledgments), поддержка различных паттернов маршрутизации (direct, fanout, topic, headers), гибкость.
  • Пример (Java с использованием AMQP): 
    ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
     Channel channel = connection.createChannel()) {
    // Объявляем очередь
    channel.queueDeclare("my_queue", false, false, false, null);
    // Публикуем сообщение в exchange по умолчанию ("") с routing key = имени очереди
    channel.basicPublish("", "my_queue", null, "Hello, RabbitMQ!".getBytes());
}

2. Apache Kafka

  • Модель: Распределенная система потоковой передачи событий (event streaming platform), а не просто очередь. Сообщения хранятся в топиках (topics), разбитых на партиции, и сохраняются на диске.
  • Ключевые особенности: Высокая пропускная способность, отказоустойчивость за счет репликации, возможность повторного чтения сообщений (consumer groups), долговременное хранение.
  • Использование: Логирование, потоковая обработка данных (Kafka Streams), event sourcing.

3. Apache ActiveMQ / Artemis

  • Модель: Реализация JMS (Java Message Service) API. Поддерживает две модели доставки: очереди (Point-to-Point) и топики (Pub/Sub).
  • Ключевые особенности: Стандартный JMS API, встроенная в Java-экосистему, поддержка различных протоколов (OpenWire, AMQP, MQTT, STOMP).
  • Пример (JMS): 
    ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
try (Connection connection = factory.createConnection()) {
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createQueue("MY.QUEUE");
    MessageProducer producer = session.createProducer(queue);
    TextMessage message = session.createTextMessage("Hello, JMS!");
    producer.send(message);
}

Сравнение и выбор:

  • RabbitMQ — для сложных маршрутизаций, RPC, фоновых задач, где важна гарантированная доставка и гибкость.
  • Kafka — для потоковой обработки больших объемов данных, логов, событий, где важны пропускная способность и возможность повторной обработки.
  • ActiveMQ/Artemis — для проектов, строго привязанных к стандарту JMS, или требующих поддержки множества протоколов.

Ответ 18+ 🔞

Слушай, а вот эти ваши брокеры сообщений — это ж целый зоопарк, блядь! Сидишь такой, думаешь: "Ну, сообщения надо пересылать, хуле тут сложного?" Ан нет, ёпта! Каждый — как отдельная религия со своими иконами и молитвами. Разбираться — терпения ноль ебать.

Вот, например, RabbitMQ — это такой старый, добрый, блядь, почтальон с мешком. Работает по протоколу AMQP, и у него там целая кухня с exchanges (это как сортировочные центры), очередями и привязками (bindings). Главный козырь — гарантированная доставка, чтоб ни одно сообщение не потерялось, как носок в стиралке. Хочешь разослать всем — fanout, хочешь по ключу — topic, direct. Гибкий, как гимнаст, блядь.

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
     Channel channel = connection.createChannel()) {
    // Объявляем очередь, типа "застолбили почтовый ящик"
    channel.queueDeclare("my_queue", false, false, false, null);
    // Кидаем в него письмецо
    channel.basicPublish("", "my_queue", null, "Hello, RabbitMQ!".getBytes());
}

А потом вылезает Apache Kafka и такой: "Вы всё, блядь, в каменном веке живете!" Это не просто очередь, это, сука, платформа потоковых событий, ёба! Сообщения пишутся в топики, которые ещё и на партиции режутся, и хранятся на диске, будто архив КГБ. Производительность — овердохуища, можно заново всё перечитать, если накосячил. Идеален для логов, ивентов и прочего потока данных, который не остановить.

А следом, похаживая, Apache ActiveMQ / Artemis. Этот чувак — эталонный зануда, который кричит: "Ребята, есть же стандарт JMS! Давайте по стандарту, блядь!" Поддерживает и очереди (точка-точка), и топики (издатель-подписчик). И говорит на куче протоколов, как полиглот-извращенец. Сильно завязан на Java-мир.

ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
try (Connection connection = factory.createConnection()) {
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    Queue queue = session.createQueue("MY.QUEUE");
    MessageProducer producer = session.createProducer(queue);
    TextMessage message = session.createTextMessage("Hello, JMS!");
    producer.send(message); // Отправлено, как по учебнику!
}

Так какой же выбрать, спросишь ты? Да всё просто, как три копейки:

  • RabbitMQ — когда тебе нужны сложные маршруты, фоновые задачи и железные гарантии, что всё дойдёт. Классика, проверенная временем.
  • Kafka — когда у тебя поток данных, как из рога изобилия, и нужно его не просто передать, а хранить, обрабатывать и перемалывать тоннами. Для big data и event-driven архитектур.
  • ActiveMQ/Artemis — когда твой проект живёт и дышит JMS, или когда нужно подружить кучу разных систем по разным протоколам. Консервативный, но надёжный выбор.

Вот и весь сказ. Главное — не пытайся молотком гвозди закручивать, а то получится пиздопроебибна, а не система.

© ХакСобесов, 2026
support@hacksobesov.com