Consulta o status de conexão de um consumidor em um grupo especificado.
Observação
Se houver mensagens acumuladas em um tópico, chame esta operação para verificar se o consumidor está online.
Limite de solicitações
Cada conta Alibaba Cloud pode chamar esta operação até 10 vezes por segundo. Se o número de solicitações enviadas em um segundo atingir esse limite, as novas requisições falharão e poderão interromper seus serviços. Para obter mais informações sobre os limites de cada operação, consulte Limites de solicitação da API.
Autorização
Contas Alibaba Cloud têm permissão padrão para chamar esta operação. Usuários do Resource Access Management (RAM) precisam receber as permissões necessárias antes de executá-la. A tabela a seguir descreve as permissões obrigatórias para usuários RAM. Para saber como conceder permissões, consulte Políticas.
|
API |
Action |
Recurso em uma instância com namespace |
Recurso em uma instância sem namespace |
|
OnsConsumerGetConnection |
mq:QueryInstanceBaseInfo mq:QueryConsumerConnection |
acs:mq:::{instanceId}%{groupId} |
acs:mq:::{groupId} |
Parâmetros da solicitação
|
Parâmetro |
Tipo |
Obrigatório |
Exemplo |
Descrição |
|
Action |
String |
Sim |
OnsConsumerGetConnection |
Operação a ser executada. Defina o valor como OnsConsumerGetConnection. |
|
GroupId |
String |
Sim |
GID_test_consumer_id |
ID do grupo de consumidores ao qual pertence o consumidor que você deseja consultar. |
|
InstanceId |
String |
Sim |
MQ_INST_111111111111_DOxxxxxx |
ID da instância que contém o consumidor a ser consultado. |
Parâmetros de resposta
|
Parâmetro |
Tipo |
Exemplo |
Descrição |
|
RequestId |
String |
DE4140C7-F42D-473D-A5FF-B1E31692**** |
ID da solicitação. O sistema gera um ID exclusivo para cada requisição, permitindo solucionar problemas com base nesse identificador. |
|
Data |
Object |
Dados retornados pela operação. |
|
|
ConnectionList |
Array of ConnectionDo |
Informações de conexão retornadas. |
|
|
ConnectionDo |
|||
|
Version |
String |
V4_3_6 |
Versão do cliente consumidor. |
|
ClientAddr |
String |
30.5.121.** |
Endereço IP e porta do consumidor. |
|
Language |
String |
JAVA |
Linguagem de programação usada no desenvolvimento da aplicação consumidora. |
|
ClientId |
String |
30.5.121.**@24813#-1999745829#-1737591554#453111174894656 |
ID do consumidor. |
Exemplos
Exemplos de solicitações
http(s)://ons.cn-hangzhou.aliyuncs.com/?Action=OnsConsumerGetConnection
&GroupId=GID_test_consumer_id
&InstanceId=MQ_INST_111111111111_DOxxxxxx
&<Common request parameters>
Exemplos de respostas de sucesso
Formato XML
HTTP/1.1 200 OK
Content-Type:application/xml
<OnsConsumerGetConnectionResponse>
<Data>
<ConnectionList>
<ConnectionDo>
<ClientAddr>30.5.121.**</ClientAddr>
<Language>JAVA</Language>
<Version>V4_3_6</Version>
<ClientId>30.5.121.**@24813#-1999745829#-1737591554#453111174894656</ClientId>
</ConnectionDo>
</ConnectionList>
</Data>
<RequestId>DE4140C7-F42D-473D-A5FF-B1E31692****</RequestId>
</OnsConsumerGetConnectionResponse>
Formato JSON
HTTP/1.1 200 OK
Content-Type:application/json
{
"Data" : {
"ConnectionList" : {
"ConnectionDo" : [ {
"ClientAddr" : "30.5.121.**",
"Language" : "JAVA",
"Version" : "V4_3_6",
"ClientId" : "30.5.121.**@24813#-1999745829#-1737591554#453111174894656"
} ]
}
},
"RequestId" : "DE4140C7-F42D-473D-A5FF-B1E31692****"
}
Códigos de erro
Para obter uma lista de códigos de erro, visite a Central de Erros da API.
Visualize o status de conexão dos consumidores no console
No Message Queue for Apache RocketMQ console, visualize o status de conexão de cada consumidor em um grupo. Para mais detalhes, consulte Visualizar o status dos consumidores.