change - broker监听器注入方式修改，websocket日志类修改final修饰

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 final ApplicationContext applicationContext;
-	private 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()));

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 final MqttServerTemplate mqttServerTemplate;
-    private MqttServerTemplate mqttServerTemplate;
+
+    public RedisMessageListener(MqttServerTemplate mqttServerTemplate) {
+        this.mqttServerTemplate = mqttServerTemplate;
+    }
 
     /**
      * 订阅设备控制信息、发布设备指令

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;
 

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;