Wondershare EdrawMind
Галерея диаграмм связей Очередь сообщений Alibaba Cloud
- 2
Очередь сообщений Alibaba Cloud
Подробное описание облачной очереди сообщений Alibaba RocketMQ, облачной очереди сообщений RocketMQ, облачной очереди сообщений RabbitMQ, облачной очереди сообщений Kafka и облачной очереди сообщений MQTT.
Отредактировано в 2024-01-20 09:44:44
Очередь сообщений Alibaba Cloud
- Рекомендовано вам
- Структура
Очередь сообщений Alibaba Cloud
Облачная очередь сообщений RocketMQ
Позиционирование продукта
Версия RocketMQ Cloud Message Queue — это типичный продукт промежуточного программного обеспечения с распределенной архитектурой, использующий асинхронную связь и модель передачи сообщений «публикация-подписка».
Продукт обладает преимуществами асинхронной связи, простой топологией системы и слабой связью в восходящем и нисходящем направлениях. Он в основном используется в сценариях асинхронной развязки, сглаживания пиков трафика и заполнения впадин.
Для синхронных каналов, требующих возврата результатов вызовов в реальном времени, рекомендуется использовать решение для вызовов RPC.
Модель домена версии RocketMQ очереди сообщений
Как показано на рисунке, жизненный цикл сообщений в версии Cloud Message Queue RocketMQ в основном разделен на три части: создание сообщений, хранение сообщений и потребление сообщений.
производство сообщений
Производитель — это работающий объект, используемый для генерации сообщений в версии RocketMQ Cloud Message Queue. Обычно он интегрируется выше канала бизнес-вызова. Производители легкие, анонимные и безличные.
Хранение сообщений
Тема: Контейнер группировки для передачи и хранения сообщений в Cloud Message Queue RocketMQ. Тема внутренне состоит из нескольких очередей. Хранение и горизонтальное расширение сообщений фактически реализованы через очереди внутри темы.
Очередь (MessageQueue): фактический модульный контейнер для передачи и хранения сообщений в очереди сообщений RocketMQ Cloud, аналогичный разделам в Kafka. Облачная очередь сообщений RocketMQ использует бесконечную структуру очереди с характеристиками потоковой передачи для хранения сообщений, а сообщения имеют характеристики последовательного хранения в очереди.
Сообщение: наименьшая единица передачи версии Cloud Message Queue для RocketMQ. Сообщения неизменяемы и становятся неизменяемыми после первоначальной отправки и завершения хранения.
Потребление сообщений
ConsumerGroup: независимая группа идентификации потребителей, определенная в модели публикации-подписки Cloud Message Queue RocketMQ, используемая для единообразного управления несколькими потребителями (потребителями), работающими внизу. Несколько потребителей одной и той же группы потребителей должны поддерживать согласованность своей логики и конфигурации потребления и совместно делиться сообщениями, на которые подписана группа потребителей, для достижения горизонтального расширения возможностей потребления.
Потребитель: действующий объект версии Cloud Message Queue для RocketMQ, который потребляет сообщения. Обычно он интегрируется после канала бизнес-вызова. Потребители должны быть отнесены к группе потребителей.
Подписка: настройка правил для фильтрации сообщений, повторных попыток и прогресса потребления в модели публикации и подписки Cloud Message Queue RocketMQ. Отношения подписки управляются на уровне группы потребителей. Группа потребителей управляет тем, как потребители в указанной группе потребителей реализуют фильтрацию сообщений, повторную попытку потребления, восстановление хода потребления и т. д. путем определения отношения подписки.
Введение в методы общения
Согласно идее распределенной системной архитектуры, сложные системы делятся на несколько независимых подмодулей, таких как микросервисные модули. В настоящее время необходимо учитывать удаленную связь между подмодулями. Типичные режимы связи делятся на следующие два типа: синхронный удаленный вызов RPC и асинхронный метод связи на основе агента промежуточного программного обеспечения;
Модель синхронного вызова RPC
В рамках модели синхронного вызова RPC связь между различными системами осуществляется напрямую. Каждый запрос отправляется непосредственно от вызывающего абонента к вызываемому, а затем вызываемый должен немедленно вернуть результат ответа вызывающему абоненту, чтобы определить, является ли результат вызова. успешный.
Модель асинхронной связи
В режиме асинхронной передачи сообщений подсистемы соединяются напрямую без сильной связи. Вызывающей стороне необходимо только преобразовать запрос в асинхронное событие (сообщение) и отправить его промежуточному агенту. Если передача прошла успешно, происходит вызов асинхронного канала. считается завершенным, а оставшееся. Рабочий промежуточный агент будет отвечать за надежное уведомление о событии нижестоящей вызывающей системы, чтобы гарантировать завершение выполнения задачи. Промежуточный агент обычно представляет собой промежуточное программное обеспечение для сообщений.
Преимущества асинхронной связи заключаются в следующем:
Топология системы проста
Поскольку вызывающий и вызываемый абоненты взаимодействуют с промежуточным агентом единым образом, система имеет звездообразную структуру, ее легко обслуживать и управлять.
Слабая связь на входе и выходе
Вышестоящая и нижестоящая системы слабо связаны, структура более гибкая, а за буферизацию и асинхронное восстановление отвечает промежуточный агент. Восходящие и нисходящие системы можно модернизировать и изменять независимо, не затрагивая друг друга.
Сглаживание пиков производительности и заполнение впадин
Промежуточные прокси-серверы на основе сообщений часто обладают мощными возможностями буферизации и формирования трафика, поэтому они не перегружают нисходящий поток при наступлении пиков бизнес-трафика.
Введение в модель передачи сообщений
Основными моделями передачи промежуточного программного обеспечения сообщений являются в основном модель «точка-точка» и модель публикации-подписки.
одноранговая модель
Модель «точка-точка» также называется моделью очереди и имеет следующие характеристики:
Анонимность потребления. Единственным идентификатором для восходящей и нисходящей передачи сообщений является очередь. Потребители нисходящего потока не могут объявлять независимые идентификаторы при получении сообщений из очереди.
Индивидуальная связь: исходя из характеристик анонимности потребления, даже если имеется несколько последующих потребителей, они не имеют собственных независимых идентификаторов. Поэтому каждое сообщение в общей очереди будет обрабатываться только одним потребителем. Таким образом, модель «точка-точка» может обеспечить только связь «один-к-одному».
модель публикации-подписки
Модель публикации-подписки имеет следующие характеристики:
Независимость потребления. По сравнению с методом анонимного потребления модели очереди все потребители в модели публикации-подписки имеют идентификатор, который обычно называется группой подписки (отношения подписки). Различные группы подписки независимы друг от друга и не влияют друг на друга. друг друга.
Связь «один ко многим». Благодаря независимому дизайну удостоверений сообщения в рамках одной темы могут обрабатываться несколькими группами подписок, и каждая группа подписок может получать полный объем сообщений. Таким образом, модель публикации-подписки может обеспечить связь «один ко многим».
Сравнение моделей трансмиссии
Модель «точка-точка» и модель «публикация-подписка» имеют свои преимущества. Модель «точка-точка» проще, а модель «публикация-подписка» более масштабируема.
Модель передачи, используемая Cloud Message Queue RocketMQ, представляет собой модель публикации-подписки, поэтому она также имеет характеристики модели публикации-подписки.
Облачная очередь сообщений Kafka
Преимущества продукта
Предоставляйте полностью управляемые услуги для Apache Kafka с открытым исходным кодом, чтобы решить проблемы продуктов с открытым исходным кодом. С версией Cloud Message Queue Kafka вам нужно сосредоточиться только на развитии бизнеса без развертывания, эксплуатации и обслуживания. По сравнению с Apache Kafka с открытым исходным кодом версия Cloud Message Queue Kafka дешевле, более эластична и надежна.
Экология применения
Он имеет богатую экосистему приложений, в основном включающую следующие аспекты:
Область больших данных: анализ поведения веб-сайтов, агрегирование журналов, мониторинг приложений, потоковая обработка данных, онлайн- и офлайн-анализ данных и другие области.
Интеграция данных: импортируйте сообщения в автономные хранилища данных, такие как MaxCompute, OSS, RDS, Hadoop и HBase.
Интеграция обработки данных: интеграция с StreamCompute, E-MapReduce, Spark, Storm и другими механизмами.
архитектура продукта
Облачная очередь сообщений, версия Kafka
структура системы
Режиссер
Отправляйте сообщения Kafka Broker версии Cloud Message Queue Kafka в режиме push. Отправляемые сообщения могут представлять собой посещения страниц веб-сайта, журналы сервера или информацию о системных ресурсах, связанную с процессором и памятью.
Кафка Брокер
Сервер, используемый для хранения сообщений. Kafka Broker поддерживает горизонтальное расширение. Чем больше узлов Kafka Broker, тем выше пропускная способность кластера Cloud Message Queue Kafka.
Группа
Подпишитесь и получайте сообщения от брокера версий Cloud Message Queue Kafka в режиме запроса.
Работник зоопарка
Управляйте конфигурацией кластера, выбирайте ведущие разделы и выполняйте балансировку нагрузки при смене группы.
Облачная очередь сообщений, версия Kafka
Модель публикации/подписки версии Cloud Message Queue Kafka
Соответствующее отношение между группой и темой — N:N, то есть группа может подписаться на несколько тем одновременно, а на тему также могут одновременно подписаться несколько групп.
Хотя на тему могут подписаться несколько групп одновременно, сообщения темы могут быть использованы только любым Потребителем в той же группе.
Преимущества продукта
Готов из коробки
Совместимость с открытым исходным кодом:
Cloud Message Queue Kafka Edition на 100% совместим с Apache Kafka с открытым исходным кодом. Вы можете напрямую использовать клиент Apache Kafka с открытым исходным кодом для связи с Cloud Message Queue Kafka Edition. Версия Cloud Message Queue Kafka в настоящее время поддерживает версии с открытым исходным кодом 0.10.x~2.6.x.
Бесшовная миграция:
Версия Cloud Message Queue Kafka основана на существующей экосистеме Apache Kafka с открытым исходным кодом, и вы можете перейти в облако без каких-либо изменений кода.
Не требует эксплуатации и обслуживания, легко наблюдать
HouseKeeping (компонент проверки работоспособности): используется для проверки основных каналов версии Cloud Message Queue Kafka во время выполнения. Он каждую минуту выполняет комплексное сканирование и диагностику кластера и может выдавать сигналы тревоги при неработоспособном состоянии. В то же время общий отчет о проверке будет предоставляться персоналу по эксплуатации и техническому обслуживанию Alibaba Cloud каждый день, чтобы облегчить мониторинг состояния работоспособности системы версий Cloud Message Queue Kafka.
Бизнес-мониторинг и оповещение: каждая группа потребителей может настроить мониторинг и оповещение для накопления сообщений, чтобы помочь вам вовремя обнаружить проблемы.
OpenAPI: версия Cloud Message Queue Kafka предоставляет вам полный набор управления и контроля OpenAPI для реализации ряда функций управления ресурсами, эксплуатации и обслуживания.
Богатая экосистема данных
Предоставляет полностью управляемые, не требующие операций компоненты обработки данных, поддерживает гибкое программирование функций и легко и гибко обрабатывает данные.
Поддержка соединителя для подключения массивных облачных продуктов и экологических продуктов для работы с большими данными, позволяющих легко реализовать интеграцию и расчет данных.
Доступен в очень большом формате
Глубоко оптимизируйте ядро, чтобы устранить проблемы с производительностью разделов тысячного уровня версии с открытым исходным кодом и поддерживать производительность разделов десяти тысяч уровней без потерь.
Поддерживает расширение второго уровня.
Поддерживает запись трафика до 2 ГБ.
Высокая доступность
Команда разработчиков продуктов для обмена сообщениями Alibaba Cloud и оптимизации производительности еще больше оптимизировала слабые места продуктов с открытым исходным кодом, чтобы предоставить вам более качественные услуги.
Сохранение данных: профессиональная команда обеспечивает более высокую доступность, а постоянство сообщений помещается в очередь сообщений. Высокая надежность данных и высокая доступность услуг.
Высокая пропускная способность: даже при накоплении большого количества сообщений он всегда может поддерживать
Высокая пропускная способность кластера версий Cloud Message Queue Kafka.
Десятки тысяч тем: поддерживает одновременное чтение и запись десятков тысяч тем, всегда поддерживая
Высокая гарантия SLA
Поддерживает гарантии оптимизации записи в экстремальных сценариях, таких как обновление в оттенках серого, обновление/холодных данных и т. д.
Полностью автоматическая система контроля, эксплуатации и технического обслуживания гарантирует доступность обслуживания на уровне 99,9% и надежность данных на уровне 99,999999%.
Безопасность данных
Предоставляет такие функции, как механизмы аутентификации и авторизации, децентрализация пользователей и защита безопасности на уровне предприятия.
Управление разрешениями: полностью поддерживает учетные записи Alibaba Cloud и пользователей оперативной памяти, черные и белые списки, STS и другие функции, а также реализует услуги авторизации для учетных записей Alibaba Cloud и пользователей оперативной памяти, а также перекрестные учетные записи между предприятиями.
Безопасность доступа: на основе системы учетных записей Alibaba Cloud механизм SASL используется для аутентификации личности пользователя, а SSL используется для шифрования канала передачи, чтобы гарантировать, что данные не будут украдены или подделаны во время процесса передачи, обеспечивая безопасность ваши данные.
Alibaba Cloud VPC: Помимо доступа к общедоступной сети, версия Cloud Message Queue Kafka также поддерживает VPC частной сети. Вы можете полностью контролировать свою собственную частную сеть, например выбирать диапазоны IP-адресов, настраивать таблицы маршрутизации и шлюзы и т. д. Вы можете использовать ресурсы Alibaba Cloud, такие как облачные серверы, версии облачной базы данных RDS, а также балансировку нагрузки в вашей собственной определенной частной сети.
Оптимизация движка с открытым исходным кодом
По сравнению с Apache Kafka с открытым исходным кодом, мощный механизм обработки поддерживает десятки тысяч тем с высокой степенью одновременного чтения и записи, масштабированием второго уровня и надежным облачным хранилищем, что обеспечивает очень экономичный выбор, а также обеспечивает компоненты проверки работоспособности и бизнеса; Функции мониторинга и сигнализации, помогающие своевременно и эффективно обнаруживать и устранять проблемы.
Сценарии применения
Отслеживание активности сайта
Cloud Message Queue Версия модели публикации/подписки Kafka позволяет собирать данные об активности веб-сайта (например, регистрация, вход в систему, пополнение счета, оплата, покупка) в режиме реального времени, публиковать сообщения по различным темам в соответствии с типами бизнес-данных, а затем использовать реальные -доставка сообщений подписки в реальном времени, использование потока сообщений для обработки в реальном времени, мониторинга в реальном времени или загрузка его в автономные системы хранилищ данных, такие как Hadoop и MaxCompute, для автономной обработки.
Версия Cloud Message Queue Kafka имеет следующие преимущества для отслеживания активности веб-сайта:
Высокая пропускная способность: информация о поведении, генерируемая пользователями веб-сайта, относительно велика и требует высокой пропускной способности для ее поддержки.
Эластичное расширение: активность веб-сайта приводит к увеличению объема поведенческих данных, а облачная платформа может быстро расширяться по требованию.
Анализ больших данных: его можно подключить к механизмам обработки данных в реальном времени, таким как Storm и Spark, а также к автономным системам хранения данных, таким как Hadoop.
Агрегация журналов
Версия Cloud Message Queue Kafka может обеспечить более высокую сохранность данных и более короткое время сквозного ответа при высокой производительности. Эта характеристика Cloud Message Queue Kafka делает ее подходящей для использования в качестве центра сбора журналов. Cloud Message Queue Kafka Edition игнорирует детали файлов и может абстрагировать данные журналов нескольких хостов или приложений в потоки сообщений журналов или событий и отправлять их асинхронно в кластер Cloud Message Queue Kafka Edition, тем самым достигая очень низкого RT. Клиент версии Cloud Message Queue Kafka может отправлять сообщения пакетами и сжимать сообщения практически без снижения производительности для производителей. Потребители могут использовать автономное складское хранилище, такое как Hadoop и MaxCompute, а также системы онлайн-анализа в реальном времени, такие как Strom и Spark, для выполнения статистического анализа журналов.
Версия Cloud Message Queue Kafka имеет следующие преимущества для агрегации данных:
Разделение приложения и анализа: постройте мост между системой приложения и системой анализа и отделите связь между ними.
Высокая масштабируемость: он обладает высокой масштабируемостью, то есть при увеличении объема данных его можно быстро расширить по горизонтали за счет добавления узлов.
Система онлайн- или автономного анализа: поддерживает систему онлайн-анализа в реальном времени и систему автономного анализа, подобную Hadoop.
обработка данных
Во многих областях, таких как анализ тенденций фондового рынка, измерение и контроль метеорологических данных, а также анализ поведения пользователей веб-сайтов, из-за быстрого сбора данных в режиме реального времени и большого объема данных сложно собрать эти данные унифицированным образом и хранить их в базе данных для обработки. В результате традиционная архитектура обработки данных не может удовлетворить потребности. В отличие от традиционной архитектуры,
Появление версии облачной очереди сообщений Kafka и механизмов обработки данных, таких как Storm, Samza и Spark, призвано лучше решать проблемы, возникающие при обработке этого типа данных. Модель обработки данных может реализовывать обработку данных во время потока данных. Собирайте и обрабатывайте данные в реальном времени, выполняйте расчеты и анализ в соответствии с бизнес-требованиями и, наконец, сохраняйте или распределяйте результаты по необходимым компонентам.
Версия Cloud Message Queue Kafka имеет следующие преимущества при обработке данных:
Потоковые данные: собирайте и обрабатывайте данные в режиме реального времени во время потока данных, а также выполняйте расчеты и анализ в соответствии с потребностями бизнеса.
Высокая масштабируемость: из-за высокой скорости генерации данных и большого объема данных требуется высокая масштабируемость.
Механизм обработки данных: может быть подключен к Storm, Samza, Spark, EMR, Blink, StreamCompute и другим продуктам Alibaba Cloud с открытым исходным кодом.
Центр передачи данных
За последние 10 лет или около того появились специальные системы, такие как хранилище KV (HBase), поиск (Elasticsearch), потоковая обработка (Storm, Spark, Samza) и базы данных временных рядов (OpenTSDB). Эти системы были созданы с единственной целью, а их простота упрощает и делает более экономичным создание распределенных систем на обычном оборудовании. Часто один и тот же набор данных необходимо ввести в несколько специализированных систем. Например, когда журналы приложений используются для автономного анализа журналов, поиск отдельных записей журналов также нецелесообразен. Очевидно, что непрактично создавать независимые рабочие процессы для сбора каждого типа данных и затем импортировать их в свои собственные выделенные системы с использованием облачного обмена сообщениями. Версия Kafka очереди служит концентратором передачи данных, и одни и те же данные можно импортировать в разные специализированные системы.
Версия Cloud Message Queue Kafka имеет следующие преимущества в качестве концентратора передачи данных:
Хранилище высокой емкости: возможность хранить данные большой емкости на коммерческом оборудовании для создания распределенной системы с горизонтальным масштабированием.
Модель потребления «один ко многим»: модель публикации/подписки, которая поддерживает использование одного и того же набора данных несколько раз одновременно.
Поддерживает как обработку в реальном времени, так и пакетную обработку: поддерживает сохранение локальных данных и кэш страниц, а также может одновременно передавать сообщения потребителям в режиме реального времени и в пакетном режиме без потери производительности.
Облачная очередь сообщений RabbitMQ
Сравнение открытого исходного кода
Сравнивая Cloud Message Queue RabbitMQ Edition и RabbitMQ с открытым исходным кодом по трем аспектам: производительность, стабильность и функциональность, Cloud Message Queue RabbitMQ Edition имеет больше преимуществ.
Особенности продукта
Совместим с RabbitMQ с открытым исходным кодом, обеспечивает полную поддержку эксплуатации и обслуживания, а также поддерживает несколько типов сообщений.
Ограничения использования
Существуют ограничения на кластеры, вызовы интерфейса и символы. При использовании версии Cloud Message Queuing RabbitMQ будьте осторожны и не превышайте соответствующие ограничения, чтобы избежать программных исключений.
Преимущества продукта
Гибкий и простой в использовании
Готов из коробки
Полностью совместим со стандартными протоколами, полностью совместим с сообществом открытого исходного кода RabbitMQ и быстро перенесен в облако.
Полностью управляемый сервис
Служба версий Cloud Message Queue RabbitMQ — это облачная служба обмена сообщениями, которая не требует развертывания, эксплуатации и обслуживания. Опираясь на профессиональную команду автоматизированной эксплуатации и обслуживания Alibaba Cloud, многомерные проверки основных каналов выполняются на втором и минутном уровне, предоставляются подробные отчеты о диагностике состояния, а также выполняются сигналы тревоги и своевременное восстановление в случае неработоспособных состояний, чтобы обеспечить доступность услуг и бизнес. непрерывность.
Высокая доступность
Предоставьте четкое соглашение об уровне обслуживания для обеспечения высокой доступности в нескольких зонах доступности. Даже если весь компьютерный зал недоступен, услуги обмена сообщениями могут предоставляться в обычном режиме.
Распределенное развертывание кластера, сервисные узлы не имеют состояния и не имеют единой точки. Даже если один узел недоступен, запросите аварийное переключение на другие узлы, чтобы обеспечить нормальное предоставление служб сообщений.
Расширение функций
Задержанное сообщение
Поддерживает отложенные сообщения, обеспечивая точность второго уровня и отсутствие ограничений «первым пришел — первым обслужен».
Он прост и удобен в использовании. Вам нужно всего лишь установить один параметр в коде, чтобы решить проблемы очереди без задержки RabbitMQ с открытым исходным кодом.
Высокоточная поддержка, самая короткая может быть с точностью до второго уровня, а самая длинная может длиться 1 день.
Высокая производительность, производительность соответствует обычным сообщениям.
Множественные копии избыточных данных обеспечивают восстановление сообщений.
повтор сообщения
Повторные попытки в течение одной минуты, до 16 повторных попыток.
Сообщения, число повторных попыток которых превышает максимальное, попадают в очередь недоставленных сообщений. Сообщения о недоставленных письмах можно запросить и экспортировать.
Мертвое письмоОбмен
Расширенный обмен недоставленными письмами не только поддерживает сообщения с отрицательными ответами, но также поддерживает сообщения, которые не удалось повторить, для автоматического входа в обмен недоставленными письмами, чтобы гарантировать, что сообщения не будут потеряны.
Супер производительность
Верхний предел производительности платформы
Поддерживает миллионы очередей, горизонтальное расширение обеспечивает линейный рост производительности, при этом производительность не имеет ограничений по параллелизму.
Расширение одной очереди
Устраните узкое место в производительности одиночной очереди RabbitMQ, поддержите горизонтальное расширение одиночной очереди и не имейте ограничений производительности при параллельном выполнении.
Эластичное масштабирование
Он обладает высокой масштабируемостью, линейным повышением производительности, эластичным расширением и сжатием в соответствии с потребностями бизнеса и прозрачен для пользователей.
Массивное накопление
В случае массового накопления сообщений всегда сохраняется высокая производительность, не влияя на нормальные службы кластера.
Производители и потребители сообщений изолированы, чтобы обеспечить высокую степень параллелизма производителей и стабильное потребление потребителями.
Безопасный и надежный
Детализация разрешений
Детальный контроль разрешений для экземпляров, виртуальных хостов, очередей и обмена, а также безопасный контроль доступа для каждого запроса сообщения.
Мастер и субсчета
Комплексная интеграция с основными и субсчетами Alibaba Cloud RAM, черными и белыми списками, STS и другими функциями.
Шифрованная передача
Поддерживает протокол шифрования передачи TLS.
Сценарии применения
Асинхронная развязка
Его можно использовать для связи между различными микросервисами после того, как одно приложение разобрано на микросервисы. Преимущество разделения приложений заключается в том, что итерации различных приложений больше не зависят друг от друга, а преимущество асинхронной связи заключается в том, что данные больше не требуют немедленной обработки. Асинхронная развязка может эффективно сократить длину канала передачи данных и повысить эффективность обработки данных.
сглаживание пиков и заполнение впадин
Когда крупномасштабные события вызывают высокие импульсы трафика, отсутствие соответствующей защиты может легко привести к перегрузке системы или даже сбою. Чрезмерные ограничения могут привести к большому количеству неудачных запросов, что повлияет на удобство работы пользователей.
Версия RabbitMQ Cloud Message Queue может срезать пики и заполнять впадины. Его высокопроизводительные возможности обработки сообщений позволяют обрабатывать импульсы трафика без перегрузки, обеспечивая доступность системы и одновременно улучшая взаимодействие с пользователем благодаря технологии быстрого и эффективного ответа на запросы. Его способность массового накопления сообщений гарантирует бесперебойную и стабильную работу последующих предприятий на безопасном уровне и позволяет избежать воздействия пиков трафика.
Синхронизация распределенного кэша
Большое количество одновременных обращений к базе данных может привести к увеличению времени ответа страницы. Создайте распределенный кеш с помощью версии RabbitMQ Cloud Message Queue Queue для поддержки уведомлений об изменениях данных в реальном времени, эффективного сокращения времени ответа страницы и удовлетворения больших требований к доступу для изменений.
Облачная очередь сообщений MQTT
Это легкое промежуточное программное обеспечение для обмена сообщениями, запущенное Alibaba Cloud для мобильного Интернета и Интернета вещей. Если между микросервисами обычно используется традиционное промежуточное программное обеспечение очереди сообщений, то версия MQTT Cloud Message Queue, подходящая для Интернета вещей, реализует передачу сообщений между концом и облаком и настоящую взаимосвязь всего. В этой статье представлена модель отправки и получения сообщений, преимущества продукта и сценарии применения версии Cloud Message Queue MQTT.
Основная идея
Тема
: Тема сообщения, тип сообщения первого уровня, которому производитель отправляет сообщения.
режиссер
: также известен как издатель сообщений, отвечающий за создание и отправку сообщений в Topic.
потребитель
: Также называется подписчиком сообщений и отвечает за получение и использование сообщений из Topic.
информация
: данные, отправленные производителем в Тему и окончательно переданные потребителю.
правило
Версия Cloud Message Queue MQTT — это ресурс, который обеспечивает совместимость данных с другими продуктами Alibaba Cloud.
Модель обмена сообщениями
В основном он включает в себя следующие две модели отправки и получения сообщений:
Модель взаимодействия терминала и облачного сервиса
Версия Cloud Message Queue MQTT соединяет терминал и облако для достижения двусторонней связи между устройством и облаком. Устройство может напрямую взаимодействовать с облачными бизнес-приложениями через версию Cloud Message Queue MQTT, а также обеспечивать межпродуктовую совместимость данных сообщений с другими продуктами Alibaba Cloud.
Типичными сценариями применения этой модели являются отчеты о состоянии интеллектуальных устройств или выдача инструкций для приложений облачного управления.
Терминал и модель взаимодействия терминалов
Эта модель подходит для передачи данных между мобильными приложениями или устройствами. Типичными сценариями являются два пользователя, напрямую обменивающиеся сообщениями в сценарии обмена мгновенными сообщениями, и приложение, управляющее интеллектуальными устройствами в сценарии интеллектуального устройства. В этой модели производители и потребители сообщений распределяются по терминальным устройствам и подключаются к облачной очереди сообщений версии продукта MQTT через протокол MQTT.
Основываясь на двух вышеупомянутых моделях отправки и получения сообщений, разработчиков, использующих версию Cloud Message Queue MQTT, можно разделить на две категории: терминальные и облачные.
Преимущества продукта
Бесшовная миграция
Совместим с любым SDK, который поддерживает протокол MQTT 3.1.1, поддерживает протокол WebSocket и охватывает большинство платформ и языков разработки мобильных устройств.
высокая производительность
Он поддерживает онлайн-соединения десятков миллионов устройств, миллионы одновременных сообщений, триллионы передач и распределенную архитектуру на уровне миллисекунд, отсутствие узких мест в одной точке и неограниченное горизонтальное расширение между компонентами;
Безопасный и надежный
Поддерживает контроль разрешений на уровне устройства, службу временных токенов и протокол безопасной передачи версии TLS 1.2 для обеспечения безопасности и надежности пользовательских данных.
Естественная совместимость
Обмен сообщениями между версией Cloud Message Queue MQTT и версией Cloud Message Queue RocketMQ обеспечивает двустороннюю связь между устройством и облаком, что делает ее более эффективной и надежной.
Сценарии применения
Он имеет многопротокольную, многоязычную и многоплатформенную поддержку и широко используется в области мобильного Интернета и Интернета вещей, охватывая различные сценарии применения, такие как мобильное прямое вещание, Интернет транспортных средств, финансовые платежи, умный кейтеринг и мгновенный чат.
Служба обмена сообщениями МНС
Служба сообщений MNS (Служба сообщений) — это эффективная, надежная, безопасная, удобная и эластично масштабируемая служба распределенного обмена сообщениями. Служба обмена сообщениями MNS может помочь разработчикам свободно передавать данные и сообщения уведомлений между распределенными компонентами приложения, тем самым создавая слабосвязанную систему. Служба обмена сообщениями MNS поддерживает модель очереди и модель тем.
модель очереди
Модель очереди обеспечивает высоконадежную модель потребления «один к одному» с высоким уровнем параллелизма, то есть каждое сообщение в очереди может быть использовано только определенным потребителем.
Очередь похожа на вращающийся суши-ресторан. В суши-ресторане работают несколько суши-поваров (производителей), которые готовят изысканные суши. Каждый кусок суши уникален. Клиенты (потребители) могут взять с конвейера понравившиеся суши для еды (потребления).
Преимущества продукта
Легко и просто использовать
Не требуется эксплуатация и обслуживание, нет необходимости создавать службу обмена сообщениями самостоятельно.
Легкий доступ, стандартный интерфейс HTTP RESTful.
Поддержка нескольких языков SDK, включая C, Java, C#, Python, PHP, Go и т. д., и продолжает расширяться.
Стабильный и надежный
Три копии сообщения, высокая надежность.
Высокая доступность сервиса.
Уникальный механизм обеспечивает постоянную возможность записи.
Безопасность
Многоуровневая защита и предотвращение DDoS-атак.
Механизм многопользовательской изоляции, каждый пользователь имеет независимое пространство имен.
Поддерживает предоставление различных прав доступа разным пользователям оперативной памяти.
Поддерживает доступ HTTPS и VPC.
Масштабная производительность и высокая масштабируемость
Количество очередей и емкость хранилища очередей легко масштабируются.
Масштаб услуг автоматически расширяется и становится прозрачным для пользователей.
Предоставляйте услуги в нескольких регионах по всему миру.
Быстрый и стабильный
Быстрое и прямое соединение с пользователями занимает всего 3 секунды.
Эксклюзивный канал Triple Play.
Выделенный компьютерный зал поддерживает большую пропускную способность и высокий уровень параллелизма.
Скорость поступления высокая, и она подключена к платформе переносимости номеров Министерства промышленности и информационных технологий в режиме реального времени.
Гарантия операторского уровня эксплуатации и обслуживания, мониторинг в реальном времени и автоматическое переключение.
Интимное техническое обслуживание
Постоянно расширяйте обмен примерами передового опыта.
Круглосуточная поддержка заказов.
Доступна настраиваемая поддержка на месте.