Предисловие

RabbitMQ Это мощная система очередей сообщений с открытым исходным кодом, которая реализует эффективную передачу сообщений и асинхронную обработку. В этой статье в основном представлены его основанные на Docker-Compose изразвертывать Установитьи некоторыеиспользоватьизопыт。

Функции

• зрелый, стабильный
• Сохранение сообщений
• Гибкая маршрутизация сообщений
• Высокая производительность, высокая доступность, высокая масштабируемость
• Система поддержки плагинов: RabbitMQ Благодаря богатой системе плагинов его функциональность может быть расширена с помощью Установить плагин, например Интерфейс. управления、Отслеживание сообщений、Преобразование сообщений и т. д.
• Официально предоставляет .NET/Java SDK.

Использование

• Используется в проекте для логирования, отправки сообщений, синхронизации данных и т.д., стабильно и надежно.
• Инициализация бизнес-модулей, асинхронная обработка импорта данных
• Выполните идемпотентную обработку,Разные сценарии и разные методы подтверждения,Предотвращение повторного использования сообщений
• RabbitMQ по умолчанию не поддерживает отложенные сообщения,использоватьПлагин отложенного сообщенияПросто реализуйте это（Ограничено, поддерживает только сообщения с задержкой до одного или двух дней.）
• использовать .NET SDK: RabbitMQ.Client, вторичную инкапсуляцию мы поделимся позже.

упражняться

использовать Docker Compose V2 Установить rabbitmq v3.12.6

Подготовить

• Текущая версия: v3.12.6.
• использоватьзеркало：rabbitmq:3.12.6-management (приносить web интерфейс управления)
• Порт по умолчанию: 5672: порт подключения приложения 15672: веб-консоль

Установите с помощью Docker Compose.

Эта статья основана на Docker V24 и Docker Compose V2,Установить Вы можете обратиться к предыдущемуизстатья

Инструкции по настройке

• Зафиксированныйзеркало Версия：rabbitmq:3.12.6-management
• обозначениеизимя хоста：rabbitserver
• обозначение Имя виртуальной машины：admin_vhost
• Укажите пароль учетной записи: root devops666
• обозначениепорт：5672：порт подключения приложения 15672：web Интерфейс управления
• Подключить каталог данных：./data:/var/lib/rabbitmq
• Монтировать дополнительныеизплагин Оглавление：./myplugins:/myplugins RabbitMQ Каталог плагинов по умолчанию в контейнере: /plugins Не рекомендуется монтировать
• Воля ./myplugins монтировать наконтейнериз,и Воляего присоединениеплагин Находитьиз Оглавлениесередина：RABBITMQ_PLUGINS_DIR: '/plugins:/myplugins'
• Укажите сеть: DevopsNetwork (docker network create devopsnetwork)

Конфигурационный файл compose.yml

Подготовитьхороший compose.yml Копировать на сервер

тогда бегиdocker compose up -dВот и все

 version: '3.1'
 services:
   rabbitmq:
     image: rabbitmq:3.12.6-management
     container_name: rabbitmq_3_12
     restart: always
     # Имя узла кролик@rabbitserver, иначе он перейдет на контейнерID
     hostname: rabbitserver
     environment:
       # Имя виртуальной машины по умолчанию
       RABBITMQ_DEFAULT_VHOST: admin_vhost
       # имя пользователя
       RABBITMQ_DEFAULT_USER: root
       # пароль
       RABBITMQ_DEFAULT_PASS: devops666
       # Укажите пользовательский каталог плагина
       RABBITMQ_PLUGINS_DIR: '/plugins:/myplugins'
     ports:
       - "5672:5672"
       - "15672:15672"
     volumes:
       - ./data:/var/lib/rabbitmq
       - ./myplugins:/myplugins
     networks:
       - devopsnetwork

 networks:
   devopsnetwork:
     external: true
 ```

Развертывание успешно

IP-адрес машины развертывания: 192.168.123.214.

Установить плагин: Плагин задержки сообщений

Примечание. Задержка публикации сообщения плагина поддерживается только в секундах, минутах или часах, вплоть до одного или двух дней, обратите внимание! ! ! Исходный текст: Этот плагин был разработан для задержки публикации сообщений на несколько секунд, минут или часов. День-два максимум.

! ! ! передний compose.yml По умолчанию — воля. /myplugins Подключен к контейнеру и укажите несколько каталогов плагинов. Система:/плагины Добавьте его самостоятельно:/myplugins , оптимизирован процесс, Установитьплагин не требует копировать файлы и перезапускает контейнер

1. Сначала необходимо скачать плагин: Rabbitmq_delayed_message_exchange-3.12.0.ez, скачать соответствующую версию из 。ez документ：Github Releases
2. Воля скачать файл исплагина на 。/myplugins папка Передний Воля myplugins Крепится к контейнеру
3. соединятьконтейнер Включение выполненияплагин：docker exec -it rabbitmq_3_12 /bin/bash -c "rabbitmq-plugins enable rabbitmq_delayed_message_exchange"
4. Потому что он установлен myplugins и установите его в каталог плагина найду сам /plugins и/myplugins Соответствующий ez документк Установить

1. Активировано успешно, его можно просмотреть на странице Обмены.

Ямы, на которые наступили

• В соответствии с приведенной выше конфигурацией следующие проблемы больше не возникнут. Если вы столкнулись с той же проблемой, см.
• Сообщения с задержкой поддерживают только сообщения с задержкой до одного или двух дней. В проекте есть функция регулярной отправки сообщений. Если соответствующая настройка времени превышает порог, она не может быть использована. иллюстрировать
• Не монтировать /плагины плагин Оглавление,доступныйRABBITMQ_PLUGINS_DIR: '/plugins:/myplugins'Приходитьобозначениенесколько Оглавление,Для этого требуется только выполнение документ
• Не указан hostname Имя узла Назовите это встречейконтейнер Id

• использовать Понятно rabbitmq:3.x-management зеркало (с web Страница управленияиз Функция）Но он был установлен пустымизплагин Оглавление Сообщим об ошибке：{"init terminating in do_boot",{undef,[{rabbit,boot,[],[]},{init,start_em,1,[]},{init,do_boot,3,[]}]}}

• Admin На странице появляется сообщение об ошибке: Обновите версию. issues Я начал использовать его 3.9.29-management（tags Сортировка списка 3.9 впереди ( ╯□╰ )), сообщите об этой ошибке

• Нужно пройти перед сменой версий. /data Очистить данные, иначе не запустится

• Ошибка страницы обмена: я сменил версию на 3.12.6-management и сообщил об этой ошибке. Я не вышел из системы, мне просто нужно было нажать Ctrl+F5 и войти снова.

использовать

.NET SDK

чиновник：RabbitMQ.Client

Конфигурация подключения

var factory = new ConnectionFactory
{
    HostName = "192.168.123.214",
    Port = 5672,
    VirtualHost = "admin_vhost",
    UserName = "root",
    Password = "devops666",
};

Демонстрационный пример

построил demo тестиспользовать Демо-адрес , мы подробно расскажем, как инкапсулировать его позже, когда будем инкапсулировать его во второй раз.

Связанные документы

• Репозиторий проекта RabbitMQ
• Образ DockerHub
• чиновникдокумент
• Плагин отложенного сообщенияскачать
• Репозиторий .NET SDK

постскриптум

Установить по-прежнему относительно просто, выберите правильную версию, больше возможностей использования, вам нужно выбрать подходящее решение в соответствии с бизнесом. плагиниз Установить потратил некоторое время на исследование и оптимизацию этого процесса.