ApsaraMQ for MQTT:Run the cloud SDK demo

Prerequisites

Before you begin, make sure that you have:

• IntelliJ IDEA Ultimate Edition or Eclipse installed

• JDK 1.8 or later installed

• An ApsaraMQ for MQTT instance, topic, and group created in the console

• An AccessKey pair (AccessKey ID and AccessKey secret) for a Resource Access Management (RAM) user

• The endpoint of your ApsaraMQ for MQTT instance

Sample classes

The demo project contains three classes:

Step 1: Download and import the demo

1. Clone or download the demo from mqtt-server-sdk-demo. After extraction, the mqtt-server-sdk-demo-main folder contains the sample code at:

      java-demo\src\main\java\com\aliyun\openservices\lmq\example

2. Open IntelliJ IDEA and import the mqtt-server-sdk-demo-main project.

Step 2: Configure connection parameters

Open a sample class and replace the following parameters with your resource information:

// 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>";

The following table describes each parameter:

Step 3: Run the demo

After you configure the parameters, right-click the sample class in IntelliJ IDEA and run the main() function.

Verify the results

Query message traces in the ApsaraMQ for MQTT console to confirm that messages were sent and received. For instructions, see Query the message traces.