В этом руководстве мы рассмотрим концепцию разветвления и обмена темами с помощью Spring AMQP и RabbitMQ .
На высоком уровне разветвленные обмены будут транслировать одно и то же сообщение во все связанные очереди , в то время как тематические обмены используют ключ маршрутизации для передачи сообщений в определенную связанную очередь или очереди .
Для этого руководства рекомендуется предварительно прочитать Messaging With Spring AMQP .
Чтобы лучше понять, как работает RabbitMQ, нам нужно погрузиться в его основные компоненты.
В этой статье мы рассмотрим обмены, очереди и привязки, а также то, как мы можем объявить их программно в приложении Java.
Как обычно, мы будем использовать клиент Java и официальный клиент для сервера RabbitMQ.
Асинхронный обмен сообщениями — это тип слабосвязанной распределенной связи, который становится все более популярным для реализации архитектур, управляемых событиями . К счастью, Spring Framework предоставляет проект Spring AMQP , позволяющий нам создавать решения для обмена сообщениями на основе AMQP.
С другой стороны, работа с ошибками в таких средах может оказаться нетривиальной задачей . Итак, в этом уроке мы рассмотрим различные стратегии обработки ошибок.
В этом руководстве мы будем использовать RabbitMQ , реализующий стандарт AMQP. Кроме того, Spring AMQP предоставляет модуль spring-rabbit , который делает интеграцию действительно простой.
В этом руководстве мы рассмотрим обмен сообщениями через AMQP с использованием платформы Spring AMQP. Сначала мы рассмотрим некоторые ключевые концепции обмена сообщениями. Затем мы перейдем к практическому примеру.
Обмен сообщениями — это метод обмена данными между приложениями. Он основан на асинхронной передаче сообщений вместо архитектуры, основанной на синхронном запросе и ответе. Производители и потребители сообщений разделены промежуточным уровнем обмена сообщениями, известным как брокер сообщений . Брокер сообщений предоставляет такие функции, как постоянное хранение сообщений, фильтрация сообщений и преобразование сообщений.
В случае обмена сообщениями между приложениями, написанными на Java, обычно используется API JMS (Java Message Service). Для обеспечения взаимодействия между различными поставщиками и платформами мы не сможем использовать клиенты и брокеры JMS. Вот где AMQP пригодится .
По умолчанию в Spring AMQP ошибочное сообщение повторно ставится в очередь для следующего раунда потребления. Следовательно, может возникнуть бесконечный цикл потребления, что приведет к нестабильной ситуации и пустой трате ресурсов.
Хотя использование очереди недоставленных сообщений является стандартным способом обработки ошибочных сообщений , мы можем захотеть повторить попытку использования сообщений и вернуть систему в нормальное состояние.
В этом руководстве мы представим два разных способа реализации стратегии повторных попыток под названием «Экспоненциальный откат » .
В этом руководстве показано, как создать простое реактивное приложение Spring Boot, которое интегрируется с сервером обмена сообщениями RabbitMQ, популярной реализацией стандарта обмена сообщениями AMQP.
Мы рассмотрим оба сценария — «точка-точка» и «публикация-подписка» — с использованием распределенной установки, которая подчеркивает различия между обоими шаблонами.
Обратите внимание, что мы предполагаем базовые знания AMQP, RabbitMQ и Spring Boot, в частности, таких ключевых понятий, как обмены, очереди, темы и так далее. Более подробную информацию об этих концепциях можно найти по ссылкам ниже:
В предыдущих частях этой серии мы видели , как мы можем использовать Spring Remoting и связанные с ним технологии для включения синхронных удаленных вызовов процедур поверх HTTP-канала между сервером и клиентом.
В этой статье мы рассмотрим Spring Remoting поверх AMQP , который позволяет выполнять синхронный RPC , используя среду, которая по своей сути является асинхронной .
Существуют различные системы обмена сообщениями, совместимые с AMQP , которые мы могли бы использовать, и мы выбираем RabbitMQ , потому что это проверенная платформа и она полностью поддерживается в Spring — оба продукта управляются одной и той же компанией (Pivotal).