From bee146dbc0f57be4a5c98be3df1fc326d69cfc44 Mon Sep 17 00:00:00 2001 From: zc Date: Fri, 6 Feb 2026 16:32:39 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E8=B4=B9=E6=94=B9=E9=80=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mica/mqtt/server/listener/MqttConnectStatusListener2.java | 3 --- system/mqtt-xf-receiver/src/main/resources/application.yml | 4 ++-- system/pom.xml | 4 ++++ 3 files changed, 6 insertions(+), 5 deletions(-) diff --git a/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java b/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java index 96eed79..9670c19 100644 --- a/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java +++ b/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java @@ -29,15 +29,12 @@ public class MqttConnectStatusListener2 implements IMqttConnectStatusListener { @Override public void online(ChannelContext context, String clientId, String username) { //设备上线不做任何处理,只有心跳报文做处理 - log.info("online-context: {}", context); log.info("设备:{}上线", clientId); } @Override @Transactional(rollbackFor = Exception.class) public void offline(ChannelContext context, String clientId, String username, String reason) { - log.info("offline-context: {}", context); - redisService.deleteObject(CacheConstants.EQUIPMENT_HEARTBEAT + clientId); log.info("设备:{}离线,offline reason:{}.", clientId, reason); } } diff --git a/system/mqtt-xf-receiver/src/main/resources/application.yml b/system/mqtt-xf-receiver/src/main/resources/application.yml index 4ad0c08..caf558c 100644 --- a/system/mqtt-xf-receiver/src/main/resources/application.yml +++ b/system/mqtt-xf-receiver/src/main/resources/application.yml @@ -6,8 +6,8 @@ spring: name: mica-mqtt-server # 环境 dev|test|prod profiles: - active: dev -# active: prod +# active: dev + active: prod messages: encoding: UTF-8 basename: i18n/messages diff --git a/system/pom.xml b/system/pom.xml index 3b1a4bb..726cad1 100644 --- a/system/pom.xml +++ b/system/pom.xml @@ -23,6 +23,10 @@ 2.13.2 + + mqtt-xf-receiver + +