What are the advantages of ApsaraMQ for RocketMQ 5.x instances over 4.x instances?
Which client versions are compatible with ApsaraMQ for RocketMQ 5.x instances?
Which programming languages does the ApsaraMQ for RocketMQ client support?
How do I enable public network access for ApsaraMQ for RocketMQ?
What is the difference between ordered messages and normal messages?
Where can I find the username and password to connect to the server?
Is there a limit on the number of tags for an ApsaraMQ for RocketMQ subscription?
How are messages consumed when multiple consumer groups subscribe to the same topic?
What is the maximum message body size in ApsaraMQ for RocketMQ?
If message consumption fails, will the message be consumed again?
Do ApsaraMQ for RocketMQ 5.x instances support broadcasting consumption?
What is the maximum delay for a scheduled message in ApsaraMQ for RocketMQ?
Are there limits on the number of topics and groups for an instance?
Can I enable or disable the disk encryption feature for a purchased instance?
How do I determine the target TPS specification when downgrading a RocketMQ 5.x instance?
¿Qué ventajas tienen las instancias de ApsaraMQ for RocketMQ 5.x frente a las 4.x?
En comparación con versiones anteriores, las instancias 5.x cuentan con una arquitectura más avanzada, menores barreras de entrada para el desarrollo y la operación y mantenimiento, costos más flexibles y modelos comerciales más completos. Para obtener más información, consulte Differences and compatibility between 4.x and 5.x versions.
¿Qué versiones de cliente son compatibles con las instancias de ApsaraMQ for RocketMQ 5.x?
Las instancias de ApsaraMQ for RocketMQ 5.x son compatibles con clientes de código abierto Apache RocketMQ 5.x, 4.x y 3.x, así como con clientes ONS 1.x de ApsaraMQ for RocketMQ. Para obtener más información, consulte Differences and compatibility between 4.x and 5.x versions.
¿Qué lenguajes de programación admite el cliente de ApsaraMQ for RocketMQ?
Serie 5.x de ApsaraMQ for RocketMQ: Admite SDK de Java, C/C++, C# y Go mediante el protocolo TCP. Para obtener más información, consulte Overview of 5.x series SDK Reference.
Serie 4.x de ApsaraMQ for RocketMQ: Admite SDK de Java, C/C# y .NET mediante el protocolo TCP, además de SDK de Java, Go, Python, Node.js, PHP, C# y C++ mediante el protocolo HTTP. Para obtener más información, consulte Overview of 4.x series SDK Reference.
¿Cómo habilito el acceso por red pública para ApsaraMQ for RocketMQ?
Instancias de la serie 5.x: Puede habilitar el acceso por red pública al adquirir una instancia. Si no lo hizo durante la creación, actualice la instancia para habilitarlo. Para más información sobre la facturación del acceso por red pública en instancias de la serie 5.x, consulte Public network access fees.
Instancias de la serie 4.x: Los endpoints de red pública están disponibles de forma predeterminada. No se requiere configuración manual. Para más información sobre la facturación del acceso por red pública en instancias de la serie 4.x, consulte Public network traffic pricing.
Obtenga el endpoint de red pública desde la página Instance Details en ApsaraMQ for RocketMQ console.
¿Cuál es la diferencia entre mensajes ordenados y mensajes normales?
Los mensajes normales no garantizan que se consuman en el mismo orden en que se produjeron.
En los mensajes ordenados, todos se particionan según una ShardingKey. Los mensajes dentro de la misma partición se consumen bajo el principio primero en entrar, primero en salir (FIFO). El orden se garantiza únicamente dentro de cada partición, pero no entre particiones distintas. Para obtener más información, consulte Ordered messages.
¿Dónde encuentro el nombre de usuario y la contraseña para conectarme al servidor?
-
Instancias de la serie 5.x: Para acceder a una instancia de esta serie, debe proporcionar su nombre de usuario y contraseña. Por ejemplo:
/** * If you use a public endpoint, you must also set the instance username and password in the configuration. * You can get the username and password from the Intelligent Identity Recognition tab of Access Control in the console. * If you access the instance from an Alibaba Cloud ECS instance over the internal network, you do not need to configure this. * The server automatically obtains the information based on the internal VPC. * For Serverless instances, you must set the username and password for public network access. * If internal network access without identity verification is enabled, you do not need to set them for internal network access. */ builder.setCredentialProvider(new StaticSessionCredentialsProvider("Instance UserName", "Instance Password"));
-
Instancias de la serie 4.x: Para acceder a una instancia de esta serie, proporcione el AccessKey ID y el AccessKey secret de su cuenta de Alibaba Cloud o usuario RAM. Por ejemplo:
// The AccessKey ID for Alibaba Cloud identity verification. Create it in the Alibaba Cloud RAM console. properties.put(PropertyKeyConst.AccessKey,"Y2lK16J6Eh******"); // The AccessKey secret for Alibaba Cloud identity verification. Create it in the Alibaba Cloud RAM console. properties.put(PropertyKeyConst.SecretKey,"SPX46tC00z******");Para crear un AccessKey, consulte Create an AccessKey.
¿Dónde encuentro el endpoint para conectarme al servidor?
Instancias 5.x: Utilice endpoints TCP. No se admite el acceso mediante SDK HTTP.
Instancias 4.x: Utilice endpoints TCP o HTTP. Seleccione el endpoint que coincida con el protocolo de su SDK. Los endpoints de distintos protocolos no son intercambiables.
Obtención mediante la consola
Inicie sesión en la consola de ApsaraMQ for RocketMQ. En el panel de navegación izquierdo, haga clic en Instances.
En la barra de navegación superior, seleccione una región, como China (Hangzhou). En la página Instances, haga clic en el nombre de la instancia que desea gestionar.
En la página Instance Details, consulte los endpoints de la instancia en la pestaña Basic Information.
Obtención del endpoint mediante llamada a API
Instancias 5.x: Llame a la operación GetInstance.
Instancias 4.x: Llame a la operación OnsInstanceBaseInfo.
¿Existe un límite en el número de etiquetas para una suscripción de ApsaraMQ for RocketMQ?
El productor establece las etiquetas al enviar un mensaje. Cada mensaje puede tener una etiqueta.
Cuando un consumidor se suscribe a mensajes, no hay límite en la cantidad de etiquetas dentro de la regla de filtro. Sin embargo, la expresión de filtro no debe ser demasiado extensa; se recomienda mantenerla por debajo de 1 KB.
Para obtener más información, consulte Best practices for topics and tags.
¿Cuál es la diferencia entre consumo por clúster y consumo por difusión en ApsaraMQ for RocketMQ?
Consumo por clúster: En este modo, ApsaraMQ for RocketMQ garantiza que solo un consumidor dentro del grupo procese cada mensaje.
Consumo por difusión: En este modo, ApsaraMQ for RocketMQ envía cada mensaje a todos los consumidores del grupo. Esto asegura que cada consumidor procese el mensaje al menos una vez.
Para obtener más información, consulte Clustering consumption and broadcasting consumption.
¿Cómo se consumen los mensajes cuando varios grupos se suscriben al mismo tema?
Un grupo de consumidores puede suscribirse a múltiples temas y un tema puede tener suscripciones de varios grupos. Cuando esto ocurre, cada mensaje se entrega una vez a cada grupo. Dado que los grupos están aislados entre sí, cada uno puede consumir el mensaje simultáneamente.
¿Cuál es el tamaño máximo del cuerpo de mensaje en ApsaraMQ for RocketMQ?
-
Instancias de la serie 5.x:
Máximo: 4 MB.
-
Instancias de la serie 4.x:
Mensaje normal u ordenado: 4 MB
Mensaje transaccional, programado o diferido: 64 KB
NotaEl tamaño total de atributos de un mensaje no puede superar los 16 KB.
¿Cuánto tiempo se almacenan los mensajes en ApsaraMQ for RocketMQ?
-
Instancias de la serie 5.x:
Mínimo: 24 horas.
Máximo: 720 horas.
-
Instancias de la serie 4.x:
Standard Edition: La duración de almacenamiento es de 3 días. Los mensajes más antiguos se eliminan automáticamente.
Enterprise Platinum Edition: La duración predeterminada es de 3 días. Si el espacio adquirido resulta insuficiente, ApsaraMQ for RocketMQ elimina los mensajes más antiguos. En tal caso, la duración real podría ser menor a 3 días.
¿Cuál es la directiva de balanceo de carga de mensajes?
Instancias de la serie 5.x: Consulte 5.x series producer load balancing policy y 5.x series consumer load balancing policy.
Instancias de la serie 4.x: Consulte 4.x series message load balancing policy.
Si falla el consumo de un mensaje, ¿se vuelve a consumir?
Si el consumo falla, ApsaraMQ for RocketMQ reenvía el mensaje al consumidor para otro intento. Para más detalles sobre el mecanismo de reintento, consulte los siguientes temas:
¿Las instancias de ApsaraMQ for RocketMQ 5.x admiten consumo por difusión?
ApsaraMQ for RocketMQ permite que varios grupos de consumidores se suscriban al mismo mensaje y que cada grupo inicialice múltiples consumidores. Los grupos y consumidores pueden configurarse para consumir mensajes en los siguientes escenarios:

