Crie um projeto de teste com a demonstração do SDK na nuvem do ApsaraMQ for MQTT para Java. Esta demonstração abrange três tarefas: envio de mensagens, inscrição em mensagens e inscrição em notificações de status do cliente.
O SDK na nuvem conecta aplicativos de back-end ao broker do ApsaraMQ for MQTT por meio do protocolo AMQP (Advanced Message Queuing Protocol) na porta 5672.
Pré-requisitos
Antes de começar, verifique se você tem:
IntelliJ IDEA Ultimate Edition ou Eclipse instalado
JDK 1.8 ou posterior instalado
Uma instância, um tópico e um grupo do ApsaraMQ for MQTT criados no console
Um par de AccessKey (AccessKey ID e AccessKey secret) de um usuário do Resource Access Management (RAM)
O endpoint da sua instância do ApsaraMQ for MQTT
Classes de exemplo
O projeto de demonstração contém três classes:
|
**Classe** |
**Finalidade** |
|
|
Envia mensagens para o broker do ApsaraMQ for MQTT |
|
|
Inscreve-se em mensagens do broker do ApsaraMQ for MQTT |
|
|
Inscreve-se em notificações de status online/offline do cliente |
Etapa 1: Baixe e importe a demonstração
-
Clone ou baixe a demonstração do repositório mqtt-server-sdk-demo. Após a extração, a pasta
mqtt-server-sdk-demo-mainconterá o código de exemplo em:java-demo\src\main\java\com\aliyun\openservices\lmq\example Abra o IntelliJ IDEA e importe o projeto
mqtt-server-sdk-demo-main.
Etapa 2: Configure os parâmetros de conexão
Abra uma classe de exemplo e substitua os parâmetros a seguir pelas informações do seu recurso:
// Endpoint of your ApsaraMQ for MQTT instance.
// For the endpoint format, see Common parameters.
String domain = "<your-instance-endpoint>";
// Cloud SDK port. Fixed value: 5672.
int port = 5672;
// Instance ID of your ApsaraMQ for MQTT instance.
String instanceId = "<your-instance-id>";
// AccessKey ID and AccessKey secret of your RAM user.
String accessKey = "<your-access-key-id>";
String secretKey = "<your-access-key-secret>";
// Parent topic created in the console for messaging.
String firstTopic = "<your-parent-topic>";
// Subtopic. No need to create in the console.
// For naming conventions, see Terms.
String secondTopic = "<your-subtopic>";
// Group ID created in the console for messaging.
String mqttGroupId = "<your-group-id>";
A tabela a seguir descreve cada parâmetro:
|
**Parâmetro** |
**Descrição** |
**Exemplo** |
|
|
Endpoint da sua instância do ApsaraMQ for MQTT. Para obter o formato, consulte Parâmetros comuns. |
mqtt-cn-xxx.mqtt.aliyuncs.com |
|
|
ID da instância obtido no console do ApsaraMQ for MQTT |
mqtt-cn-xxx |
|
|
AccessKey ID do seu usuário RAM |
LTAI5tXxx |
|
|
AccessKey secret do seu usuário RAM |
xXxXxXx |
|
|
Tópico pai criado no console |
TestTopic |
|
|
Nome do subtópico. Não é necessário criá-lo no console. Para convenções de nomenclatura, consulte Termos. |
/level2/level3 |
|
|
ID do grupo criado no console |
GID_Test |
Etapa 3: Execute a demonstração
Após configurar os parâmetros, clique em com o botão direito na classe de exemplo no IntelliJ IDEA e execute a função main().
Verifique os resultados
Consulte os rastreamentos de mensagem no console do ApsaraMQ for MQTT para confirme o envio e o recebimento das mensagens. Para obter instruções, consulte Consultar os rastreamentos de mensagem.