From ba1e219d97e123b91657dc424f13a2fdeaa85d21 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: Mon, 21 Aug 2023 13:37:01 +0800
Subject: [PATCH] 修改兴趣点列表井号模糊查询
---
ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java
index 3c36909..37a4a18 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumer.java
@@ -22,7 +22,7 @@
@Override
public void run(ApplicationArguments args) {
- log.info("初始化并启动mqtt......");
+ log.debug("初始化并启动mqtt......");
if(PropertiesUtil.MQTT_ENABLED)
{
this.connect();
@@ -56,7 +56,7 @@
if (null == client) {
client = new MqttClient(PropertiesUtil.MQTT_HOST, PropertiesUtil.MQTT_CLIENT_ID, new MemoryPersistence());
}
- log.info("--创建mqtt客户端");
+ log.debug("--创建mqtt客户端");
} catch (Exception e) {
log.error("创建mqtt客户端异常：" + e);
}
@@ -75,8 +75,8 @@
// 设置会话心跳时间
options.setKeepAliveInterval(PropertiesUtil.MQTT_KEEP_ALIVE);
// 是否清除session
- options.setCleanSession(false);
- log.info("--生成mqtt配置对象");
+ options.setCleanSession(true);
+ log.debug("--生成mqtt配置对象");
return options;
}
@@ -96,7 +96,7 @@
*/
qos[i] = 1;
}
- log.info("--设置消息发布质量");
+ log.debug("--设置消息发布质量");
return qos;
}
@@ -106,10 +106,10 @@
public void create(MqttConnectOptions options, String[] topic, int[] qos) {
try {
client.setCallback(new MqttConsumerCallback(client, options, topic, qos));
- log.info("--添加回调处理类");
+ log.debug("--添加回调处理类");
client.connect(options);
} catch (Exception e) {
- log.info("装载实例或订阅主题异常：" + e);
+ log.error("装载实例或订阅主题异常：" + e);
}
}
@@ -121,7 +121,7 @@
*/
public void subscribe(String topic, int qos) {
try {
- log.info("topic:" + topic);
+ log.debug("topic:" + topic);
client.subscribe(topic, qos);
} catch (MqttException e) {
e.printStackTrace();
@@ -144,7 +144,7 @@
* 发布
*/
public static void publish(int qos, boolean retained, String topic, String pushMessage) {
- log.info("【主题】:" + topic + "【qos】:" + qos + "【pushMessage】:" + pushMessage);
+ log.debug("【主题】:" + topic + "【qos】:" + qos + "【pushMessage】:" + pushMessage);
MqttMessage message = new MqttMessage();
message.setQos(qos);
message.setRetained(retained);
@@ -162,7 +162,7 @@
token = mTopic.publish(message);
token.waitForCompletion();
if (token.isComplete()) {
- log.info("消息发送成功");
+ log.debug("消息发送成功");
}
} catch (MqttPersistenceException e) {
e.printStackTrace();
--
Gitblit v1.9.3