alsace/wu-lazy-cloud-network
1
0
Fork 0
mirror of https://gitee.com/wujiawei1207537021/wu-lazy-cloud-network.git synced 2025-06-06 21:37:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

[fix] 优化负载获取可以使用的客户端

Browse Source
This commit is contained in:
wujiawei 2024-11-18 20:41:02 +08:00
parent 5a079fcba8
commit 79b09ecfea
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/ChannelContext.java
View File

@ -11,6 +11,7 @@ import java.util.Collections;
import java.util.List; import java.util.List;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import java.util.stream.Collectors;
/** /**
* 通道上下文 * 通道上下文
@ -117,6 +118,7 @@ public class ChannelContext {
if(ObjectUtils.isEmpty(channels)){ if(ObjectUtils.isEmpty(channels)){
return null; return null;
} }
channels = channels.stream().filter(Channel::isActive).collect(Collectors.toList());
return channels.get(0); return channels.get(0);
} }

1
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/standalone/application/impl/LazyClientStatsChangeApplicationImpl.java
View File

@ -129,6 +129,7 @@ public class LazyClientStatsChangeApplicationImpl implements LazyClientStatsChan
lazyNettyClientState.setOriginalIp(lazyNettyClientLoginCommand.getOriginalIp()); lazyNettyClientState.setOriginalIp(lazyNettyClientLoginCommand.getOriginalIp());
lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState); lazyNettyClientStateRepository.updateStagingState(lazyNettyClientState);
lazyNettyClientLoginCommand.setStagingState("CLOSED"); lazyNettyClientLoginCommand.setStagingState("CLOSED");
lazyNettyClientLoginCommand.setOnLineState(NettyClientStatus.ON_LINE);
lazyNettyClientLoginCommand.setServerId(serverId); lazyNettyClientLoginCommand.setServerId(serverId);
storyClientStateRecord(lazyNettyClientLoginCommand); storyClientStateRecord(lazyNettyClientLoginCommand);
} }