From c7dd2d844f5306d75b1fdb03a64211735bec86f2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= Date: Thu, 13 Feb 2025 17:01:12 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BD=BF=E7=94=A8@Slf4j?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/qyft/gd/config/WebSocketServer.java | 4 ++-- src/main/java/com/qyft/gd/device/client/TcpClient.java | 8 ++------ 2 files changed, 4 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/qyft/gd/config/WebSocketServer.java b/src/main/java/com/qyft/gd/config/WebSocketServer.java index 83626b8..5907901 100644 --- a/src/main/java/com/qyft/gd/config/WebSocketServer.java +++ b/src/main/java/com/qyft/gd/config/WebSocketServer.java @@ -3,6 +3,7 @@ package com.qyft.gd.config; import jakarta.websocket.*; import jakarta.websocket.server.ServerEndpoint; +import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; @@ -11,12 +12,11 @@ import java.util.Collections; import java.util.HashSet; import java.util.Set; +@Slf4j @ServerEndpoint("/ws") @Component public class WebSocketServer { - private static final Logger log = LoggerFactory.getLogger(WebSocketServer.class); - private static final Set sessions = Collections.synchronizedSet(new HashSet<>()); @OnOpen diff --git a/src/main/java/com/qyft/gd/device/client/TcpClient.java b/src/main/java/com/qyft/gd/device/client/TcpClient.java index a406fea..e343628 100644 --- a/src/main/java/com/qyft/gd/device/client/TcpClient.java +++ b/src/main/java/com/qyft/gd/device/client/TcpClient.java @@ -12,11 +12,8 @@ import io.netty.channel.*; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.util.CharsetUtil; -import jakarta.annotation.PostConstruct; import lombok.RequiredArgsConstructor; -import lombok.Setter; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; +import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; @@ -27,12 +24,11 @@ import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; - +@Slf4j @Component @RequiredArgsConstructor public class TcpClient { - private static final Logger log = LoggerFactory.getLogger(TcpClient.class); private final TcpConfig tcpConfig; private DeviceMessageHandler deviceMessageHandler;