diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java index bdb72da..9bdaf1d 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyNettyClientStateApplicationImpl.java @@ -3,6 +3,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application import io.netty.channel.Channel; import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; import org.framework.lazy.cloud.network.heartbeat.common.ChannelContext; import org.framework.lazy.cloud.network.heartbeat.common.MessageType; import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext; @@ -34,6 +35,7 @@ import java.util.stream.Collectors; * @date 2023/12/27 03:46 下午 * @see DefaultDDDLazyApplicationImpl **/ +@Slf4j @LazyApplication public class LazyNettyClientStateApplicationImpl implements LazyNettyClientStateApplication { @@ -207,6 +209,7 @@ public class LazyNettyClientStateApplicationImpl implements LazyNettyClientState // 关闭访客 List nettyServerPermeateClientVisitorSocketList = NettyClientVisitorContext.getVisitorSockets(clientId); if (!ObjectUtils.isEmpty(nettyServerPermeateClientVisitorSocketList)) { + log.info("size:{}",nettyServerPermeateClientVisitorSocketList.size()); for (NettyServerPermeateClientVisitorSocket nettyServerPermeateClientVisitorSocket : nettyServerPermeateClientVisitorSocketList) { nettyServerPermeateClientVisitorSocket.close(); }