Расширенный протокол очереди сообщений - Advanced Message Queuing Protocol

В Расширенный протокол очереди сообщений (AMQP) является открытый стандарт прикладной уровень протокол для промежуточное ПО, ориентированное на сообщения. Определяющими особенностями AMQP являются ориентация сообщений, организация очередей, маршрутизация (включая точка-точка и опубликовать и подписаться ), надежность и безопасность.[1]

AMQP предписывает поведение поставщика сообщений и клиента в той степени, в которой реализации от разных поставщиков совместимый, так же, как SMTP, HTTP, FTP и т. д. создали совместимые системы. Предыдущие стандартизации промежуточное ПО произошли на уровне API (например, JMS ) и были сосредоточены на стандартизации взаимодействия программистов с различными реализациями промежуточного программного обеспечения, а не на обеспечении взаимодействия между несколькими реализациями.[2] В отличие от JMS, который определяет API и набор поведений, которые должна обеспечивать реализация обмена сообщениями, AMQP - это протокол проводного уровня. Протокол проводного уровня - это описание формата данных, которые передаются по сети в виде транслировать из байты. Следовательно, любой инструмент, который может создавать и интерпретировать сообщения, соответствующие этому формату данных, может взаимодействовать с любым другим совместимым инструментом независимо от языка реализации.

Обзор

AMQP - это двоичный, протокол прикладного уровня, предназначенный для эффективной поддержки широкого спектра приложений обмена сообщениями и шаблонов связи. Он обеспечивает контроль потока,[3] коммуникация, ориентированная на сообщения, с гарантиями доставки сообщений, такими как максимум один раз (где каждое сообщение доставляется один раз или никогда), Хотя бы один раз (где каждое сообщение обязательно будет доставлено, но может быть доставлено несколько раз) и ровно один раз (когда сообщение обязательно будет приходить только один раз),[4] и аутентификация и / или шифрование на основе SASL и / или TLS.[5] Он предполагает наличие базового надежного протокола транспортного уровня, такого как Протокол управления передачей (TCP).[6]

Спецификация AMQP определяется на нескольких уровнях: (i) система типов, (ii) симметричный асинхронный протокол для передачи сообщений от одного процесса к другому, (iii) стандартный расширяемый формат сообщения и (iv) набор стандартизированных, но расширяемых «возможностей обмена сообщениями».

История

AMQP был создан в 2003 году Джоном О'Хара в JPMorgan Chase в Лондон.[1][7] AMQP задумывался как открытое совместное усилие. Первоначальный дизайн был разработан JPMorgan Chase с середины 2004 г. до середины 2006 г. iMatix Corporation разработать брокер C и документацию по протоколу. В 2005 году JPMorgan Chase обратился к другим компаниям с предложением сформировать рабочую группу, в которую вошли Cisco Systems, IONA Technologies, iMatix, Красная шляпа, и Команда по внедрению стандартов инновационного рабочего процесса транзакций (КРУТИТЬ). В том же году JPMorgan Chase в партнерстве с Red Hat создал Apache Qpid изначально на Java, а вскоре после C ++. Независимо, RabbitMQ был разработан в Erlang компанией Rabbit Technologies, а затем Microsoft и StormMQ реализации.

Рабочая группа выросла до 23 компаний, в том числе Банк Америки, Barclays, Cisco Systems, Credit Suisse, Deutsche Börse, Голдман Сакс, HCL Technologies Ltd, Программное обеспечение Progress, Программное обеспечение IIT, INETCO Systems Limited, Informatica (в том числе 29 West), JPMorgan Chase, Корпорация Майкрософт, мои-каналы, Novell, Красная шляпа, Software AG, Системы утешения, StormMQ, Tervela Inc., TWIST Process Innovations ltd, VMware (которая приобрела Rabbit Technologies) и WSO2.

В августе 2011 года рабочая группа AMQP объявила о своей реорганизации в ОАЗИС членский раздел.[8]

