RabbitMQ Cheatsheet – Резюме – “Кратко и по делу”

Общие упрощенные понятия. Возможно существуют способы задать другое поведение нежели данное упощенное.

Основные понятия RabbitMQ

  • producer – отправитель, программный код, который отправляет сообщение.
  • consumer – получатель, программный код, который должен получить сообшение.
  • exchange – обменник, функционал RabbitMQ, получает сообщение с заданными параметрами от отправителя и:
    • может сбросить(удалить) сообщение или вернуть отправителю (зависит от атрибутов сообщения),
    • может отправить сообщение в очередь,
    • может отправить сообщение в несколько очередей (сообщение будет скопировано для каждой очереди)
  • queue – очередь, функционал RabbitMQ, хранит все сообщения и раздает их получателям.
  • message – сообщение, содержит атрибуты необходимые RabbitMQ, а также данные для передачи от отправителя к получателю
  • binding – связывание очереди и обменника. Обменник может отправить сообщения только в те очереди которые с ним связаны.
  • routingKey – ключ маршрутизации (может не использоваться), используется обменником для маршрутизации (выбора очереди(ей)) сообщений.
    • используется при связывании очереди с обменником
    • содержится в атрибуте сообщения при совпадении этих ключей сообщение будет отправлено в очередь

Обменник

Default exchange

RabbitMQ всегда создает безымянный обменник типа direct. На этот обменник по умолчанию завязаны все очереди, где routingKey равен имени очереди. Отправка сообщения напрямую в очередь на самом деле это отправка сообщения безымянному обменнику с routingKey нужной очереди. Как итог это выглядит и работает как отправка сообщения напрямую в очередь, но сообщения всегда отправляются через обменник.

Тип обменика (один из четырех вариантов)

  1. direct – прямая отправка в очередь, используется routingKey. Сообщение с каким-то routingKey будет отправленно обменником в очередь связанную с этим обменником с тем же routingKey, иначе сброшено(удалено).
  2. fanout – routingKey игнорируется, сообщения будут отправлены во все очереди связанные с обменником
  3. topic – похож на direct, сообщения отправляются с routingKey, но очереди связываются с обменником по шаблонной строке, сообщение попадет в те очереди с шаблонами которых совпадает routingKey
  4. headers – (todo)

Создание обменника

Необходимо указать:

  • имя очереди
  • имя обменника
  • шаблон или routingKey (зависит от типа обменника)
  • тип обменника
  • перечень аргументов
  • durable (bool) – сохранять и восстанавливать после рестарта RabbitMQ
  • autoDelete (bool) – удалится после того как все очереди отключатся
  • (todo)

Очередь

Перед использованием должны быть созданы. Повторное создание с теми же аргументами не создаст ошибки и не создаст еще одну очередь. Повторное создание с другими аргументами создаст ошибку.

Создание очереди

  • имя очереди (опционально), RabbitMQ сгенерирует имя при необходимости
  • опции
    • exclusive – используется только данным подключением, будет удалено после закрытия подключения
    • durable – сохранение после рестарта
    • autoDelete – удалится если кол-во получетелей станет ноль
    • maxPriority – очередь станет поддерживать приоритетные сообщения с приоритетом от 0 до maxPriority, чем выше число тем приоритетнее
    • (todo)

Отправитель

Программа не входящая в состав RabbitMQ, отправляет сообщения.

Отправка сообщения (публикация)

  • имя обменника
  • ключ маршрутизации
  • содержимое сообщения
  • опции
    • expiration – строка в мс, время через которое сообщение будет удалено из очереди
    • priority – приоритет, для приоритетных очередей
    • persistent – сохранение сообщения при перезагрузки
    • mandatory – если true, то сообщение будет возвращено отправителю в случае когда не нашлось очереди для отправки
    • (todo)

Получатель

Программа не входящая в состав RabbitMQ, получает сообщения.

Прием сообщения

  • имя очереди
  • функция
  • опции
    • noAck – сообщение подверждается при получении автоматически и будет удалено из очереди независимо от как обработано сообщение получателем
    • exclusive – эксклюзивное подключение
    • priority – приоритет получателя

Сервер вернет consumerTag, необходимый для отмены приема сообщений в будущем. Null вернется для отмененных сообщений.

Ограничение на прием

Количество не подтвержденных сообщений которых может получить получатель.

Взято с – https://gist.github.com/kyptov/9fdfd3893823997bfeb9e8a797bb3260

Добавить комментарий

Ваш e-mail не будет опубликован. Обязательные поля помечены *

Этот сайт использует Akismet для борьбы со спамом. Узнайте как обрабатываются ваши данные комментариев.