Wondershare EdrawMind
Galería de mapas mentales Cola de mensajes en la nube de Alibaba
Cola de mensajes en la nube de Alibaba
Un resumen detallado de Alibaba Cloud Message Queue RocketMQ, Cloud Message RocketMQ, Cloud Message Queue RabbitMQ, Cloud Message Queue Kafka y Cloud Message Queue MQTT.
Editado a las 2024-01-20 09:44:44,
- Breve historia del tiempo
Este es un mapa mental sobre una breve historia del tiempo. "Una breve historia del tiempo" es una obra de divulgación científica con una influencia de gran alcance. No sólo presenta los conceptos básicos de cosmología y relatividad, sino que también analiza los agujeros negros y la expansión. del universo. temas científicos de vanguardia como la inflación y la teoría de cuerdas.
- ¿Cuáles son los métodos de fijación de precios para los subcontratos de proyectos bajo el modelo de contratación general EPC
¿Cuáles son los métodos de fijación de precios para los subcontratos de proyectos bajo el modelo de contratación general EPC? EPC (Ingeniería, Adquisiciones, Construcción) significa que el contratista general es responsable de todo el proceso de diseño, adquisición, construcción e instalación del proyecto, y es responsable de los servicios de operación de prueba.
- Puntos de conocimiento que los ingenieros de Java deben dominar en cada etapa
Los puntos de conocimiento que los ingenieros de Java deben dominar en cada etapa se presentan en detalle y el conocimiento es completo, espero que pueda ser útil para todos.
Cola de mensajes en la nube de Alibaba
- Breve historia del tiempo
Este es un mapa mental sobre una breve historia del tiempo. "Una breve historia del tiempo" es una obra de divulgación científica con una influencia de gran alcance. No sólo presenta los conceptos básicos de cosmología y relatividad, sino que también analiza los agujeros negros y la expansión. del universo. temas científicos de vanguardia como la inflación y la teoría de cuerdas.
- ¿Cuáles son los métodos de fijación de precios para los subcontratos de proyectos bajo el modelo de contratación general EPC
¿Cuáles son los métodos de fijación de precios para los subcontratos de proyectos bajo el modelo de contratación general EPC? EPC (Ingeniería, Adquisiciones, Construcción) significa que el contratista general es responsable de todo el proceso de diseño, adquisición, construcción e instalación del proyecto, y es responsable de los servicios de operación de prueba.
- Puntos de conocimiento que los ingenieros de Java deben dominar en cada etapa
Los puntos de conocimiento que los ingenieros de Java deben dominar en cada etapa se presentan en detalle y el conocimiento es completo, espero que pueda ser útil para todos.
- Recomendados
- Resumen
Cola de mensajes en la nube de Alibaba
Cola de mensajes en la nube RocketMQ
Posicionamiento del producto
La versión Cloud Message Queue RocketMQ es un producto de middleware típico bajo una arquitectura distribuida, que utiliza comunicación asincrónica y un modelo de transmisión de mensajes de publicación-suscripción.
El producto tiene las ventajas de comunicación asíncrona, topología de sistema simple y acoplamiento débil ascendente y descendente. Se utiliza principalmente en escenarios de desacoplamiento asíncrono, reducción de picos de tráfico y llenado de valles.
Para enlaces sincrónicos, en escenarios donde los resultados de las llamadas deben devolverse en tiempo real, se recomienda utilizar la solución de llamadas RPC.
Modelo de dominio de versión RocketMQ de cola de mensajes
Como se muestra en la figura, el ciclo de vida de los mensajes en la versión Cloud Message Queue RocketMQ se divide principalmente en tres partes: producción de mensajes, almacenamiento de mensajes y consumo de mensajes.
producción de mensajes
El productor es una entidad en ejecución que se utiliza para generar mensajes en la versión Cloud Message Queue RocketMQ. Generalmente está integrado en sentido ascendente del enlace de llamada comercial. Los productores son ligeros, anónimos y sin identidad.
Almacenamiento de mensajes
Tema: Un contenedor de agrupación para la transmisión y almacenamiento de mensajes en Cloud Message Queue RocketMQ. El tema se compone internamente de múltiples colas. El almacenamiento y la expansión horizontal de mensajes en realidad se implementan a través de colas dentro del tema.
Cola (MessageQueue): el contenedor de unidades real para la transmisión y almacenamiento de mensajes en RocketMQ Cloud Message Queue, que es análogo a las particiones en Kafka. Cloud Message Queue RocketMQ utiliza una estructura de cola infinita con características de transmisión para almacenar mensajes, y los mensajes tienen características de almacenamiento secuencial en la cola.
Mensaje: la unidad de transmisión más pequeña de la versión RocketMQ de Cloud Message Queue. Los mensajes son inmutables y se vuelven inmutables después del envío inicial y la finalización del almacenamiento.
Consumo de mensajes
ConsumerGroup: un grupo de identidad de consumidores independiente definido en el modelo de publicación-suscripción de Cloud Message Queue RocketMQ, que se utiliza para administrar de manera uniforme varios consumidores (Consumidores) que se ejecutan en la parte inferior. Varios consumidores del mismo grupo de consumidores deben mantener su lógica y configuración de consumo consistentes y compartir conjuntamente los mensajes suscritos por el grupo de consumidores para lograr una expansión horizontal de las capacidades de consumo.
Consumidor: la entidad en ejecución de la versión RocketMQ de Cloud Message Queue que consume mensajes. Generalmente está integrada en sentido descendente del enlace de llamada comercial. Los consumidores deben estar asignados a un grupo de consumidores.
Suscripción: configuración de reglas para el filtrado de mensajes, reintentos y progreso del consumo en el modelo de publicación y suscripción de Cloud Message Queue RocketMQ. Las relaciones de suscripción se administran en la granularidad de los grupos de consumidores. Al definir las relaciones de suscripción, los grupos de consumidores controlan cómo los consumidores del grupo de consumidores especificado implementan el filtrado de mensajes, el reintento de consumo, la recuperación del progreso del consumo, etc.
Introducción a los métodos de comunicación.
Bajo la idea de una arquitectura de sistema distribuido, los sistemas complejos se dividen en múltiples submódulos independientes, como los módulos de microservicio. En este momento, es necesario considerar la comunicación remota entre submódulos. Los modos de comunicación típicos se dividen en los dos tipos siguientes: uno es la llamada remota RPC sincrónica y el otro es el método de comunicación asincrónico basado en el agente de middleware.
Modelo de llamada RPC síncrona
Bajo el modelo de llamada RPC síncrona, la comunicación de llamadas se realiza directamente entre diferentes sistemas. Cada solicitud se envía directamente desde la persona que llama a la persona que llama, y luego la persona que llama debe devolver inmediatamente el resultado de la respuesta a la persona que llama para determinar si el resultado de la llamada es correcto. exitoso.
Modelo de comunicación asincrónica
En el modo de comunicación de mensajes asincrónicos, los subsistemas están conectados directamente sin un fuerte acoplamiento. La persona que llama solo necesita convertir la solicitud en un evento asincrónico (mensaje) y enviarla al agente intermedio. Si la transmisión es exitosa, la llamada de enlace asincrónico es. se considera completado, y el resto El agente intermedio de trabajo será responsable de notificar de manera confiable el evento al sistema de llamadas descendente para garantizar que se complete la ejecución de la tarea. El agente intermediario es generalmente un middleware de mensajes.
Las ventajas de la comunicación asincrónica son las siguientes:
La topología del sistema es simple
Dado que la persona que llama y el destinatario se comunican con el agente intermediario de manera unificada, el sistema tiene una estructura en estrella y es fácil de mantener y administrar.
Acoplamiento débil aguas arriba y aguas abajo
Los sistemas ascendentes y descendentes están débilmente acoplados, la estructura es más flexible y el agente intermedio es responsable del almacenamiento en búfer y la recuperación asincrónica. Los sistemas ascendentes y descendentes se pueden actualizar y cambiar de forma independiente sin afectarse entre sí.
Capacidad de reducción de picos y llenado de valles
Los proxies intermedios basados en mensajes a menudo tienen fuertes capacidades de configuración y almacenamiento en búfer del tráfico, por lo que no abrumarán el flujo descendente cuando lleguen los picos de tráfico empresarial.
Introducción al modelo de transmisión de mensajes.
Los principales modelos de transmisión de middleware de mensajes son principalmente el modelo punto a punto y el modelo de publicación-suscripción.
modelo de igual a igual
El modelo punto a punto también se denomina modelo de cola y tiene las siguientes características:
Anonimato de consumo: la única identidad para la comunicación de mensajes ascendentes y descendentes es la cola. Los consumidores descendentes no pueden declarar identidades independientes al obtener mensajes de la cola.
Comunicación uno a uno: según las características del anonimato del consumo, incluso si hay varios consumidores posteriores, no tienen sus propias identidades independientes, por lo que cada mensaje en la cola compartida solo será procesado por un solo consumidor. Por lo tanto, el modelo punto a punto solo puede lograr una comunicación uno a uno.
modelo de publicación-suscripción
El modelo publicación-suscripción tiene las siguientes características:
Independencia de consumo: en comparación con el método de consumo anónimo del modelo de cola, todos los consumidores en el modelo de publicación-suscripción tienen una identidad, generalmente denominada grupo de suscripción (relación de suscripción). Los diferentes grupos de suscripción son independientes entre sí y no se afectan entre sí. .
Comunicación uno a muchos: según el diseño de identidad independiente, los mensajes dentro del mismo tema pueden ser procesados por múltiples grupos de suscripción, y cada grupo de suscripción puede recibir la cantidad total de mensajes. Por lo tanto, el modelo de publicación-suscripción puede lograr una comunicación de uno a muchos.
Comparación de modelos de transmisión
El modelo punto a punto y el modelo de publicación-suscripción tienen cada uno sus propias ventajas. El modelo punto a punto es más simple, mientras que el modelo de publicación-suscripción es más escalable.
El modelo de transmisión utilizado por Cloud Message Queue RocketMQ es un modelo de publicación-suscripción, por lo que también tiene las características de un modelo de publicación-suscripción.
Cola de mensajes en la nube Kafka
Ventajas del producto
Proporcione servicios totalmente administrados para Apache Kafka de código abierto para resolver los puntos débiles de los productos de código abierto. Con la versión Cloud Message Queue Kafka, solo necesita concentrarse en el desarrollo empresarial sin implementación, operación ni mantenimiento. En comparación con Apache Kafka de código abierto, la versión Cloud Message Queue Kafka es más económica, más elástica y más confiable.
Ecología de aplicaciones
Tiene un rico ecosistema de aplicaciones, que incluye principalmente los siguientes aspectos:
Campo de big data: análisis del comportamiento de sitios web, agregación de registros, monitoreo de aplicaciones, procesamiento de datos en tiempo real, análisis de datos en línea y fuera de línea, etc.
Integración de datos: importe mensajes a almacenes de datos fuera de línea como MaxCompute, OSS, RDS, Hadoop y HBase.
Integración de procesamiento de datos: integre con StreamCompute, E-MapReduce, Spark, Storm y otros motores.
arquitectura del producto
Versión Kafka de cola de mensajes en la nube
estructura del sistema
Productor
Envíe mensajes a Kafka Broker de la versión Cloud Message Queue Kafka a través del modo push. Los mensajes enviados pueden ser visitas a páginas web, registros del servidor o información de recursos del sistema relacionada con la CPU y la memoria.
Corredor Kafka
El servidor utilizado para almacenar mensajes. Kafka Broker admite la expansión horizontal. Cuanto mayor sea el número de nodos de Kafka Broker, mayor será la tasa de rendimiento del clúster de Cloud Message Queue Kafka.
Grupo
Suscríbase y consuma mensajes del Broker versión Kafka de Cloud Message Queue a través del modo pull.
cuidador del zoológico
Administre la configuración del clúster, elija particiones líderes y realice el equilibrio de carga cuando cambie el grupo.
Versión Kafka de cola de mensajes en la nube
El modelo de publicación/suscripción de la versión Kafka de Cloud Message Queue
La relación correspondiente entre grupo y tema es N: N, es decir, un grupo puede suscribirse a varios temas al mismo tiempo y varios grupos también pueden suscribir un tema al mismo tiempo.
Aunque varios grupos pueden suscribirse a un tema al mismo tiempo, los mensajes del tema solo pueden ser consumidos por cualquier consumidor del mismo grupo.
Ventajas del producto
Listo para usar
Compatible con código abierto:
Cloud Message Queue Kafka Edition es 100% compatible con Apache Kafka de código abierto. Puede utilizar directamente el cliente Apache Kafka de código abierto para comunicarse con Cloud Message Queue Kafka Edition. La versión de Cloud Message Queue Kafka actualmente admite las versiones de código abierto 0.10.x~2.6.x.
Migración perfecta:
La versión Cloud Message Queue Kafka se basa en el ecosistema Apache Kafka de código abierto existente y puede migrar a la nube sin ninguna modificación del código.
Sin operación ni mantenimiento, fácil de observar.
HouseKeeping (componente de inspección de estado): se utiliza para la inspección en tiempo de ejecución de los enlaces principales de la versión Cloud Message Queue Kafka. Realizará un escaneo y diagnóstico completo del clúster cada minuto y puede emitir alarmas en caso de estado incorrecto. Al mismo tiempo, se emitirá un informe de inspección general al personal de operación y mantenimiento de Alibaba Cloud todos los días para facilitar el monitoreo del estado de salud del sistema de la versión Cloud Message Queue Kafka.
Monitoreo y alarmas comerciales: cada grupo de consumidores puede configurar monitoreo y alarmas para la acumulación de mensajes para ayudarlo a encontrar problemas a tiempo.
OpenAPI: la versión Cloud Message Queue Kafka le proporciona un conjunto completo de OpenAPI de administración y control para implementar una serie de funciones de administración de recursos y operación y mantenimiento.
Ecosistema de datos rico
Proporciona componentes de procesamiento de datos totalmente administrados y sin operaciones, admite programación de funciones flexible y procesa datos de manera fácil y flexible.
Support Connector para conectar productos masivos en la nube y productos ecológicos de big data de construcción propia para realizar fácilmente la integración y el cálculo de datos.
Disponible en formato extra grande
Optimice profundamente el kernel para resolver el cuello de botella de rendimiento de las particiones de mil niveles de la versión de código abierto y admita el rendimiento de particiones de diez mil niveles sin pérdidas.
Soporta expansión de segundo nivel.
Admite escritura de hasta 2 GB de tráfico.
Alta disponibilidad
El equipo de optimización del rendimiento e I+D de productos de mensajería de Alibaba Cloud ha optimizado aún más los puntos débiles de los productos de código abierto para brindarle mejores servicios.
Persistencia de datos: un equipo profesional garantiza una mayor disponibilidad y la persistencia de los mensajes se coloca en la cola de mensajes. La confiabilidad de los datos es alta y la disponibilidad del servicio es alta.
Capacidad de alto rendimiento: incluso cuando se acumulan mensajes masivos, siempre puede mantener
Capacidades de alto rendimiento del clúster de la versión Kafka de Cloud Message Queue.
Decenas de miles de temas: admite una alta lectura y escritura simultáneas de decenas de miles de temas, manteniendo siempre
Alta garantía SLA
Admite garantías de optimización de escritura en escenarios extremos, como actualización en escala de grises, actualización/datos fríos, etc.
El sistema de inspección, operación y mantenimiento totalmente automático garantiza una disponibilidad del servicio del 99,9% y una confiabilidad de los datos del 99,999999%.
Seguridad de datos
Proporciona funciones como mecanismos de autenticación y autorización, descentralización de usuarios y protección de seguridad a nivel empresarial.
Gestión de permisos: es totalmente compatible con cuentas de Alibaba Cloud y usuarios de RAM, listas blancas y negras, STS y otras funciones, y realiza servicios de autorización para cuentas de Alibaba Cloud y usuarios de RAM, así como cuentas cruzadas entre empresas.
Seguridad de acceso: basado en el sistema de cuentas de Alibaba Cloud, el mecanismo SASL se utiliza para autenticar las identidades de los usuarios y SSL se utiliza para cifrar el canal de transmisión para garantizar que los datos no sean robados ni manipulados durante el proceso de transmisión, lo que garantiza la seguridad de tu información.
Alibaba Cloud VPC: además del acceso a la red pública, la versión Cloud Message Queue Kafka también admite VPC de red privada. Puede controlar completamente su propia red privada, como seleccionar rangos de direcciones IP, configurar tablas de enrutamiento y puertas de enlace, etc. Puede utilizar recursos de Alibaba Cloud, como servidores en la nube, versiones RDS de bases de datos en la nube y equilibrio de carga en su propia red privada definida.
Optimización de motores de código abierto
En comparación con el Apache Kafka de código abierto, el potente motor de procesamiento admite decenas de miles de temas con alta lectura y escritura concurrentes, escalamiento de segundo nivel y almacenamiento confiable en la nube, lo que brinda una opción muy rentable y también proporciona componentes de inspección de salud y negocios; Funciones de monitoreo y alarma, que lo ayudan a descubrir y resolver problemas de manera oportuna y efectiva.
Escenarios de aplicación
Seguimiento de la actividad del sitio web
La versión Cloud Message Queue Kafka del modelo de publicación/suscripción le permite recopilar datos de actividad del sitio web (como registro, inicio de sesión, recarga, pago, compra) en tiempo real, publicar mensajes sobre diferentes temas según los tipos de datos comerciales y luego utilizar datos reales. -Entrega en tiempo de mensajes de suscripción, utilice el flujo de mensajes para procesamiento y monitoreo en tiempo real, o cárguelo en sistemas de almacenamiento de datos fuera de línea como Hadoop y MaxCompute para procesamiento fuera de línea.
La versión Cloud Message Queue Kafka tiene las siguientes ventajas para el seguimiento de la actividad del sitio web:
Alto rendimiento: la información de comportamiento generada por los usuarios del sitio web es relativamente grande y requiere un alto rendimiento para respaldarla.
Expansión elástica: la actividad del sitio web genera un aumento en los datos de comportamiento y la plataforma en la nube puede expandirse rápidamente según la demanda.
Análisis de big data: se puede conectar a motores de procesamiento de datos en tiempo real como Storm y Spark, así como a sistemas de almacenamiento de datos fuera de línea como Hadoop.
Agregación de registros
La versión Cloud Message Queue Kafka puede lograr una mayor persistencia de datos y un tiempo de respuesta de un extremo a otro más corto, al mismo tiempo que tiene un alto rendimiento. Esta característica de Cloud Message Queue Kafka lo hace adecuado como centro de recopilación de registros. Cloud Message Queue Kafka Edition ignora los detalles de los archivos y puede abstraer los datos de registro de múltiples hosts o aplicaciones en flujos de mensajes de registros o eventos y enviarlos de forma asincrónica al clúster de Cloud Message Queue Kafka Edition, logrando así un RT muy bajo. El cliente de la versión Kafka de Cloud Message Queue puede enviar mensajes en lotes y comprimirlos, casi sin sobrecarga de rendimiento para los productores. Los consumidores pueden utilizar el almacenamiento de almacén fuera de línea, como Hadoop y MaxCompute, y sistemas de análisis en línea en tiempo real, como Strom y Spark, para realizar análisis estadísticos de los registros.
La versión Cloud Message Queue Kafka tiene las siguientes ventajas para la agregación de datos:
Desacoplar aplicación y análisis: construir un puente entre el sistema de aplicación y el sistema de análisis y desacoplar la asociación entre ellos.
Alta escalabilidad: Tiene alta escalabilidad, es decir, cuando aumenta la cantidad de datos, se puede expandir rápidamente horizontalmente agregando nodos.
Sistema de análisis en línea o fuera de línea: admite un sistema de análisis en línea en tiempo real y un sistema de análisis fuera de línea similar a Hadoop.
procesamiento de datos
En muchos campos, como el análisis de tendencias del mercado de valores, la medición y el control de datos meteorológicos y el análisis del comportamiento de los usuarios de sitios web, debido a la generación de datos rápida, en tiempo real y de gran tamaño, es difícil recopilar estos datos de manera unificada y almacenarlos en una base de datos para su procesamiento. Como resultado, la arquitectura de procesamiento de datos tradicional no puede satisfacer las necesidades. A diferencia de la arquitectura tradicional,
La aparición de la versión Kafka de la cola de mensajes en la nube y motores de procesamiento de datos como Storm, Samza y Spark tiene como objetivo resolver mejor los problemas encontrados en el procesamiento de este tipo de datos. El modelo de procesamiento de datos puede realizar el procesamiento de datos durante el flujo de datos. Capture y procese en tiempo real, realice cálculos y análisis de acuerdo con los requisitos comerciales y finalmente guarde o distribuya los resultados a los componentes requeridos.
La versión Cloud Message Queue Kafka tiene las siguientes ventajas para el procesamiento de datos:
Flujo de datos: capture y procese datos en tiempo real durante el flujo de datos y realice cálculos y análisis según las necesidades comerciales.
Alta escalabilidad: debido a la rápida velocidad de generación de datos y la gran cantidad de datos, se requiere una alta escalabilidad.
Motor de procesamiento de datos: se puede conectar a Storm, Samza, Spark, EMR, Blink, StreamCompute y otros productos de código abierto de Alibaba Cloud.
Centro de transferencia de datos
En los últimos 10 años, han surgido sistemas especiales como almacenamiento KV (HBase), búsqueda (Elasticsearch), procesamiento de transmisión (Storm, Spark, Samza) y bases de datos de series temporales (OpenTSDB). Estos sistemas se crearon con un único objetivo en mente y su simplicidad hace que sea más fácil y rentable construir sistemas distribuidos en hardware básico. A menudo, es necesario inyectar el mismo conjunto de datos en varios sistemas especializados. Por ejemplo, cuando los registros de aplicaciones se utilizan para el análisis de registros fuera de línea, la búsqueda de registros individuales también es indispensable. Obviamente, no es práctico crear flujos de trabajo independientes para recopilar cada tipo de datos y luego importarlos a sus propios sistemas dedicados. La versión cola de Kafka sirve como centro de transferencia de datos y los mismos datos se pueden importar a diferentes sistemas dedicados.
La versión Cloud Message Queue Kafka tiene las siguientes ventajas como centro de transferencia de datos:
Almacenamiento de alta capacidad: capaz de almacenar datos de alta capacidad en hardware comercial para lograr un sistema distribuido escalable horizontalmente.
Modelo de consumo uno a muchos: modelo de publicación/suscripción, que admite el consumo del mismo conjunto de datos varias veces al mismo tiempo.
Admite procesamiento por lotes y en tiempo real: admite la persistencia de datos locales y la caché de páginas, y puede transmitir mensajes simultáneamente a consumidores por lotes y en tiempo real sin pérdida de rendimiento.
Cola de mensajes en la nube RabbitMQ
Comparación de código abierto
Comparando Cloud Message Queue RabbitMQ Edition y RabbitMQ de código abierto desde tres aspectos: rendimiento, estabilidad y funcionalidad, Cloud Message Queue RabbitMQ Edition tiene más ventajas.
Características del producto
Compatible con RabbitMQ de código abierto, proporciona soporte completo de operación y mantenimiento y admite múltiples tipos de mensajes.
Restricciones de uso
Existen restricciones en clústeres, llamadas de interfaz y caracteres. Cuando utilice la versión RabbitMQ de Cloud Message Queuing, tenga cuidado de no exceder los límites correspondientes para evitar excepciones del programa.
Ventajas del producto
Flexible y fácil de usar
Listo para usar
Totalmente compatible con protocolos estándar, totalmente compatible con la comunidad de código abierto RabbitMQ y migró rápidamente a la nube.
Servicio totalmente gestionado
El servicio Cloud Message Queue RabbitMQ es un servicio de mensajería en la nube que no requiere implementación, operación ni mantenimiento. Confiando en el equipo profesional de operación y mantenimiento automatizado de Alibaba Cloud, se realizan inspecciones multidimensionales de los enlaces principales en el segundo y minuto nivel, se proporcionan informes completos de diagnóstico de salud y se realizan alarmas y recuperación oportuna para estados no saludables para garantizar la disponibilidad del servicio y el negocio. continuidad.
Alta disponibilidad
Proporcione un SLA claro para garantizar una alta disponibilidad en múltiples zonas de disponibilidad. Incluso si toda la sala de computadoras no está disponible, los servicios de mensajería aún se pueden brindar con normalidad.
Implementación distribuida en clúster, los nodos de servicio no tienen estado y no tienen un punto único. Incluso si un solo nodo no está disponible, solicite conmutación por error a otros nodos para garantizar la prestación normal de los servicios de mensajes.
Mejora de funciones
mensaje retrasado
Admite mensajes retrasados, logrando una precisión de segundo nivel y sin restricciones de primero en entrar, primero en salir.
Es simple y fácil de usar. Solo necesita establecer un parámetro en el código para resolver los puntos débiles de la cola sin demora RabbitMQ de código abierto.
Soporte de alta precisión, el más corto puede tener una precisión del segundo nivel y el más largo puede durar 1 día.
Alto rendimiento, el rendimiento es consistente con los mensajes ordinarios.
Varias copias de redundancia de datos garantizan la recuperación de mensajes.
Reintento de mensaje
Reintentos durante un minuto, hasta 16 reintentos.
Los mensajes que superan el número máximo de reintentos ingresan a la cola de mensajes no entregados. Los mensajes de mensajes no entregados se pueden consultar y exportar.
Intercambio de letras muertas
El Intercambio de mensajes no entregados mejorado no solo admite mensajes con respuestas negativas, sino que también admite mensajes que no se pueden reintentar para ingresar automáticamente al Intercambio de mensajes no entregados para garantizar que los mensajes no se pierdan.
Súper rendimiento
Límite superior de rendimiento de la plataforma
Admite millones de colas, la expansión horizontal genera un crecimiento lineal en el rendimiento y no hay límite de simultaneidad en el rendimiento.
Expansión de cola única
Resuelva el cuello de botella de rendimiento de la cola única de RabbitMQ, admita la expansión horizontal de la cola única y no tenga límite de simultaneidad en el rendimiento.
Escalado elástico
Tiene una gran escalabilidad, mejora lineal del rendimiento, expansión y contracción elástica según las necesidades comerciales y es transparente para los usuarios.
Acumulación masiva
En el caso de una acumulación masiva de mensajes, siempre se mantiene un alto rendimiento sin afectar los servicios normales del clúster.
Los productores y consumidores de mensajes están aislados para hacer frente a la gran concurrencia de productores y al consumo estable de los consumidores.
Seguro y confiable
Granularidad de permisos
Control de permisos detallado para instancias, Vhosts, colas y Exchange, y control de acceso seguro para cada solicitud de mensaje.
Cuentas maestras y subcuentas
Integración completa con cuentas maestras y secundarias de Alibaba Cloud RAM, listas blancas y negras, STS y otras funciones.
Transmisión cifrada
Admite el protocolo de cifrado de transmisión TLS.
Escenarios de aplicación
Desacoplamiento asincrónico
Se puede utilizar para la comunicación entre diferentes microservicios después de desensamblar una sola aplicación en microservicios. El beneficio del desacoplamiento de aplicaciones es que las iteraciones de diferentes aplicaciones ya no dependen entre sí, mientras que el beneficio de la comunicación asincrónica es que ya no es necesario procesar los datos de inmediato. El desacoplamiento asíncrono puede acortar eficazmente la longitud del enlace de datos y mejorar la eficiencia del procesamiento de datos.
Afeitado de picos y relleno de valles
Cuando los eventos a gran escala generan pulsos de tráfico elevados, la falta de protección adecuada puede provocar fácilmente una sobrecarga del sistema o incluso un fallo. Las restricciones excesivas pueden generar una gran cantidad de solicitudes fallidas, lo que afecta la experiencia del usuario.
La versión Cloud Message Queue RabbitMQ puede eliminar picos y llenar valles. Sus capacidades de procesamiento de mensajes de alto rendimiento pueden manejar pulsos de tráfico sin verse abrumados, lo que garantiza la disponibilidad del sistema y al mismo tiempo mejora la experiencia del usuario a través de una tecnología de respuesta a solicitudes rápida y eficaz. Su capacidad de acumulación masiva de mensajes garantiza que los negocios intermedios funcionen sin problemas y de manera estable dentro de un nivel seguro y evita el impacto de los picos de tráfico.
Sincronización de caché distribuida
Una gran cantidad de accesos simultáneos a la base de datos pueden generar tiempos de respuesta de página prolongados. Cree un caché distribuido a través de la versión Cloud Message Queue RabbitMQ para admitir la notificación en tiempo real de cambios de datos, reducir efectivamente el tiempo de respuesta de la página y cumplir con los grandes requisitos de acceso para los cambios.
Cola de mensajes en la nube MQTT
Es un middleware de mensajes liviano lanzado por Alibaba Cloud para los campos de Internet móvil e Internet de las cosas. Si el middleware de cola de mensajes tradicional se usa generalmente entre microservicios, entonces la versión MQTT de Cloud Message Queue adecuada para Internet de las cosas logra el paso de mensajes entre el final y la nube y la verdadera interconexión de todo. Este artículo presenta el modelo de envío y recepción de mensajes, las ventajas del producto y los escenarios de aplicación de la versión Cloud Message Queue MQTT.
Idea principal
Tema
: Tema del mensaje, tipo de mensaje de primer nivel, al que el productor envía mensajes.
productor
: También conocido como editor de mensajes, responsable de producir y enviar mensajes al tema.
consumidor
: También llamado suscriptor de mensajes, responsable de recibir y consumir mensajes del tema.
información
: Los datos enviados por el productor al Tema y finalmente transmitidos al consumidor.
regla
La versión Cloud Message Queue MQTT es un recurso que permite la interoperabilidad de datos con otros productos de Alibaba Cloud.
Modelo de mensajería
Incluye principalmente los siguientes dos modelos de envío y recepción de mensajes:
Modelo de interacción entre terminal y servicio en la nube.
La versión Cloud Message Queue MQTT conecta el terminal y la nube para lograr una comunicación bidireccional entre el dispositivo y la nube. El dispositivo puede comunicarse directamente con aplicaciones comerciales en la nube a través de la versión Cloud Message Queue MQTT y también puede lograr la interoperabilidad entre productos de datos de mensajes con otros productos de Alibaba Cloud.
Los escenarios de aplicación típicos de este modelo son informar datos de estado de dispositivos inteligentes o emitir instrucciones para aplicaciones de control de la nube.
Modelo de interacción terminal y terminal.
Este modelo es adecuado para la comunicación de datos entre aplicaciones o dispositivos móviles. Los escenarios típicos son dos usuarios que conversan mensajes directamente en el escenario de comunicación IM y la aplicación controla dispositivos inteligentes en el escenario de dispositivo inteligente. En este modelo, los productores y consumidores de mensajes se distribuyen en dispositivos terminales y se conectan al producto de la versión MQTT de la cola de mensajes en la nube a través del protocolo MQTT.
Según los dos modelos de envío y recepción de mensajes anteriores, los desarrolladores que utilizan la versión MQTT de Cloud Message Queue se pueden dividir en dos categorías: terminal y nube.
Ventajas del producto
Migración perfecta
Compatible con cualquier SDK que admita el protocolo MQTT 3.1.1, admita el protocolo WebSocket y cubra la mayoría de las plataformas y lenguajes de desarrollo móvil.
alto rendimiento
Admite conexiones en línea de decenas de millones de dispositivos, millones de mensajes simultáneos, billones de transferencias y empuje a nivel de milisegundos; diseño de arquitectura distribuida, sin cuellos de botella en un solo punto y expansión horizontal ilimitada entre componentes.
Seguro y confiable
Admite control de permisos a nivel de dispositivo, servicio de token temporal y protocolo de transmisión segura versión TLS 1.2 para garantizar que los datos del usuario sean seguros y confiables.
Interoperabilidad natural
El intercambio de mensajes entre la versión Cloud Message Queue MQTT y la versión Cloud Message Queue RocketMQ permite la comunicación bidireccional entre el dispositivo y la nube, haciéndola más eficiente y confiable.
Escenarios de aplicación
Tiene capacidades de soporte multiprotocolo, multilingüe y multiplataforma, y se usa ampliamente en los campos de Internet móvil e Internet de las cosas, cubriendo una variedad de escenarios de aplicaciones como transmisión móvil en vivo, Internet de vehículos, pagos financieros, catering inteligente y chat instantáneo.
Servicio de mensajería MNS
Servicio de mensajes MNS (Servicio de mensajes) es un servicio de mensajería distribuida eficiente, confiable, seguro, conveniente y elásticamente escalable. El servicio de mensajería MNS puede ayudar a los desarrolladores a transferir libremente datos y mensajes de notificación entre componentes distribuidos de la aplicación, creando así un sistema débilmente acoplado. El servicio de mensajería MNS admite el modelo de cola y el modelo de tema.
modelo de cola
El modelo de cola proporciona un modelo de consumo uno a uno de alta confiabilidad y alta concurrencia, es decir, cada mensaje en la cola solo puede ser consumido por un determinado consumidor.
La cola es como un restaurante de sushi giratorio. Hay varios chefs (productores) de sushi en el restaurante de sushi que elaboran un sushi exquisito. Cada pieza de sushi es única. Los clientes (consumidores) pueden tomar el sushi que les gusta de la cinta transportadora para comerlo (consumirlo).
Ventajas del producto
Simple y fácil de usar
No requiere operación ni mantenimiento, no es necesario crear un servicio de mensajería usted mismo.
Interfaz RESTful HTTP estándar de fácil acceso.
Compatibilidad con SDK en varios idiomas, incluidos C, Java, C#, Python, PHP, Go, etc., y continúa enriqueciéndose.
Estable y confiable
Tres copias del mensaje, alta confiabilidad.
Alta disponibilidad de servicio.
Mecanismo único que garantiza que siempre se pueda escribir.
Seguridad
Protección de seguridad multinivel y prevención de ataques DDoS.
Mecanismo de aislamiento multiusuario, cada usuario está equipado con un espacio de nombres independiente.
Admite otorgar diferentes permisos de acceso a diferentes usuarios de RAM.
Admite acceso HTTPS y VPC.
Rendimiento a gran escala y alta escalabilidad
La cantidad de colas y la capacidad de almacenamiento de colas son altamente escalables.
La escala del servicio se amplía automáticamente y es transparente para los usuarios.
Proporcionar servicios en múltiples regiones alrededor del mundo.
Rápido y estable
Rápido y directo, solo toma 3 segundos conectarse con los usuarios.
Canal exclusivo triple play.
La sala de computadoras de línea dedicada admite gran capacidad y alta concurrencia.
El ritmo de llegada es elevado y está conectado en tiempo real a la plataforma de portabilidad numérica del Ministerio de Industria y Tecnologías de la Información.
Garantía de operación y mantenimiento de nivel de operador, monitoreo en tiempo real y conmutación automática.
Servicio técnico íntimo
Enriquecer continuamente el intercambio de casos de mejores prácticas.
Soporte de órdenes de trabajo 24 horas al día, 7 días a la semana.
Soporte personalizable en el sitio disponible.