Работал ли с Message Broker

Question

Accepted Answer

Да, работал с Message Broker, в основном с RabbitMQ и Kafka.

RabbitMQ (AMQP) — для гарантированной доставки сообщений, очередей, обмена между микросервисами. Пример:

java

ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
try (Connection connection = factory.newConnection();
     Channel channel = connection.createChannel()) {
    channel.queueDeclare("test-queue", false, false, false, null);
    channel.basicPublish("", "test-queue", null, "Hello, RabbitMQ!".getBytes());
}

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)) {
    producer.send(new ProducerRecord<>("test-topic", "key", "Hello, Kafka!"));
}

Использовал их для асинхронной коммуникации, event sourcing, балансировки нагрузки.

Работал ли с Message Broker

Следующий вопрос