diff --git a/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/MqttServerMessageListener.java b/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/MqttServerMessageListener.java index f194479..157899c 100644 --- a/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/MqttServerMessageListener.java +++ b/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/MqttServerMessageListener.java @@ -23,10 +23,13 @@ import org.tio.core.ChannelContext; @Service public class MqttServerMessageListener implements IMqttMessageListener, SmartInitializingSingleton { private static final Logger logger = LoggerFactory.getLogger(MqttServerMessageListener.class); - @Autowired - private ApplicationContext applicationContext; + private final ApplicationContext applicationContext; private MqttServerTemplate mqttServerTemplate; + public MqttServerMessageListener(ApplicationContext applicationContext) { + this.applicationContext = applicationContext; + } + @Override public void onMessage(ChannelContext context, String clientId, String topic, MqttQoS qos, MqttPublishMessage message) { logger.info("context:{} clientId:{} message:{} payload:{}", context, clientId, message, ByteBufferUtil.toString(message.getPayload())); diff --git a/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/RedisMessageListener.java b/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/RedisMessageListener.java index 45a12f7..5d4b970 100644 --- a/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/RedisMessageListener.java +++ b/ruoyi-modules/hw-mqtt-broker/src/main/java/com/hw/mqtt/listener/RedisMessageListener.java @@ -25,8 +25,11 @@ public class RedisMessageListener { private static final Logger logger = LoggerFactory.getLogger(RedisMessageListener.class); - @Autowired - private MqttServerTemplate mqttServerTemplate; + private final MqttServerTemplate mqttServerTemplate; + + public RedisMessageListener(MqttServerTemplate mqttServerTemplate) { + this.mqttServerTemplate = mqttServerTemplate; + } /** * 订阅设备控制信息、发布设备指令 diff --git a/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/controller/WebSocketApi.java b/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/controller/WebSocketApi.java index 780a025..6799a6b 100644 --- a/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/controller/WebSocketApi.java +++ b/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/controller/WebSocketApi.java @@ -23,7 +23,7 @@ import javax.annotation.Resource; @RequestMapping("/webSocketApi") public class WebSocketApi { - private Logger logger = LoggerFactory.getLogger(WebSocketApi.class); + private final Logger logger = LoggerFactory.getLogger(WebSocketApi.class); @Resource private WebSocket webSocket; diff --git a/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/operate/WebSocket.java b/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/operate/WebSocket.java index eb8e8ac..6ce6b83 100644 --- a/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/operate/WebSocket.java +++ b/ruoyi-modules/hw-websocket-server/src/main/java/com/hw/websocket/operate/WebSocket.java @@ -20,7 +20,7 @@ import java.util.concurrent.CopyOnWriteArraySet; @ServerEndpoint("/websocket/{userId}") // 接口路径 ws://localhost:8087/webSocket/userId; public class WebSocket { - private Logger logger = LoggerFactory.getLogger(WebSocket.class); + private final Logger logger = LoggerFactory.getLogger(WebSocket.class); //与某个客户端的连接会话,需要通过它来给客户端发送数据 private Session session;