From 30e1141ecf5787489338ccd4ea98d59f46672ac7 Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Tue, 19 Nov 2024 19:21:12 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E4=BC=98=E5=8C=96=E8=B4=9F=E8=BD=BD?= =?UTF-8?q?=E8=8E=B7=E5=8F=96=E5=8F=AF=E4=BB=A5=E4=BD=BF=E7=94=A8=E7=9A=84?= =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../application/impl/LazyNettyClientStateApplicationImpl.java | 3 +++ 1 file changed, 3 insertions(+) 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(); }