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

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

Browse Source
This commit is contained in:
wujiawei 2024-11-19 19:21:12 +08:00
parent 79b09ecfea
commit 30e1141ecf
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3,6 +3,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.standalone.application
import io.netty.channel.Channel; import io.netty.channel.Channel;
import jakarta.annotation.Resource; 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.ChannelContext;
import org.framework.lazy.cloud.network.heartbeat.common.MessageType; import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext; import org.framework.lazy.cloud.network.heartbeat.common.NettyClientVisitorContext;
@ -34,6 +35,7 @@ import java.util.stream.Collectors;
* @date 2023/12/27 03:46 下午 * @date 2023/12/27 03:46 下午
* @see DefaultDDDLazyApplicationImpl * @see DefaultDDDLazyApplicationImpl
**/ **/
@Slf4j
@LazyApplication @LazyApplication
public class LazyNettyClientStateApplicationImpl implements LazyNettyClientStateApplication { public class LazyNettyClientStateApplicationImpl implements LazyNettyClientStateApplication {
@ -207,6 +209,7 @@ public class LazyNettyClientStateApplicationImpl implements LazyNettyClientState
// 关闭访客 // 关闭访客
List<NettyServerPermeateClientVisitorSocket> nettyServerPermeateClientVisitorSocketList = NettyClientVisitorContext.getVisitorSockets(clientId); List<NettyServerPermeateClientVisitorSocket> nettyServerPermeateClientVisitorSocketList = NettyClientVisitorContext.getVisitorSockets(clientId);
if (!ObjectUtils.isEmpty(nettyServerPermeateClientVisitorSocketList)) { if (!ObjectUtils.isEmpty(nettyServerPermeateClientVisitorSocketList)) {
log.info("size:{}",nettyServerPermeateClientVisitorSocketList.size());
for (NettyServerPermeateClientVisitorSocket nettyServerPermeateClientVisitorSocket : nettyServerPermeateClientVisitorSocketList) { for (NettyServerPermeateClientVisitorSocket nettyServerPermeateClientVisitorSocket : nettyServerPermeateClientVisitorSocketList) {
nettyServerPermeateClientVisitorSocket.close(); nettyServerPermeateClientVisitorSocket.close();
} }