Browse Source

使用@Slf4j

master
白凤吉 6 months ago
parent
commit
c7dd2d844f
  1. 4
      src/main/java/com/qyft/gd/config/WebSocketServer.java
  2. 8
      src/main/java/com/qyft/gd/device/client/TcpClient.java

4
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<Session> sessions = Collections.synchronizedSet(new HashSet<>());
@OnOpen

8
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;

Loading…
Cancel
Save