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 2025-01-16 09:52:03 +08:00
parent f985cdac8f
commit a019561c06
3 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerInFlowHandler.java
View File

@ -28,7 +28,11 @@ public class ServerHandlerInFlowHandler extends AbstractHandleChannelFlowAdvance
*/ */
@Override @Override
protected boolean doSupport(ChannelFlow channelFlow) { 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;
}
} }
/** /**

6
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/flow/ServerHandlerOutFlowHandler.java
View File

@ -28,7 +28,11 @@ public class ServerHandlerOutFlowHandler extends AbstractHandleChannelFlowAdvanc
*/ */
@Override @Override
protected boolean doSupport(ChannelFlow channelFlow) { 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;
}
} }
/** /**

2
wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/properties/ServerNodeProperties.java
View File

@ -59,8 +59,6 @@ public class ServerNodeProperties {
@Data @Data
public static class Tcp { public static class Tcp {
private Integer port; private Integer port;
} }
@Data @Data