-
Consumo por difusión entre grupos de consumidores: Este escenario se ilustra en el lado izquierdo de la figura anterior. Cada grupo inicializa su propio consumidor, quien recibe todos los mensajes. Los temas entregan mensajes a múltiples suscriptores en una relación de uno a muchos.
Este modo suele usarse en escenarios como envío masivo desde gateways y distribución de configuraciones.
-
Consumo por clúster dentro de un grupo de consumidores: Este escenario se muestra en el lado derecho de la figura. Cada grupo inicializa varios consumidores y los mensajes se distribuyen entre todos ellos. Resulta útil para implementar particionamiento horizontal de tráfico y balanceo de carga dentro del grupo.
Este modo es adecuado para desacoplar microservicios.
En instancias de la serie 5.x, no necesita configurar por separado el código del SDK del cliente. Logre el efecto de difusión diseñando la relación de suscripción basada en consumo por difusión entre grupos de consumidores.
¿Cuál es el retraso máximo para un mensaje programado en ApsaraMQ for RocketMQ?
-
Instancias de la serie 5.x:
Las instancias Standard Edition de suscripción y pay-as-you-go, junto con las instancias Serverless Standard y Professional Edition, admiten un retraso máximo de 7 días.
Las instancias Professional Edition y Platinum Edition de suscripción y pay-as-you-go admiten un retraso máximo de 40 días.
-
Instancias de la serie 4.x: El retraso máximo es de 40 días.
Establezca el parámetro
msg.setStartDeliverTimede un mensaje en un momento dentro de los siguientes 40 días. El valor se expresa en milisegundos. Si especifica un valor mayor a 40 días, el broker no podrá entregar el mensaje.NotaExiste un retraso de 1 a 2 segundos entre la hora programada y la hora real de envío del mensaje.
¿Existen límites en el número de temas y grupos por instancia?
-
Instancias de la serie 5.x
Los límites de temas y grupos dependen del tipo de instancia adquirida. Para conocer los límites específicos, consulte Instance specifications.
-
Instancias de la serie 4.x
Tipo de instancia
Límite de temas
Límite de grupos
Instancia Standard Edition
Sin límite
NotaLas instancias de la serie 4.x se facturan según el número de temas. Para evitar cargos adicionales, elimine oportunamente los temas que ya no utilice. Para detalles de facturación, consulte Message sending and receiving pricing.
1,000
Instancia Enterprise Platinum Edition
Depende de la especificación de temas seleccionada al comprar
1,000
¿El almacenamiento de ApsaraMQ for RocketMQ requiere montar un disco?
No, no es necesario.
Solo debe seleccionar un tamaño de espacio de almacenamiento al crear una instancia Platinum Edition de la serie 4.x. El almacenamiento real se configura según el tamaño elegido.
Para otros tipos de instancia, la facturación se basa en la cantidad real de mensajes almacenados. No necesita configurar el almacenamiento.
¿Puedo habilitar o deshabilitar la función de cifrado de disco en una instancia existente?
No, no es posible. La función de cifrado de disco solo se habilita al crear una instancia. No puede activarla en una instancia existente ni deshabilitarla después de haberla activado.