diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java index ed9dd2a..21847bc 100644 --- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java +++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java @@ -11,6 +11,7 @@ import java.util.Collections; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; +import java.util.stream.Collectors; /** * 通道上下文 @@ -117,6 +118,7 @@ public class ChannelContext { if(ObjectUtils.isEmpty(channels)){ return null; } + channels = channels.stream().filter(Channel::isActive).collect(Collectors.toList()); return channels.get(0); } diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java index aca312a..8c2564e 100644 --- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java +++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java @@ -129,6 +129,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan lazyNettyClientState.setOriginalIp(lazyNettyClientLoginCommand.getOriginalIp()); lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState); lazyNettyClientLoginCommand.setStagingState("CLOSED"); + lazyNettyClientLoginCommand.setOnLineState(NettyClientStatus.ON_LINE); lazyNettyClientLoginCommand.setServerId(serverId); storyClientStateRecord(lazyNettyClientLoginCommand); }