Ответ
Message Broker (брокер сообщений) — промежуточное ПО, обеспечивающее асинхронный обмен сообщениями между компонентами системы (производителями и потребителями). Он решает задачи декаплинга сервисов, буферизации нагрузки и надёжной доставки.
RabbitMQ vs Apache Kafka: сравнение и применение
| Аспект | RabbitMQ (AMQP) | Apache Kafka |
|---|---|---|
| Модель | Точка-точка (очереди), Pub/Sub (Exchange) | Публикация/подписка на основе логов (log-based). Сообщения хранятся. |
| Главная цель | Надёжная доставка, маршрутизация сообщений, RPC. | Обработка потоков событий в реальном времени, хранение и воспроизведение данных. |
| Гарантии | Подтверждения (ack), persistence, dead letter exchanges. | Высокая пропускная способность, долговременное хранение, гарантия порядка в партиции. |
| Идеально для | Фоновые задачи, распределение работы между воркерами, микросервисная коммуникация. | Потоковая аналитика, event sourcing, сбор логов, мониторинг в реальном времени. |
Пример отправки сообщения в RabbitMQ (Java):
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
// Объявляем очередь
channel.queueDeclare("task_queue", true, false, false, null);
// Публикуем сообщение
String message = "New task #42";
channel.basicPublish("", "task_queue",
MessageProperties.PERSISTENT_TEXT_PLAIN,
message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
}Пример отправки события в Kafka (Java):
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
try (Producer<String, String> producer = new KafkaProducer<>(props)) {
// Отправка записи в топик
ProducerRecord<String, String> record =
new ProducerRecord<>("user-events", "user123", "{"action":"login"}");
producer.send(record);
// send() асинхронный, можно добавить callback для обработки результата
}Опыт применения: RabbitMQ — для фоновой обработки заказов и нотификаций; Kafka — для потоковой аналитики пользовательских действий и репликации данных между системами.
Ответ 18+ 🔞
А, ну вот, опять про эти ваши брокеры сообщений! Сидишь, блядь, читаешь, а там — RabbitMQ, Kafka... Как будто в зоопарке каком-то, ей-богу. Ну ладно, разберёмся, что к чему, а то потом на собеседовании опять спросят, а ты будешь как Герасим — «Му-му» и нихуя.
Брокер сообщений, если по-простому, — это такой почтальон-переросток между твоими программами. Одна штука кричит: «Вот тебе задание!», а брокер берёт, суёт в карман и несёт другой, которая сидит и ждёт, когда ей работу дадут. И всё это асинхронно, то есть они друг другу в глаза не смотрят, не дергаются. Главные фишки — развязать сервисы (чтобы один сдох, а другие жили), сгладить пики нагрузки (когда навалило, а переварить не могут) и доставить наверняка, а не как почта России.
А теперь, блядь, главный цирк: RabbitMQ против Apache Kafka. Это как сравнивать трактор и спорткар. Оба ездят, но задачи, ёпта, разные.
| Штука | RabbitMQ (этот с ушами) | Apache Kafka (длинный и упрямый) |
|---|---|---|
| Как работает | Очереди (отдал одному — ушло) или раздача всем (через Exchange). | Публикация в лог-журнал. Все подписчики могут читать, и всё хранится дохуя времени. |
| Зачем создан | Чтобы сообщения точно дошли, разошлись по нужным адресам, можно даже ответ дождаться (RPC). | Чтобы глотать овердохуища событий в реальном времени, хранить их и потом по сто раз перемалывать. |
| Что гарантирует | Подтверждения получения, сохранность на диске, мёртвые письма в отдельную корзину. | Бешеную скорость, порядок событий в рамках одной «пачки» (партиции) и хранение, пока не надоест. |
| Куда тыкать | Фоновые задачи (отправка писем, обработка заказов), балансировка нагрузки между воркерами, общение микросервисов. | Потоковая аналитика (клики, логины), Event Sourcing (история всех изменений), сбор логов, мониторинг в реальном времени. |
Вот тебе пример, как в RabbitMQ запихнуть сообщение (Java): (Код не трогаю, он святой, но представь, что пишешь это с чувством глубокого удовлетворения)
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
Channel channel = connection.createChannel()) {
// Объявляем очередь
channel.queueDeclare("task_queue", true, false, false, null);
// Публикуем сообщение
String message = "New task #42";
channel.basicPublish("", "task_queue",
MessageProperties.PERSISTENT_TEXT_PLAIN,
message.getBytes());
System.out.println(" [x] Sent '" + message + "'");
}А вот как в Kafka событие отправить (тоже Java): (Тут уже чувствуешь себя большим начальником, который данные в трубу закидывает)
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
try (Producer<String, String> producer = new KafkaProducer<>(props)) {
// Отправка записи в топик
ProducerRecord<String, String> record =
new ProducerRecord<>("user-events", "user123", "{"action":"login"}");
producer.send(record);
// send() асинхронный, можно добавить callback для обработки результата
}Из моего, блядь, горького опыта: RabbitMQ — это когда тебе нужно раздать задания воркерам, чтобы они там письма рассылали или заказы обрабатывали, и чтобы ни одно не потерялось. А Kafka — это когда у тебя поток событий, как из пожарного шланга: клики, логи, транзакции. Ты их всех в одну большую трубу засунул, а потом разные системы прильнули и сосут, кто что хочет. Красота, ёпта!
Короче, выбирай по задаче. Не надо Kafka там, где нужно просто очередь на три сообщения, и не надо RabbitMQ тащить, когда тебе нужно историю всех действий пользователя за год хранить. А то получится как в той сказке — «ядра — чистый изумруд», а на деле — просто ебучка с настройками.