Envía un mensaje a un consumidor específico.
Nota
Esta operación permite comprobar si los mensajes de un tema específico pueden consumirlos los consumidores de un grupo de consumidores determinado. La operación obtiene el cuerpo del mensaje que especifica el parámetro MsgId, lo reencapsula para generar un nuevo mensaje y luego lo envía al consumidor indicado. El contenido del mensaje enviado al consumidor es idéntico al del mensaje original; sin embargo, no son el mismo mensaje porque utilizan identificadores distintos.
Límite de solicitudes
Cada cuenta de Alibaba Cloud puede invocar esta operación hasta 10 veces por segundo. Si la cantidad de solicitudes enviadas en un segundo alcanza el límite establecido, las nuevas solicitudes fallarán, lo cual podría interrumpir su servicio. Para obtener más información sobre los límites de solicitud de cada operación, consulte Límites de solicitudes de API.
Autorización
De forma predeterminada, las cuentas de Alibaba Cloud pueden invocar esta operación. Un usuario de Resource Access Management (RAM) solo podrá hacerlo después de recibir los permisos obligatorios. En la tabla a continuación se describen los permisos que debe otorgar a un usuario de RAM para que pueda invocar esta operación. Para obtener más información sobre cómo otorgar permisos, consulte Políticas.
|
API |
Acción |
Recurso en una instancia con espacio de nombres |
Recurso en una instancia sin espacio de nombres |
|
OnsMessagePush |
mq:QueryInstanceBaseInfo mq:SUB |
acs:mq:::{instanceId}%{topic} |
acs:mq:::{topic} |
Parámetros de solicitud
|
Parámetro |
Tipo |
Obligatorio |
Ejemplo |
Descripción |
|
Action |
String |
Sí |
OnsMessagePush |
La operación que desea ejecutar. Establezca el valor como OnsMessagePush. |
|
GroupId |
String |
Sí |
GID_test_group_id |
El identificador del grupo de consumidores. Para obtener más información sobre qué es un grupo de consumidores, consulte Términos. |
|
ClientId |
String |
Sí |
30.5.121.**@24813#-1999745829#-1737591554#453111174894656 |
El identificador del consumidor. Invoque la operación OnsConsumerGetConnection para consultar el identificador de cada consumidor dentro de un grupo. |
|
MsgId |
String |
Sí |
0BC1669963053CF68F733BB70396**** |
El identificador del mensaje. |
|
Topic |
String |
Sí |
test-mq_topic |
El tema al que se envía el mensaje. |
|
InstanceId |
String |
Sí |
MQ_INST_111111111111_DOxxxxxx |
El identificador de la instancia de Message Queue for Apache RocketMQ a la que pertenece el grupo de consumidores especificado. |
Parámetros de respuesta
|
Parámetro |
Tipo |
Ejemplo |
Descripción |
|
RequestId |
String |
B8EDC90D-F726-4B9E-8BEF-F0DD25EC**** |
El identificador de la solicitud. El sistema genera un ID único para cada solicitud, el cual sirve para solucionar problemas. |
Ejemplos
Solicitudes de ejemplo
http(s)://ons.cn-zhangjiakou.aliyuncs.com/?Action=OnsMessagePush
&GroupId=GID_test_group_id
&ClientId=30.5.121.**@24813#-1999745829#-1737591554#453111174894656
&MsgId=0BC1669963053CF68F733BB70396****
&Topic=test-mq_topic
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&<Common request parameters>Respuestas exitosas de ejemplo
Formato XML
HTTP/1.1 200 OK
Content-Type:application/xml
<OnsMessagePushResponse>
<RequestId>B8EDC90D-F726-4B9E-8BEF-F0DD25EC****</RequestId>
</OnsMessagePushResponse>Formato JSON
HTTP/1.1 200 OK
Content-Type:application/json
{
"RequestId" : "B8EDC90D-F726-4B9E-8BEF-F0DD25EC****"
}Códigos de error
Para consultar la lista de códigos de error, visite el Centro de errores de API.