AMQP 1.0 был выпущен рабочей группой AMQP 30 октября 2011 года на конференции в Нью-Йорке. На мероприятии Microsoft, Red Hat, VMware, Apache, INETCO и IIT Software продемонстрировали программное обеспечение, работающее с этим протоколом, в ходе демонстрации совместимости. На следующий день, 1 ноября 2011 г., формирование ОАЗИС Объявлен технический комитет[9] для продвижения этого внесла AMQP версии 1.0 через процесс международных открытых стандартов. Первый проект OASIS был выпущен в феврале 2012 года.[10] изменения по сравнению с опубликованными Рабочей группой ограничены редакциями для большей ясности (без функциональных изменений). Второй проект был выпущен на публичное рассмотрение 20 июня (снова без функциональных изменений).[11] а AMQP был утвержден в качестве стандарта OASIS 31 октября 2012 года.[12]

OASIS AMQP был утвержден для выпуска в качестве международного стандарта ISO и IEC в апреле 2014 года.[13] Голосование за AMQP 1.0 было проведено Объединенным техническим комитетом по информационным технологиям (JTC1) Международной организации по стандартизации (ISO) и Международной электротехнической комиссией (IEC). Утвержденному представлению OASIS AMQP присвоено обозначение ISO / IEC 19464.

Предыдущие версии AMQP: 0-8, опубликовано в июне 2006 г., 0-9, опубликовано в декабре 2006 г., 0-10, опубликовано в феврале 2008 г.[14] и 0-9-1, опубликованные в ноябре 2008 г. Эти более ранние выпуски значительно отличаются от спецификации 1.0.[15][16]

Хотя AMQP зародился в индустрии финансовых услуг, он в целом применим к широкому кругу промежуточное ПО проблемы.

Описание AMQP 1.0

Система типов

AMQP определяет самоописывающий схема кодирования, обеспечивающая совместное представление широкого диапазона обычно используемых типов. Это также позволяет печатать данные аннотированный с дополнительным смыслом,[17] например, конкретное строковое значение может быть аннотировано, чтобы его можно было понять как URL. Аналогичным образом значение карты, содержащее пары «ключ-значение» для «имени», «адреса» и т. Д., Может быть аннотировано как представление типа «клиент».

Система типов используется для определения формата сообщения, позволяющего выражать и понимать стандартные и расширенные метаданные обрабатывающими объектами. Он также используется для определения примитивов связи, посредством которых сообщения обмениваются между такими объектами, то есть AMQP каркасные тела.

Перформативы и протокол связи

Базовая единица данных в AMQP - это Рамка. Определены девять тел кадров AMQP, которые используются для инициирования, управления и прерывания передачи сообщений между двумя одноранговыми узлами. Это:

  • Открой связь)
  • начать ( сессия)
  • прикрепить ( связь)
  • передача
  • поток
  • расположение
  • отсоединить ( связь)
  • конец ( сессия)
  • закройте связь)

В протокол связи лежит в основе AMQP.

An прикреплять тело кадра отправляется, чтобы инициировать новую ссылку; а отделить снести ссылку. Ссылки могут быть установлены для получения или отправки сообщений.

Сообщения отправляются через установленный связь с использованием передача Рамка. Сообщения по ссылке текут только в одном направлении.

Переводы подлежат кредитной схеме управления потоком, управляемой с использованием поток кадры. Это позволяет процессу защитить себя от перегрузки из-за слишком большого объема сообщений или чего-то еще, просто чтобы ссылка для подписки могла извлекать сообщения по мере необходимости.[18]

Каждое переданное сообщение в конечном итоге должно быть поселился. Расчет гарантирует, что отправитель и получатель согласовывают состояние перевода, обеспечивая гарантии надежности. Изменения в состоянии и расчетах по передаче (или группе переводов) передаются между одноранговыми узлами с помощью расположение Рамка. Таким образом могут быть обеспечены различные гарантии надежности: не более одного раза, не менее одного раза и ровно один раз.[19]

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

Формат сообщения

AMQP определяет как голое сообщение, та часть сообщения, которая создается приложением-отправителем. Это считается неизменным, поскольку сообщение передается между одним или несколькими процессами.

Обеспечение неизменности сообщения, отправленного приложением, позволяет подписывать сообщения из конца в конец и / или шифрование и гарантирует, что любые проверки целостности (например, хэши или переваривает ) остаются в силе. Сообщение может быть аннотировано посредниками во время передачи, но любые такие аннотации хранятся отдельно от неизменяемых голое сообщение. Аннотации могут быть добавлены до или после простого сообщения.

