本文主要以 Java 为例,面向初次接触OneNET消息队列MQ的开发者,演示如何搭建测试工程
下载demo工程 并解压,解压后可以看到本地新增了OneNET-MQ-demo文件夹
在 IDE(以 Eclipse 为例)中,选择 File -> Import,选择 Import 类型为 Existing Maven Projects
点击 Next,点击 Browse,选择解压后的OneNET-MQ-demo文件夹
点击 Finish,完成工程导入
demo 工程导入时需要加载依赖的jar包,整个导入过程需要等待约1分钟
请按照如下说明,根据在平台创建的资源参数,修改 MqClient.java 中的 MqClient 类
demo中45 - 47行:
String userName = "您的MQ实例名称";
String mqTopic = "您创建的topic名称";
String mqSub = "您创建的订阅名称";
81 - 83行:
String userName = "您的MQ实例名称";
String accessKey = "您的MQ access_key";
String expirationTime = "您自定义的鉴权参数过期时间";
注:如需手动回复puback,请将 MqClient.java 中 第25行 manualAcks 设置为 true,并在PushCallback类中的messageArrived的接口中手动回复
private boolean manualAcks = false;
配置规则引擎并生产消息,运行 MqClient 类,连接服务并消费队列中的消息,成功后,可以在 console 中观察到成功消费的消息