快速使用MQTT的Java SDK收发消息（跨产品数据流入）

网络访问

使用流程

后端应用消息发送至MQTT客户端的使用流程如下所示。

步骤一：创建MQTT实例并获取接入点

1. 登录微消息队列MQTT版控制台，在顶部菜单栏选择实例所在地域。
2. 在概览页面的实例列表区域， 点击这里创建您的第一个实例。
3. 在售卖页面，按需选择您所需的实例规格，单击立即购买。
   您可购买包年包月或按量付费实例，两种实例的计费详情请参见计费说明。此处以按量付费实例为例。
4. 在确认订单页面，选中微消息队列 for loT （按量付费）服务协议，单击立即开通。
   此处以按量付费实例为例。
   支付完成后，即可看到以下界面，说明已购买成功。
5. 回到微消息队列MQTT版控制台，在顶部菜单栏将地域切换为您所购买的实例所对应的地域。
6. 在左侧导航栏，选择实例详情 > 实例信息。
7. 在实例信息页签的获取接入点信息 区域，即可看到接入点信息，本文示例以公网接入点为例。

步骤二：创建父级Topic

MQTT协议支持多级Topic，父级Topic需在控制台或调用OpenAPI创建，子级Topic无需创建，Topic详情请参见名词解释。本文以在控制台创建父级Topic为例。

1. 在左侧导航栏，选择 Topic 管理 > 创建 Topic 。
2. 在创建 Topic 对话框，输入 Topic 以及描述，单击确认。
   您可以在 Topic 管理页面查看刚创建的 Topic。

步骤三：创建Group ID

Group ID详情请参见名词解释。

1. 在左侧导航栏，选择 Group 管理 > 创建 Group ID。
2. 在创建 Group ID 对话框，输入 Group ID，然后单击确认。
   您可以在 Group ID 列表中查看到刚创建的 Group ID。

步骤四：创建数据流入规则

规则中填写的参数需与您创建的资源保持一致。

1. 在左侧导航栏，选择规则管理 > 创建规则 。
2. 在创建规则面板，单击数据流入页签。
3. 在数据流入页签，按提示填写以下参数，单击确定。

   参数	取值示例	说明
   规则 ID	111111	规则的全局唯一标识，说明如下： 只能包含字母、数字、横划线（-）和下划线（_），至少包含一个字母或数字。 名称长度限制在 3~64 字符之间，长于 64 字符将被自动截取。 创建后无法更新。
   规则描述	migrate from rocketmq	对规则的描述。
   状态	启用	是否启用当前规则，取值说明如下： 启用 禁用
   数据源 说明 当前仅支持消息队列RocketMQ版。
   云产品	消息队列 RocketMQ	指定您需将哪个源云产品的数据流入至微消息队列 MQTT 版。
   实例 ID	MQ_INST_13801563067*****_BbyOD2jQ	指定的源云产品的实例 ID。
   Topic	Topic_test	指定的源云产品的资源键值，即消息队列 RocketMQ 版的 Topic。Topic_test 的数据将流转至目标微消息队列 MQTT 版的 Topic。
   流转目标
   Topic	TopicA	指定您需将其他源云产品的数据导入至微消息队列 MQTT 版的哪个目标 Topic。

   您可以在规则管理的规则列表查看到刚创建的数据流入规则。

步骤五：调用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.openservices</groupId>
               <artifactId>ons-client</artifactId>
               <version>1.8.5.Final</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>

   说明 ons-client的版本详情请参见版本说明。
5. 在RocketMQSendMessageToMQ4IoT.java类中，按代码注释说明填写相应参数，主要涉及步骤一至步骤三所创建的MQTT资源以及您在消息队列RocketMQ版创建的相应资源，然后执行Main函数运行代码实现消息收发。
   示例代码详情请参见RocketMQSendMessageToMQ4IoT.java。

结果验证

完成消息收发后，您可在微消息队列MQTT版控制台查询轨迹以验证消息是否发送并接收成功。详情请参见查询消息轨迹。

更多信息

• 快速使用MQTT的Java SDK收发消息（无跨产品数据互通）
• 快速使用MQTT的Java SDK收发消息（跨产品数据流出）
• 快速使用MQTT的Java SDK收发消息（客户端上下线通知）