В заголовок представляет собой стандартный набор аннотаций, связанных с доставкой, которые могут быть запрошены или указаны для сообщения и включают время существования, надежность и приоритет.[20]

Само пустое сообщение структурировано как необязательный список стандартных свойств (идентификатор сообщения, идентификатор пользователя, время создания, ответ, тема, идентификатор корреляции, идентификатор группы и т. Д.), Необязательный список свойств, специфичных для приложения (т. Е. Расширенные свойства) и тело, которое AMQP называет данными приложения.[21]

Свойства указываются в системе типов AMQP, как и аннотации. Данные приложения могут быть любой формы и в любой кодировке по выбору приложения. Один из вариантов - использовать систему типов AMQP для отправки структурированных данных с самоописанием.

Возможности обмена сообщениями

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

Ключевой категорией являются узлы, используемые в качестве место встречи между отправителями и получателями сообщений (например, очереди или же темы). В спецификации AMQP такие узлы называются узлы распределения и кодифицирует некоторые общие модели поведения.[22]

Это включает в себя:

  • некоторые стандартные результаты для передач, посредством которых получатели сообщений могут, например, принимать или отклонять сообщения [23]
  • механизм для указания или запроса одного из двух основных шаблонов распределения, конкурирующих и неконкурирующих потребителей, через режимы распределения двигаться и копировать соответственно [24]
  • возможность создавать узлы по запросу,[25][26] например для временных очередей ответов
  • возможность уточнения набора интересующих получателя сообщений с помощью фильтров [27]

Хотя AMQP можно использовать в простых одноранговых системах, определение этой структуры для возможностей обмена сообщениями дополнительно обеспечивает взаимодействие с посредниками обмена сообщениями (брокерами, мостами и т. Д.) В более крупных и богатых сетях обмена сообщениями. Указанная структура охватывает базовое поведение, но позволяет развиваться расширениям, которые могут быть далее кодифицированы и стандартизированы.

Реализации

Реализации брокера AMQP 1.0

Реализации брокера AMQP до версии 1.0

Технические характеристики

Версия протокола AMQP 1.0 является текущей версией спецификации. Он фокусируется на основных функциях, которые необходимы для взаимодействия в масштабе Интернета. Он содержит менее явную маршрутизацию, чем предыдущие версии, поскольку основные функции должны быть строго стандартизированы в первую очередь. Совместимость AMQP 1.0 была более тщательно протестирована с большим количеством разработчиков, чем предыдущие версии.[33]

Веб-сайт AMQP содержит Спецификация OASIS для версии 1.0.

Более ранние версии AMQP, опубликованные до выпуска 1.0 (см. Историю выше) и значительно отличающиеся от него, включают:

  • AMQP 0-9-1, у которого есть клиенты, доступные "для многих популярных языков программирования и платформ"[34]
  • AMQP 0–10

Сопоставимые характеристики

Это известные спецификации открытого протокола, которые охватывают то же или подобное пространство, что и AMQP:

Служба сообщений Java (JMS), часто сравнивают с AMQP. Однако JMS - это спецификация API (часть Java EE спецификация), которая определяет, как реализованы производители и потребители сообщений. JMS не гарантирует взаимодействия между реализациями, а JMS-совместимый система обмена сообщениями при использовании может потребоваться развернуть как на клиенте, так и на сервере. С другой стороны, AMQP - это спецификация протокола на уровне проводов. Теоретически AMQP обеспечивает взаимодействие, поскольку на стороне клиента и сервера может быть развернуто различное программное обеспечение, совместимое с AMQP. Обратите внимание, что, как и HTTP и XMPP, AMQP не имеет стандартного API.

Смотрите также

