Antes de usar o SDK para enviar e receber mensagens, crie os recursos necessários do ApsaraMQ for RocketMQ: uma instância, um tópico e um grupo de consumidores, e especifique esses recursos no código do SDK. Você também precisa do endpoint da instância.
Pré-requisitos
Informações de contexto
Você pode criar recursos no console ou por meio de chamadas de API. O procedimento a seguir usa o console.
Para criar recursos usando o OpenAPI, consulte os seguintes tópicos:
Limites
-
Restrições de região
Certifique-se de criar a instância na mesma região da VPC e do vSwitch indicados nos pré-requisitos.
-
Convenções de nomenclatura
Para conhecer as convenções de nomenclatura para instâncias, tópicos e grupos de consumidores, consulte Quotas and limits.
-
Restrições de tipo de tópico
O tipo de mensagem de um tópico deve corresponder ao tipo de mensagem que você envia e recebe. Por exemplo, se criar um tópico para mensagens normais, você só poderá usá-lo para enviar e receber mensagens normais, e não mensagens ordenadas. Para mais informações, consulte Topic usage recommendations.
Criar uma instância
Acesse o console do ApsaraMQ for RocketMQ. No painel de navegação à esquerda, clique em Instances.
Na barra de navegação superior, selecione uma região, por exemplo, China (Hangzhou).
-
Na página Instances, clique em Create Instance. No painel Create Message Queue for Apache RocketMQ Instance, defina Instance Version como V5.0, selecione um Product Type e, em seguida, clique em OK.
O ApsaraMQ for RocketMQ oferece suporte aos seguintes tipos de product:
Assinatura: modelo pré-pago com faturamento mensal da especificação de computação da instância.
Pagamento conforme o uso: modelo pós-pago com faturamento horário da especificação de computação da instância.
-
Serverless: modelo de pagamento conforme o uso com faturamento baseado no número total de solicitações de mensagens.
NotaAs instâncias Serverless estão disponíveis nas seguintes regiões: China (Hangzhou), China (Zhangjiakou), China (Beijing), China (Shenzhen), Singapore (Singapore), Germany (Frankfurt), US (Virginia) e US (Silicon Valley). Novas regiões receberão suporte ao longo do tempo. Para verificar a disponibilidade atual, consulte Supported regions.
Para obter detalhes sobre itens faturáveis e cenários aplicáveis, consulte Billing overview.
-
Na página de compra, selecione as especificações da instância, clique em Buy Now e conclua o pagamento.
Consulte as tabelas a seguir ao criar uma instância. Para obter detalhes sobre cada parâmetro, consulte Selecione a edição da instância.
Serverless
Parâmetro
Valor de exemplo
Primary Edition
Standard
Modo de faturamento
O padrão é Pay-by-request.
Especificação de armazenamento de mensagens
Não é necessário selecionar uma capacidade de armazenamento. O faturamento é baseado no espaço de armazenamento real utilizado.
ID da VPC
vpc-bp1cg09dua6sgh0
O ID da VPC que você criou nos pré-requisitos.
ImportanteApós a criação da instância, não é possível alterar a VPC selecionada. Para alterar a VPC associada, libere primeiro a instância comprada e, em seguida, compre uma nova.
vSwitch ID
vsw-bp1vqb0p9nz3irz
O ID do vSwitch que você criou nos pré-requisitos.
Selecione dois vSwitch ID para uma instância Serverless.
ImportanteApós a criação da instância, não é possível alterar o vSwitch selecionado. Modifique o vSwitch associado: libere primeiro a instância comprada e, em seguida, compre uma nova.
Internet Access
Off
Nota-
Este procedimento usa o acesso por VPC como exemplo; portanto, o acesso à Internet fica desativado por padrão. Para acessar o service pela Internet, defina Internet Access Type como Enabled.
Tipo de acesso à intranet
O padrão é Pay-By-Data-Transfer.
As instâncias Serverless oferecem suporte apenas ao acesso por VPC, e não ao acesso pela Internet.
Resource Group
Selecione o grupo de recursos padrão.
Security Group
Selecione o grupo de segurança que você criou nos pré-requisitos.
Assinatura ou pagamento conforme o uso
Parâmetro
Valor de exemplo
Primary Edition
Standard
Edição de subcategoria
Cluster High-availability Edition (Recomendada para ambientes de produção)
Especificação de computação para envio e recebimento de mensagens
rmq.s2,2xlarge
ID da VPC
vpc-bp1cg09dua6sgh0
O ID da VPC que você criou nos pré-requisitos.
ImportanteApós a criação da instância, não é possível alterar a VPC selecionada. Para alterar a VPC associada, libere primeiro a instância comprada e, em seguida, compre uma nova.
vSwitch ID
vsw-bp1vqb0p9nz3irz
O ID do vSwitch que você criou nos pré-requisitos.
ImportanteApós a criação da instância, não é possível alterar o vSwitch selecionado. Para alterar o vSwitch associado, libere primeiro a instância comprada e, em seguida, compre uma nova.
Tipo de acesso público
Off
NotaEste procedimento usa o acesso por VPC como exemplo; portanto, o acesso à Internet fica desativado por padrão. Para acessar o service pela Internet, defina o Internet access type como Enabled.
Resource Group
Selecione o grupo de recursos padrão.
Disk Encryption
Off
NotaA criptografia de disco é compatível apenas com instâncias da Platinum Edition.
Disk Encryption Key
key-hzz66c8207****
NotaO ID da chave usada para a criptografia de disco na mesma região. Este parâmetro é necessário apenas quando Disk Encryption está definido como Enable.
-
Obter o endpoint da instância
Na página Instances, clique no nome da instância de destino.
-
Na página Instance Details, visualize as informações do endpoint na seção TCP Endpoint.
Endpoint de VPC: use este endpoint para acessar o ApsaraMQ for RocketMQ a partir de uma VPC. Este endpoint é fornecido por padrão.
Endpoint público: use este endpoint para acessar o service pela Internet. Este endpoint é exibido apenas se o acesso público estiver ativado.
Obter o nome de usuário e a senha da instância
As etapas a seguir mostram como obter o nome de usuário e a senha do sistema por meio do método de controle de acesso padrão: autenticação inteligente.
Para usar a autenticação de lista de controle de acesso (ACL), crie um usuário ACL, configure as permissões e use o nome de usuário e a senha da ACL. Para mais informações, consulte User authentication.
Ao conectar um cliente ao servidor do ApsaraMQ for RocketMQ, configure um nome de usuário e uma senha com base no método de acesso.
Para acessar o servidor pela Internet: configure o nome de usuário e a senha da instância.
Para acessar o servidor a partir de uma VPC: em instâncias Serverless, as credenciais não são necessárias se o acesso sem autenticação estiver ativado. Para outros tipos de instância, a autenticação é automática e não requer credenciais.
Na página Instances, clique no nome da instância de destino.
No painel de navegação à esquerda, clique em Access Control.
Clique na guia Intelligent Authentication para visualizar o Username e a Password da instância.
Criar um tópico
Na página Instances, clique no nome da instância de destino.
No painel de navegação à esquerda, clique em Topics. Em seguida, na página Topics, clique em Create Topic.
No painel Create Topic, insira um nome e uma descrição para o tópico, defina Message Type como Normal Message e, em seguida, clique em OK.
Criar um grupo de consumidores
Na página Instances, clique no nome da instância de destino.
No painel de navegação à esquerda, clique em Groups. Em seguida, na página Groups, clique em Create Group.
No painel Create Group, insira um Group ID, mantenha os outros parâmetros com as configurações padrão e, em seguida, clique em OK.