[fix] // TODO 流量并发异常

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/config/HeartbeatServerConfiguration.java

@@ -3,6 +3,7 @@ package org.framework.lazy.cloud.network.heartbeat.server.config;
 
 import org.framework.lazy.cloud.network.heartbeat.common.adapter.ChannelFlowAdapter;
 import org.framework.lazy.cloud.network.heartbeat.server.netty.advanced.*;
+import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.*;
 import org.springframework.beans.factory.config.BeanDefinition;
 import org.springframework.context.annotation.Bean;
@@ -42,13 +43,17 @@ public class HeartbeatServerConfiguration {
             LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication,
             LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication,
             LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication,
-            LazyNettyClientTokenBucketApplication lazyNettyClientTokenBucketApplication) {
+            LazyNettyClientTokenBucketApplication lazyNettyClientTokenBucketApplication,
+            ServerNodeProperties serverNodeProperties
+    ) {
         return new ServerHandleClientConnectSuccessTypeAdvanced(lazyClientStatsChangeApplication,
                 lazyNettyClientBlacklistApplication,
                 lazyInternalNetworkServerPermeateClientMappingApplication,
                 lazyInternalNetworkClientPermeateServerMappingApplication,
                 lazyInternalNetworkClientPermeateClientMappingApplication,
-                lazyNettyClientTokenBucketApplication);
+                lazyNettyClientTokenBucketApplication,
+                serverNodeProperties
+        );
     }
 
     /**

wu-lazy-cloud-heartbeat-server/src/main/java/org/framework/lazy/cloud/network/heartbeat/server/netty/advanced/ServerHandleClientConnectSuccessTypeAdvanced.java

@@ -9,6 +9,7 @@ import org.framework.lazy.cloud.network.heartbeat.common.MessageType;
 import org.framework.lazy.cloud.network.heartbeat.common.NettyProxyMsg;
 import org.framework.lazy.cloud.network.heartbeat.common.advanced.server.AbstractHandleClientConnectSuccessTypeAdvanced;
 import org.framework.lazy.cloud.network.heartbeat.common.utils.ChannelAttributeKeyUtils;
+import org.framework.lazy.cloud.network.heartbeat.server.properties.ServerNodeProperties;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.*;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.client.mapping.LazyInternalNetworkClientPermeateClientMappingQueryListCommand;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.command.lazy.netty.client.permeate.server.mapping.LazyInternalNetworkClientPermeateServerMappingQueryListCommand;
@@ -16,7 +17,6 @@ import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateClientMappingDTO;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.application.dto.LazyInternalNetworkClientPermeateServerMappingDTO;
 import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.blacklist.LazyNettyClientBlacklist;
-import org.framework.lazy.cloud.network.heartbeat.server.standalone.domain.model.lazy.netty.client.token.bucket.LazyNettyClientTokenBucket;
 import org.springframework.stereotype.Component;
 import org.wu.framework.web.response.Result;
 
@@ -39,13 +39,17 @@ public class ServerHandleClientConnectSuccessTypeAdvanced extends AbstractHandle
     private final LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication;
 
     private final LazyNettyClientTokenBucketApplication lazyNettyClientTokenBucketApplication;
-    public ServerHandleClientConnectSuccessTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication, LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication, LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication, LazyNettyClientTokenBucketApplication lazyNettyClientTokenBucketApplication) {
+
+    private final ServerNodeProperties serverNodeProperties;
+
+    public ServerHandleClientConnectSuccessTypeAdvanced(LazyClientStatsChangeApplication lazyClientStatsChangeApplication, LazyNettyClientBlacklistApplication lazyNettyClientBlacklistApplication, LazyInternalNetworkServerPermeateClientMappingApplication lazyInternalNetworkServerPermeateClientMappingApplication, LazyInternalNetworkClientPermeateServerMappingApplication lazyInternalNetworkClientPermeateServerMappingApplication, LazyInternalNetworkClientPermeateClientMappingApplication lazyInternalNetworkClientPermeateClientMappingApplication, LazyNettyClientTokenBucketApplication lazyNettyClientTokenBucketApplication, ServerNodeProperties serverNodeProperties) {
         this.lazyClientStatsChangeApplication = lazyClientStatsChangeApplication;
         this.lazyNettyClientBlacklistApplication = lazyNettyClientBlacklistApplication;
         this.lazyInternalNetworkServerPermeateClientMappingApplication = lazyInternalNetworkServerPermeateClientMappingApplication;
         this.lazyInternalNetworkClientPermeateServerMappingApplication = lazyInternalNetworkClientPermeateServerMappingApplication;
         this.lazyInternalNetworkClientPermeateClientMappingApplication = lazyInternalNetworkClientPermeateClientMappingApplication;
         this.lazyNettyClientTokenBucketApplication = lazyNettyClientTokenBucketApplication;
+        this.serverNodeProperties = serverNodeProperties;
     }
 
 
@@ -81,6 +85,8 @@ public class ServerHandleClientConnectSuccessTypeAdvanced extends AbstractHandle
                 // 认证验证
                 Result<Boolean> existsTokenResult = lazyNettyClientTokenBucketApplication.certificationToken(clientId, appKey, appSecret);
                 Boolean existsToken= existsTokenResult.getData();
+                Boolean enableTokenVerification = serverNodeProperties.getEnableTokenVerification();
+                existsToken = enableTokenVerification ? existsToken : true;
                 if(existsToken){
                     // 服务状态在线
                     LazyNettyClientLoginCommand lazyNettyClientLoginCommand = new LazyNettyClientLoginCommand();

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

@@ -41,4 +41,9 @@ public class ServerNodeProperties {
      * 开启流量监控
      */
     private Boolean enableFlowControl=false;
+
+    /**
+     * 是否开启 token 验证
+     */
+    private Boolean enableTokenVerification = false;
 }