Рекомендации

  1. ^ а б О'Хара, Дж. (2007). «К промежуточному программному обеспечению товарного предприятия» (PDF). Очередь ACM. 5 (4): 48–55. Дои:10.1145/1255421.1255424.
  2. ^ Виноски, С. (2006). «Расширенный протокол очереди сообщений» (PDF). Интернет-вычисления IEEE. 10 (6): 87–89. Дои:10.1109 / MIC.2006.116.
  3. ^ «OASIS AMQP версия 1.0, разделы 2.6.7–2.6.8». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  4. ^ «OASIS AMQP версия 1.0, разделы 2.6.12-2.6.13». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  5. ^ «OASIS AMQP версия 1.0, раздел 5.1». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  6. ^ «OASIS AMQP версия 1.0, раздел 2.1». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  7. ^ Хинтьенс, Питер (7 февраля 2006 г.). "Предыстория проекта AMQ, авторы". iMatix Corporation. Получено 18 февраля 2018.
  8. ^ «Переход рабочей группы AMQP в членскую секцию OASIS». Архивировано из оригинал 16 апреля 2012 г.. Получено 28 января 2012.
  9. ^ OASIS формирует технический комитет AMQP для улучшения совместимости бизнес-сообщений в промежуточном программном обеспечении, мобильных и облачных средах
  10. ^ «30-дневная публичная проверка OASIS AMQP версии 1.0». 21 февраля 2012 г.. Получено 18 июн 2012.
  11. ^ «15-дневная публичная проверка OASIS AMQP версии 1.0». 20 июня 2012 г.. Получено 20 июн 2012.
  12. ^ «AMQP 1.0 становится стандартом OASIS». 31 октября 2012 г.. Получено 1 ноября 2012.
  13. ^ «Информационные технологии - спецификация Advanced Message Queuing Protocol (AMQP) v1.0». ISO / IEC 19464. ISO. Получено 1 мая 2014.
  14. ^ «Протокол заседания AMQP PMC от 13 февраля 2008 г.». AMQP PMC Минуты. Рабочая группа AMQP. Архивировано из оригинал 30 ноября 2012 г.. Получено 15 июн 2012.
  15. ^ "RabbitMQ - AMQP от 0-8 до 0-9-1". www.rabbitmq.com. Получено 12 января 2018.
  16. ^ rabbitmq-amqp1.0: поддержка AMQP 1.0 для RabbitMQ, RabbitMQ, 17 декабря 2017 г., получено 12 января 2018
  17. ^ «OASIS AMQP версия 1.0, раздел 1.1». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  18. ^ "OASIS AMQP версия 1.0, раздел 2.6.7-2.6.9". Технический комитет OASIS AMQP. Получено 18 июн 2012.
  19. ^ "OASIS AMQP версии 1.0, раздел 2.6.12-2.6.14". Рабочая группа AMQP. Получено 18 июн 2012.
  20. ^ «OASIS AMQP версия 1.0, раздел 3.2.1». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  21. ^ «OASIS AMQP версия 1.0, раздел 3.2». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  22. ^ «OASIS AMQP версия 1.0, раздел 3.3». Технический комитет OASIS AMQP. Получено 15 июн 2012.
  23. ^ «OASIS AMQP версия 1.0, раздел 3.4». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  24. ^ «OASIS AMQP версия 1.0, раздел 3.5.2». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  25. ^ «OASIS AMQP версия 1.0, раздел 3.5.3». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  26. ^ «OASIS AMQP версия 1.0, раздел 3.5.4». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  27. ^ «OASIS AMQP версия 1.0, раздел 3.5.1». Технический комитет OASIS AMQP. Получено 18 июн 2012.
  28. ^ а б осьc. «AMQP 1.0 в руководстве по протоколу служебной шины и концентраторов событий Azure». docs.microsoft.com. Получено 21 мая 2019.
  29. ^ Шубха Виджаясаратхи. «Что такое концентраторы событий Azure? - служба приема больших данных». docs.microsoft.com. Получено 21 мая 2019.
  30. ^ осьc. «Обзор AMQP 1.0 в служебной шине Azure». docs.microsoft.com. Получено 21 мая 2019.
  31. ^ "Solace PubSub +". solace.com.
  32. ^ https://web.archive.org/web/20130914045254/http://qpid.apache.org/releases/qpid-0.22/index.html
  33. ^ «Статус версий AMQP до 1.0». AMQP сайт. Получено 28 мая 2014.
  34. ^ «Описание модели AMQP 0-9-1». VMWare, Inc. Получено 1 ноября 2012.

внешняя ссылка