From a019561c06c5cca04c7555300df9242a87ceb6fc Mon Sep 17 00:00:00 2001
From: wujiawei <12345678>
Date: Thu, 16 Jan 2025 09:52:03 +0800
Subject: [PATCH] =?UTF-8?q?[fix]=20=20=E8=B0=83=E6=95=B4=E6=98=AF=E5=90=A6?=
 =?UTF-8?q?=E7=BB=9F=E8=AE=A1=E6=B5=81=E9=87=8F=EF=BC=8C=E9=81=BF=E5=85=8D?=
 =?UTF-8?q?=E7=BD=91=E7=BB=9C=E9=97=AE=E9=A2=98=E5=AF=BC=E8=87=B4=E6=B5=81?=
 =?UTF-8?q?=E9=87=8F=E7=BC=BA=E5=8F=A3=EF=BC=8C=E6=95=B0=E6=8D=AE=E4=B8=A2?=
 =?UTF-8?q?=E5=A4=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../server/netty/flow/ServerHandlerInFlowHandler.java       | 6 +++++-
 .../server/netty/flow/ServerHandlerOutFlowHandler.java      | 6 +++++-
 .../heartbeat/server/properties/ServerNodeProperties.java   | 2 --
 3 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerInFlowHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerInFlowHandler.java
index 5b87cd9..aa6abe7 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerInFlowHandler.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerInFlowHandler.java
@@ -28,7 +28,11 @@ public class ServerHandlerInFlowHandler extends AbstractHandleChannelFlowAdvance
      */
     @Override
     protected boolean doSupport(ChannelFlow channelFlow) {
-        return ChannelFlowEnum.IN_FLOW.equals(channelFlow.channelFlowEnum());
+        if (serverNodeProperties.getEnableFlowControl()) {
+            return ChannelFlowEnum.IN_FLOW.equals(channelFlow.channelFlowEnum());
+        } else {
+            return false;
+        }
     }
 
     /**
diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerOutFlowHandler.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerOutFlowHandler.java
index 25d6959..560f658 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerOutFlowHandler.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerOutFlowHandler.java
@@ -28,7 +28,11 @@ public class ServerHandlerOutFlowHandler extends AbstractHandleChannelFlowAdvanc
      */
     @Override
     protected boolean doSupport(ChannelFlow channelFlow) {
-        return ChannelFlowEnum.OUT_FLOW.equals(channelFlow.channelFlowEnum());
+        if (serverNodeProperties.getEnableFlowControl()) {
+            return ChannelFlowEnum.OUT_FLOW.equals(channelFlow.channelFlowEnum());
+        } else {
+            return false;
+        }
     }
 
     /**
diff --git a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/properties/ServerNodeProperties.java b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/properties/ServerNodeProperties.java
index 316a9e6..2427e6a 100644
--- a/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/properties/ServerNodeProperties.java
+++ b/wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/properties/ServerNodeProperties.java
@@ -59,8 +59,6 @@ public class ServerNodeProperties {
     @Data
     public static class Tcp {
         private Integer port;
-
-
     }
 
     @Data