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 21847bc..e0eda62 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 @@ -119,6 +119,10 @@ public class ChannelContext { return null; } channels = channels.stream().filter(Channel::isActive).collect(Collectors.toList()); + if(ObjectUtils.isEmpty(channels)){ + return null; + } + // TODO 负载问题 return channels.get(0); }