Quais são as vantagens das instâncias do ApsaraMQ for RocketMQ 5.x em relação às instâncias 4.x?
Quais versões de cliente são compatíveis com instâncias do ApsaraMQ for RocketMQ 5.x?
Quais linguagens de programação o cliente do ApsaraMQ for RocketMQ suporta?
Como ativar o acesso à rede pública para o ApsaraMQ for RocketMQ?
Qual é a diferença entre mensagens ordenadas e mensagens normais?
Onde encontro o nome de usuário e a senha para conectar ao servidor?
Existe limite para o número de tags em uma assinatura do ApsaraMQ for RocketMQ?
Qual é a diferença entre consumo por cluster e consumo por broadcast no ApsaraMQ for RocketMQ?
Como as mensagens são consumidas quando vários grupos de consumidores assinam o mesmo tópico?
Qual é o tamanho máximo do corpo da mensagem no ApsaraMQ for RocketMQ?
Por quanto tempo as mensagens ficam armazenadas no ApsaraMQ for RocketMQ?
Se o consumo de uma mensagem falhar, ela será consumida novamente?
As instâncias do ApsaraMQ for RocketMQ 5.x suportam consumo por broadcast?
Qual é o atraso máximo para uma mensagem agendada no ApsaraMQ for RocketMQ?
Existem limites para o número de tópicos e grupos em uma instância?
O armazenamento do ApsaraMQ for RocketMQ exige a montagem de um disco?
Posso ativar ou desativar o recurso de criptografia de disco para uma instância adquirida?
Como consulto o espaço de armazenamento de uma instância do RocketMQ?
Como determino a especificação de TPS alvo ao fazer downgrade de uma instância do RocketMQ 5.x?
Quais são as vantagens das instâncias do ApsaraMQ for RocketMQ 5.x em relação às instâncias 4.x?
Em comparação com versões anteriores, as instâncias 5.x oferecem arquitetura mais avançada, menor complexidade para desenvolvimento e O&M, custos mais flexíveis e modelos de vendas mais abrangentes. Para obter mais informações, consulte Diferenças e compatibilidade entre instâncias 4.x e 5.x.
Quais versões de cliente são compatíveis com instâncias do ApsaraMQ for RocketMQ 5.x?
As instâncias do ApsaraMQ for RocketMQ 5.x são compatíveis com clientes open source Apache RocketMQ 5.x, 4.x e 3.x, além de clientes ApsaraMQ for RocketMQ ONS 1.x. Para obter mais informações, consulte Diferenças e compatibilidade entre instâncias 4.x e 5.x.
Quais linguagens de programação o cliente do ApsaraMQ for RocketMQ suporta?
Série ApsaraMQ for RocketMQ 5.x: suporta SDKs Java, C/C++, C# e Go via protocolo TCP. Para obter mais informações, consulte Visão geral da referência de SDK da série 5.x.
Série ApsaraMQ for RocketMQ 4.x: suporta SDKs Java, C/C# e .NET via protocolo TCP, além de SDKs Java, Go, Python, Node.js, PHP, C# e C++ via protocolo HTTP. Para obter mais informações, consulte Visão geral da referência de SDK da série 4.x.
Como ativar o acesso à rede pública para o ApsaraMQ for RocketMQ?
Instâncias da série 5.x: ative o acesso à rede pública durante a compra da instância. Caso não tenha ativado esse acesso na criação, faça upgrade da instância para habilitá-lo. Para detalhes sobre faturamento do acesso à rede pública nas instâncias da série 5.x, consulte Taxas de acesso à rede pública.
Instâncias da série 4.x: os endpoints de rede pública já vêm habilitados por padrão, sem necessidade de configuração manual. Para detalhes sobre faturamento do acesso à rede pública nas instâncias da série 4.x, consulte Preços de tráfego de rede pública.
Obtenha o endpoint de rede pública na página Instance Details no console do ApsaraMQ for RocketMQ.
Qual é a diferença entre mensagens ordenadas e mensagens normais?
Mensagens normais não garantem que o consumo ocorra na mesma ordem da produção.
No caso de mensagens ordenadas, todas as mensagens são particionadas com base em uma ShardingKey. As mensagens dentro da mesma partição seguem o modelo FIFO (first-in, first-out). A ordem é garantida apenas dentro de cada partição, mas não entre partições diferentes. Para obter mais informações, consulte Mensagens ordenadas.
Onde encontro o nome de usuário e a senha para conectar ao servidor?
-
Instâncias da série 5.x: para acessar uma instância dessa série, informe o nome de usuário e a senha correspondentes. Exemplo:
/** * 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"));
-
Instâncias da série 4.x: para acessar uma instância dessa série, informe o AccessKey ID e o AccessKey secret da sua conta Alibaba Cloud ou do usuário RAM. Exemplo:
// 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 criar um AccessKey, consulte Criar um AccessKey.
Onde encontro o endpoint para conectar ao servidor?
Instâncias 5.x: utilize endpoints TCP. O acesso via SDKs HTTP não é suportado.
Instâncias 4.x: utilize endpoints TCP ou HTTP. Selecione o endpoint correspondente ao protocolo do seu SDK. Endpoints de protocolos diferentes não são intercambiáveis.
Obter pelo console
Faça login no console do ApsaraMQ for RocketMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior, selecione uma região, como China (Hangzhou). Na página Instances, clique em nome da instância que deseja gerenciar.
Na página Instance Details, visualize os endpoints da instância na aba Basic Information.
Obter o endpoint chamando uma operação de API
Instâncias 5.x: chame a operação GetInstance.
Instâncias 4.x: chame a operação OnsInstanceBaseInfo.
Existe limite para o número de tags em uma assinatura do ApsaraMQ for RocketMQ?
O produtor define as tags ao enviar uma mensagem. Cada mensagem pode ter apenas uma tag.
Ao assinar mensagens, o consumidor não tem limite quanto ao número de tags na regra de filtro. Contudo, a expressão de filtro não deve ser excessivamente longa. Recomendamos mantê-la abaixo de 1 KB.
Para obter mais informações, consulte Melhores práticas para tópicos e tags.
Qual é a diferença entre consumo por cluster e consumo por broadcast no ApsaraMQ for RocketMQ?
Consumo por cluster: neste modo, o ApsaraMQ for RocketMQ garante que apenas um consumidor dentro do grupo processe cada mensagem.
Consumo por broadcast: neste modo, o ApsaraMQ for RocketMQ envia cada mensagem para todos os consumidores do grupo. Isso assegura que cada consumidor processe a mensagem pelo menos uma vez.
Para obter mais informações, consulte Consumo por cluster e consumo por broadcast.
Como as mensagens são consumidas quando vários grupos assinam o mesmo tópico?
Um grupo de consumidores pode assinar vários tópicos, e um tópico pode ser assinado por múltiplos grupos. Quando isso ocorre, cada mensagem é entregue uma vez a cada grupo de consumidores. Como os grupos são isolados entre si, o consumo acontece simultaneamente em cada um deles.
Qual é o tamanho máximo do corpo da mensagem no ApsaraMQ for RocketMQ?
Instâncias da série 5.x:
-
Instâncias da série 4.x:
Mensagem normal ou ordenada: 4 MB
Mensagem transacional, agendada ou atrasada: 64 KB
NotaO tamanho total dos atributos de uma mensagem não pode exceder 16 KB.
Por quanto tempo as mensagens ficam armazenadas no ApsaraMQ for RocketMQ?
-
Instâncias da série 5.x:
-
Instâncias da série 4.x:
Standard Edition: a duração de armazenamento é de 3 dias. Mensagens mais antigas são excluídas automaticamente.
Enterprise Platinum Edition: a duração padrão de armazenamento é de 3 dias. Se o espaço adquirido for insuficiente, o ApsaraMQ for RocketMQ remove as mensagens mais antigas. Nesse cenário, a retenção efetiva pode ser inferior a 3 dias.
Qual é a política de balanceamento de carga de mensagens?
Instâncias da série 5.x: consulte Política de balanceamento de carga do produtor da série 5.x e Política de balanceamento de carga do consumidor da série 5.x.
Instâncias da série 4.x: consulte Política de balanceamento de carga de mensagens da série 4.x.
Se o consumo de uma mensagem falhar, ela será consumida novamente?
Quando o consumo falha, o ApsaraMQ for RocketMQ reentrega a mensagem ao consumidor para nova tentativa. Para detalhes sobre o mecanismo de retentativa, consulte os seguintes tópicos:
As instâncias do ApsaraMQ for RocketMQ 5.x suportam consumo por broadcast?
O ApsaraMQ for RocketMQ permite que vários grupos de consumidores assinem a mesma mensagem e que cada grupo inicialize múltiplos consumidores. Configure grupos e consumidores para os seguintes cenários de consumo:

-
Consumo por broadcast entre grupos de consumidores: este cenário aparece no lado esquerdo da figura anterior. Cada grupo inicializa seu próprio consumidor, que recebe todas as mensagens. Os tópicos entregam mensagens a vários assinantes em uma relação de um para muitos.
Esse modo é comum em casos como push de gateway e push de configurações.
-
Consumo por cluster dentro de um grupo de consumidores: este cenário aparece no lado direito da figura anterior. Cada grupo inicializa vários consumidores, e as mensagens são distribuídas entre eles. Essa abordagem facilita o particionamento horizontal de tráfego e o balanceamento de carga interno.
Esse modo é ideal para desacoplamento de microsserviços.
Nas instâncias da série 5.x, não é necessário ajustar o código do SDK do cliente separadamente. Obtenha o efeito de broadcast projetando a relação de assinatura com base no consumo por broadcast entre grupos de consumidores.
Qual é o atraso máximo para uma mensagem agendada no ApsaraMQ for RocketMQ?
-
Instâncias da série 5.x:
-
Instâncias da série 4.x: o atraso máximo é de 40 dias.
Defina o parâmetro
msg.setStartDeliverTimeda mensagem para um momento dentro dos próximos 40 dias. O valor deve estar em milissegundos. Valores superiores a 40 dias impedem a entrega da mensagem pelo broker.NotaExiste um atraso de 1 a 2 segundos entre o horário agendado e o envio efetivo da mensagem.
Existem limites para o número de tópicos e grupos em uma instância?
-
Instâncias da série 5.x
Os limites de tópicos e grupos variam conforme o tipo de instância adquirido. Para valores específicos, consulte Especificações da instância.
-
Instâncias da série 4.x
Tipo de instância
Limite de tópicos
Limite de grupos
Instância Standard Edition
Ilimitado
NotaAs instâncias da série 4.x são cobradas com base no número de tópicos. Para evitar custos extras, exclua prontamente os tópicos que não estiverem mais em uso. Para detalhes de faturamento, consulte Preços de envio e recebimento de mensagens.
1.000
Instância Enterprise Platinum Edition
Depende da especificação de tópicos selecionada na compra
1.000
O armazenamento do ApsaraMQ for RocketMQ exige a montagem de um disco?
Não.
Selecione o tamanho do espaço de armazenamento apenas ao criar uma instância Platinum Edition da série 4.x. O armazenamento real é configurado conforme o tamanho escolhido.
Para outros tipos de instância, o faturamento considera o volume real de mensagens armazenadas. Não é preciso configurar o armazenamento manualmente.
Posso ativar ou desativar o recurso de criptografia de disco para uma instância adquirida?
Não. A criptografia de disco só pode ser ativada durante a criação da instância. Não é possível habilitar esse recurso em uma instância existente nem desativá-lo após a ativação.