本demo主要以 Java 为例,面向初次接触OneNET消息队列MQ的开发者,演示如何一步一步搭建测试工程
下载demo工程并解压,解压后可以看到本地新增了OneNET-MQ-Reconn-demo文件夹
在 IDE(以 Eclipse 为例)中,选择 File -> Import,选择 Import 类型为 Existing Maven Projects
点击 Next,点击 Browse,选择解压后的OneNET-MQ-demo文件夹
点击 Finish,完成工程导入
demo 工程导入时需要加载依赖的jar包,整个导入过程需要等待约1分钟
请按照如下说明,根据在平台创建的资源参数,修改 MqClient.java 中的 MqClient 类
demo中30 - 32行:
String userName = "您的MQ实例名称";
String mqTopic = "您创建的topic名称";
String mqSub = "您创建的订阅名称";
64 - 66行:
String userName = "您的MQ实例名称";
String accessKey = "您的MQ access_key";
String expirationTime = "您自定义的鉴权参数过期时间";
运行 MqClient 类,连接服务并消费队列中的消息,成功后,可以在 console 中观察到成功消费的消息
用户可以使用平台的模拟工具产生设备消息,操作如下:
进入设备列表 -> 数据流 -> 模拟数据工具
点击发送数据,完成消息的模拟产生