ApsaraMQ for RocketMQ es una plataforma distribuida de Alibaba Cloud que unifica el procesamiento de mensajes, eventos y flujos. Está construida sobre Apache RocketMQ y ofrece baja latencia, alta concurrencia, alta disponibilidad y gran confiabilidad. Tras la versión de Apache RocketMQ 5.0, ApsaraMQ for RocketMQ cuenta ahora con una versión 5.x del lado del servidor más estable y confiable. En este tema se describen las diferencias y la compatibilidad entre las versiones 5.x y 4.x del lado del servidor de ApsaraMQ for RocketMQ.
Ventajas de la versión 5.x
En comparación con las versiones anteriores del lado del servidor, ApsaraMQ for RocketMQ 5.x ofrece las siguientes ventajas:
-
Arquitectura más avanzada
Adopta por completo una arquitectura de mensajes con separación de almacenamiento y cómputo. Los recursos de almacenamiento y cómputo se escalan horizontalmente y de forma independiente según sea necesario. Esta arquitectura admite operaciones y mantenimiento (O&M) elásticos eficientes, además de ofrecer capacidades de alto rendimiento a gran escala.
-
Menor umbral de desarrollo
Promueve principalmente el uso de SDK de cliente totalmente compatibles con Apache RocketMQ. También mantiene retrocompatibilidad con todas las versiones anteriores de los SDK y las operaciones de API.
Admite identificación segura dentro de una VPC. Para migrar a la nube, solo modifique el punto de acceso. No se requieren otros cambios en el código.
-
Menor umbral de O&M
Proporciona soluciones como rotación y elasticidad automáticas, así como un entorno de ensayo ligero. Estas soluciones resuelven desafíos comunes, como la evaluación de capacidad en línea, la elasticidad para picos y valles de negocio, y los entornos de despliegue gradual diarios. Este enfoque reduce el umbral general de O&M y disminuye los riesgos.
-
Costos más flexibles
Gracias a la optimización de la tecnología de infraestructura en la nube, las capacidades de cómputo para enviar y recibir mensajes admiten una combinación de tráfico reservado y tráfico en ráfaga. Esto significa que los negocios no necesitan reservar grandes márgenes para el tráfico en ráfaga.
El almacenamiento de mensajes funciona bajo el modelo pay-as-you-go. Este modelo ofrece ventajas elásticas significativas frente a la conexión de discos en la nube, los cuales no permiten reducir su escala.
-
Modelos de comercialización más completos
Ofrece un conjunto más amplio de planes escalonados y admite modelos de precios tanto mensuales como por hora.
-
La nueva LiteTopic model mejora la compatibilidad con la comunicación asíncrona de aplicaciones de IA
Resuelve problemas frecuentes, como los tiempos prolongados de procesamiento en tareas de negocio de IA, la escasez y el alto costo de los recursos de cómputo, y los conflictos entre el uso de dicho cómputo y las fluctuaciones del tráfico de negocio. Proporciona una función de topic ligera junto con sus respectivas soluciones. Los desarrolladores pueden construir fácilmente un sistema de comunicación asíncrona sólido, eficiente y escalable. Esto suaviza los picos y valles de solicitudes, alivia la presión de procesamiento en el backend, mejora el uso de recursos e incrementa el ahorro de costos.
Descripción de los SDK para cada versión
A continuación se presenta una tabla que describe los SDK y la compatibilidad de funciones para cada versión de ApsaraMQ for RocketMQ. En la tabla, ✔#10004; indica que la función es compatible y ✘#10008; indica que no lo es.
En la siguiente tabla, ✔ indica que la función es compatible y ✘ indica que no lo es.
Elemento de comparación | ||||||
Protocolo | Protocolo gRPC v2 | Protocolo Remoting | Protocolo Remoting | Protocolo Remoting | Protocolo gRPC v1 | Protocolo HTTP |
Instancias accesibles | Instancias de la serie 5.x |
|
|
| Instancias de la serie 4.x | Instancias de la serie 4.x |
Recomendaciones de uso | Utilice el SDK gRPC 5.x.
|
|
| |||
Envío de mensajes ordinarios, ordenados, transaccionales y programados | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo concurrente | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo ordenado de mensajes | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
Consumo ordenado de mensajes concurrency optimization | ✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; |
Consumo por difusión | ✘#10008; | ✔#10004; | ✔#10004; | ✔#10004; | ✘#10008; | ✘#10008; |
Consumo de flujos (por ejemplo, conexión con Flink) | ✘#10008; | ✔#10004; | ✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; |
Rastreo de mensajes | ✔#10004; | ✔#10004; | Compatible desde la versión 4.5.2 | ✔#10004; | ✔#10004; | ✘#10008; |
✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | |
✔#10004; | Solo compatible con instancias de la serie 5.x | ✘#10008; | ✘#10008; | ✘#10008; | ✘#10008; | |
Compatibilidad de funciones entre las versiones 4.x y 5.x
Las instancias de ApsaraMQ for RocketMQ 5.x se basan en la experiencia de producción de grandes clientes empresariales, por lo que cuentan con funciones y comportamientos optimizados para enviar y recibir mensajes. Como resultado, la configuración de parámetros y el comportamiento de las funciones pueden diferir en algunos escenarios. Estos cambios generalmente no afectan el flujo principal de mensajes. Si actualiza una instancia 4.x existente a la 5.x, evalúe los riesgos según las necesidades de su negocio.
A continuación se describen las diferencias en funciones y comportamientos:
Diferencia de función | Versión 4.x | Versión 5.x | Descripción |
Duración máxima de los mensajes programados | 40 días |
Para obtener más información, consulte Quotas and limits. | Las duraciones de programación prolongadas representan un riesgo de estabilidad para el sistema. No configure una duración demasiado larga. Utilice duraciones más cortas para simular escenarios de negocio. Para obtener más información, consulte Scheduled and delayed messages. Si está migrando una instancia 4.x existente y la duración máxima no cumple con sus requisitos, envíe un ticket para solicitar asistencia. |
Compatibilidad con el protocolo HTTP | ✔ | ✘ | La versión 5.x no admite el protocolo HTTP. Si su instancia 4.x actual utiliza este protocolo, posponga la actualización. |
Política de autorización de RAM | Enlace de datos + enlace de control | Admite el enlace de control, pero la política de autorización difiere de la versión 4.x. |
|
Enrutamiento global de mensajes | ✔ | Utilice la función Global Message Replication. | Global Message Replication admite tipos de instancia de código abierto, de Alibaba Cloud 4.x y de Alibaba Cloud 5.x. Proporciona sincronización entre regiones y entre instancias para mensajes y progreso de consumo. |
Restricción de tipo de mensaje | Sin restricción | Estrictamente restringido | En la versión 5.x, los tipos de mensajes se separan en topics para gestionar y procesar de forma independiente. El sistema valida estrictamente el tipo de mensaje enviado contra el tipo definido para el topic. Si la validación falla, se rechaza la solicitud de envío y se devuelve una excepción de discrepancia de tipo. Para obtener más información, consulte Topic behavior constraints. |
Restricciones de compra
Todos los usuarios pueden comprar instancias de ApsaraMQ for RocketMQ 5.x.
Solo los usuarios existentes pueden comprar instancias de ApsaraMQ for RocketMQ 4.x. Se recomienda actualizar su instancia a la versión 5.x lo antes posible. Para actualizarla, envíe un ticket para solicitar asistencia.
Descripción de la actualización de la versión 4.x a la 5.x
Actualmente no es posible actualizar directamente las instancias 4.x a la versión 5.x mediante una herramienta de actualización. Para actualizar una instancia existente a la 5.x, compre una instancia 5.x y luego migre gradualmente el tráfico de su servicio a la nueva instancia, tal como se muestra en la siguiente figura.
Como se muestra en la figura anterior, puede crear rápidamente los metadatos en el segundo paso mediante las funciones de importación y exportación de Topic y Group. Para obtener más información, consulte Topic Import/Export y Group Import/Export.
Al migrar su negocio, utilice la siguiente solución, la cual combina operaciones de lectura y escritura dual con una versión por fases.
