1、开通RocketMQ

2、

3、

4、

5、回到微消息队列 MQTT 版控制台实例详情 > 实例信息

在实例信息页签的获取接入点信息 区域，即可看到接入点信息

6、步骤二：创建父级 Topic

7、步骤三：创建 Group ID

7、步骤四：调用 Java SDK 收发消息

1. 下载第三方的开源 Java SDK。下载地址为 Eclipse Paho Java Client。
2. 下载阿里云 MQTT 的 Java SDK 的 Demo 示例作为您代码开发的参考。下载地址为 mqtt-java-demo。
3. 解压该 Demo 工程包至您指定的文件夹。
4. 在 Intellij IDEA 中，导入解压后的文件以创建相应的工程，并确认 pom.xml 中已包含以下依赖。

<dependencies>
        <dependency>
            <groupId>commons-codec</groupId>
            <artifactId>commons-codec</artifactId>
            <version>1.10</version>
        </dependency>
        <dependency>
            <groupId>org.eclipse.paho</groupId>
            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
            <version>1.2.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.48</version>
        </dependency>
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-onsmqtt</artifactId>
            <version>1.0.3</version>
        </dependency>
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-core</artifactId>
            <version>4.5.0</version>
        </dependency>
</dependencies>

• 在 MQ4IoTSendMessageToMQ4IoTUseSignatureMode.java 类中，按代码注释说明填写相应参数，主要涉及步骤一至步骤三所创建的 MQTT 资源，然后执行 Main 函数运行代码实现消息收发。

  示例代码详情请参见 MQTTSendMessageToMQTT。