Configure o Apache RocketMQ SDK for Java para enviar e receber mensagens pelo ApsaraMQ for RocketMQ 5.x.
Etapa 1: Instale o SDK
Importe as dependências via Maven ou baixe o pacote JAR. Para obter a versão mais recente do SDK, consulte Recommended versions.
Etapa 2: Crie recursos na cloud
Crie os seguintes recursos no console do ApsaraMQ for RocketMQ antes de executar o código de exemplo:
|
Recurso |
Descrição |
|
Endpoint da instância |
URL usada pelo cliente para se conectar ao ApsaraMQ for RocketMQ |
|
Topic |
Destino para onde os produtores enviam mensagens |
|
Consumer group |
Grupo de consumidores que assinam tópicos |
Para instruções detalhadas, consulte Step 2: Create resources.
Etapa 3: Execute o projeto de demonstração
Clone o projeto de demonstração do GitHub.
Atualize os parâmetros de conexão no código de exemplo com os recursos criados na Etapa 2.
Compile e execute o projeto.
Se o seu projeto usar o SDK rocketmq-client em vez do rocketmq-client-java, não é necessário baixar o projeto de demonstração. Consulte Sample code para exemplos de integração.