ApsaraMQ for RocketMQ ofrece SDK de cliente TCP y HTTP para varios lenguajes de programación. Esta guía le explica cómo activar el servicio, crear recursos y enviar sus primeros mensajes normales.
Elegir un protocolo
Cada instancia de ApsaraMQ for RocketMQ expone un endpoint TCP y un endpoint HTTP. Seleccione el protocolo adecuado para su carga de trabajo y utilice el SDK y el endpoint correspondientes.
|
Protocolo |
SDK |
|
TCP |
SDK de cliente TCP |
|
HTTP |
SDK de cliente HTTP |
Utilice siempre el SDK con su endpoint correspondiente. El SDK de cliente TCP se conecta únicamente al endpoint TCP, mientras que el SDK de cliente HTTP se conecta solo al endpoint HTTP.
Requisitos previos
Antes de empezar, asegúrese de contar con lo siguiente:
Una cuenta de Alibaba Cloud con ApsaraMQ for RocketMQ activado
Permisos de RAM para crear y gestionar recursos de ApsaraMQ for RocketMQ
Un entorno de cliente con el SDK instalado para su lenguaje de programación
Enviar y recibir mensajes normales
ApsaraMQ for RocketMQ admite cuatro tipos de mensaje. Los siguientes pasos utilizan mensajes normales como ejemplo. Para trabajar con mensajes ordenados, transaccionales o programados, consulte la documentación específica de cada tipo.
Paso 1: Activar el servicio y otorgar permisos
Habilite ApsaraMQ for RocketMQ en la consola de Alibaba Cloud y configure los permisos de RAM para su cuenta.
Paso 2: Crear recursos
Cree una instancia, un topic y un group en la consola de ApsaraMQ for RocketMQ.
Al crear el topic, seleccione Normal Message como tipo de mensaje. Cada topic admite un solo tipo de mensaje; por lo tanto, un topic de mensajes normales no puede enviar ni recibir otros tipos.
Se recomienda crear grupos separados para consumidores TCP y HTTP, ya que cada protocolo requiere un SDK de cliente distinto. Para consultar los límites de los grupos y los detalles de configuración, consulte Gestionar grupos.
Paso 3: Obtener el endpoint
Localice el endpoint TCP o HTTP de su instancia. Elija el endpoint que corresponda a su protocolo.
Los endpoints públicos y privados están disponibles para TCP y HTTP en todas las regiones:
|
Tipo de endpoint |
Cuándo utilizarlo |
|
Endpoint de VPC (recomendado) |
Cargas de trabajo de producción. Sin cargos por tráfico de Internet. |
|
Endpoint público |
Acceso entre regiones, centros de datos locales o acceso basado en Internet cuando Cloud Enterprise Network (CEN) no está disponible. Se aplican cargos por tráfico de salida. Para más detalles, consulte Facturación del tráfico de Internet. |
Paso 4: Enviar y recibir mensajes
Utilice el SDK de su lenguaje de programación para conectarse al endpoint, enviar mensajes al topic y suscribirse a los mensajes del topic.
Para TCP, consulte Enviar y suscribirse a mensajes con SDK de cliente TCP.
Para HTTP, consulte Enviar y suscribirse a mensajes con SDK de cliente HTTP.
El siguiente diagrama de flujo muestra el proceso integral:
