ApsaraMQ for RocketMQ es una plataforma de mensajería distribuida basada en Apache RocketMQ. Unifica el procesamiento de mensajes, eventos y flujos con baja latencia, alta concurrencia, alta disponibilidad y alta confiabilidad. Sus capacidades principales incluyen el desacoplamiento asíncrono, el procesamiento de datos en flujo y el procesamiento orientado a eventos para aplicaciones distribuidas.
Por qué elegir ApsaraMQ for RocketMQ
ApsaraMQ for RocketMQ se basa en la infraestructura cloud-native de Alibaba Cloud y es compatible con las API y funciones principales de Apache RocketMQ.
En comparación con los clústeres autogestionados, ApsaraMQ for RocketMQ ofrece las siguientes ventajas:
Arquitectura avanzada
ApsaraMQ for RocketMQ desacopla la computación del almacenamiento. El almacenamiento y la computación escalan horizontalmente y de forma independiente, lo que permite operaciones y mantenimiento (O&M) elásticos y mensajería de alto rendimiento a gran escala.
Alto rendimiento
Un clúster de instancia única admite hasta 1 millón de transacciones por segundo (TPS) para el envío y recepción de mensajes, lo que garantiza estabilidad durante picos de tráfico como grandes promociones.
Seguridad y confiabilidad
Almacenamiento redundante entre zonas: Se despliega en varias zonas con almacenamiento de datos triplemente redundante. Si una zona deja de estar disponible, el servicio permanece accesible.
Replicación de datos: Admite replicación de datos entre regiones y dentro de la misma región. Las reglas de enrutamiento sincronizan los datos entre las instancias de origen y destino.
SLA de estabilidad
El despliegue multizona ofrece un SLA líder en la industria: 99.99% de disponibilidad del servicio y 99.99999999% de confiabilidad de los datos mediante almacenamiento de múltiples réplicas.
Elasticidad y rentabilidad
La computación de mensajes combina capacidad reservada y bajo demanda, lo que elimina la necesidad de reservar grandes márgenes para picos de tráfico y ahorra hasta la mitad de los recursos de máquina. El almacenamiento es serverless y pay-as-you-go, lo que ofrece mayor elasticidad y menores costos en comparación con los discos en la nube conectados.
O&M y observability
Proporciona funciones de O&M y observability: integración con un solo clic con OpenTelemetry y Prometheus, rastreo de extremo a extremo y compatibilidad con OpenAPI para la integración de O&M de autoservicio.
Recuperación ante desastres de nivel financiero
Admite enrutamiento y replicación global de mensajes entre regiones con latencia a nivel de milisegundos, así como copia de seguridad y sincronización de datos a nivel de tema.
Casos de uso
Basado en un almacenamiento de mensajes unificado y una capa de computación ligera, ApsaraMQ for RocketMQ admite tres escenarios principales: desacoplamiento asíncrono, procesamiento de datos en flujo y procesamiento orientado a eventos.
Mensajes empresariales
-
ApsaraMQ for RocketMQ se creó originalmente para el Double 11 de Alibaba y se usa ampliamente en sistemas de microservicios para logística, carritos de compras y puntos de crédito. ApsaraMQ for RocketMQ proporciona los siguientes beneficios:
-
Desacoplamiento asíncrono para acortar las cadenas de procesamiento
ApsaraMQ for RocketMQ desacopla los servicios ascendentes de los descendentes, lo que acorta la cadena de invocación. Esto genera tiempos de respuesta más rápidos, un acoplamiento más flexible y una mayor eficiencia para los desarrolladores.
-
Distribución de carga pico para mejorar la estabilidad
A diferencia del middleware tradicional que solo proporciona operaciones asíncronas, ApsaraMQ for RocketMQ se diseñó para escenarios de transacciones en línea e incluye la distribución de carga pico como función principal, lo que mejora la estabilidad y reduce los costos.
ApsaraMQ for RocketMQ acumula cientos de millones de mensajes y gestiona modelos de tráfico mixtos calientes y fríos. Absorbe los aumentos de tráfico durante escenarios pico, como grandes promociones, y mantiene los servicios descendentes dentro de límites operativos seguros.
-
-
La solución distributed transactional message de ApsaraMQ for RocketMQ ofrece los siguientes beneficios:
-
Sistema de alto rendimiento
Basados en la consistencia eventual, los mensajes transaccionales ofrecen un mayor rendimiento y escalabilidad que las transacciones XA tradicionales.
-
Reducción del costo de desarrollo
Una interfaz de dos fases coordina múltiples ramas de transacción, lo que elimina la necesidad de lógica de compensación empresarial.
La siguiente figura compara una transacción tradicional con la solución de mensajes transaccionales de ApsaraMQ for RocketMQ:
-
-
ApsaraMQ for RocketMQ proporciona scheduled messages distribuido con precisión a nivel de segundos, utilizado ampliamente para el procesamiento de tiempos de espera de pedidos y la programación diferida distribuida.
Los mensajes programados de ApsaraMQ for RocketMQ proporcionan los siguientes beneficios:
-
Alta precisión de programación y baja sobrecarga de desarrollo
No hay intervalos escalonados para los tiempos de programación. Active eventos con precisión arbitraria sin necesidad de deduplicación en el lado empresarial.
-
Alto rendimiento y escalabilidad
Las soluciones de programación tradicionales requieren escaneos de base de datos que crean cuellos de botella en el rendimiento. ApsaraMQ for RocketMQ utiliza procesamiento orientado a eventos para alcanzar millones de TPS.
-
Procesamiento de flujos
ApsaraMQ for RocketMQ proporciona almacenamiento de flujos de alto rendimiento que conecta la recopilación de registros, la integración de datos y los sistemas de análisis. Utilice ApsaraMQ for RocketMQ para distribuir datos ascendentes a sistemas descendentes, como computación en tiempo real y almacenamiento sin conexión.
Procesamiento orientado a eventos
Combine ApsaraMQ for RocketMQ con EventBridge para implementar arquitecturas orientadas a eventos. Las reglas de eventos visuales en EventBridge procesan los datos de los mensajes y activan destinos descendentes como Function Compute, endpoints HTTP o servicios de terceros.
Guía de migración
Primeros pasos
Cree una instancia de ApsaraMQ for RocketMQ: