From 7da5f582638db7b1eec7a87d005ca3a73ffe10b0 Mon Sep 17 00:00:00 2001 From: wujiawei <12345678> Date: Wed, 22 Jan 2025 10:20:26 +0800 Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E4=BF=AE=E5=A4=8D=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E8=B4=9F=E8=BD=BD=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lazy/cloud/network/heartbeat/common/ChannelContext.java | 4 ++++ 1 file changed, 4 insertions(+) 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); }