RabbitTemplate — основной способ отправки в Spring AMQP: convertAndSend(exchange, routingKey, payload) с конвертером сообщений (JSON через Jackson2JsonMessageConverter), плюс синхронный request-reply и получение.
sottopublisher-confirm-type: correlated) и returns (mandatory) для неотмаршрутизированныхА ещё Отправка в транзакции базы не атомарна — outbox
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Отправка:
rabbitTemplate.convertAndSend("orders", "order.created", event); // exchange, routing key, объектОбъект сериализуется MessageConverter: по умолчанию — Java-сериализация или строки, на практике ставят Jackson2JsonMessageConverter (JSON и заголовок типа). MessagePostProcessor — для заголовков, TTL, приоритета.
Надёжность:
spring.rabbitmq.publisher-confirm-type=correlated — брокер подтверждает приём; CorrelationData позволяет понять, какое сообщение подтверждено или отвергнуто (nack) и повторить;publisher-returns=true и template.mandatory=true — если сообщение не попало ни в одну очередь (нет привязки), оно вернётся в callback, а не исчезнет молча;Топология объявляется бинами Queue, TopicExchange, Binding — RabbitAdmin создаёт их при старте.
Request-reply: convertSendAndReceive — синхронный вызов через очередь ответов. Удобно, но превращает асинхронную систему в синхронную; использовать осторожно.
Согласованность с базой: как и с Kafka — outbox.
Один верный вариант. Подумайте, потом откройте ответ.
RabbitTemplate, @RabbitListener, exchanges, bindings, manual ack, retries, DLQ и prefetch.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.