Merge branch '20230426' into 'master_dev'

fix: 鉴权随机失败问题修复

See merge request yunteng/thingskit!185

@@ -450,7 +450,6 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements
             transportService.process(deviceSessionCtx.getSessionInfo(), SESSION_EVENT_MSG_OPEN, new TransportServiceCallback<Void>() {
             transportService.process(deviceSessionCtx.getSessionInfo(), SESSION_EVENT_MSG_OPEN, new TransportServiceCallback<Void>() {
                 @Override
                 @Override
                 public void onSuccess(Void msg) {
                 public void onSuccess(Void msg) {
-                    authedCounter.incrementAndGet();
                     SessionMetaData sessionMetaData = transportService.registerAsyncSession(deviceSessionCtx.getSessionInfo(), TcpTransportHandler.this);
                     SessionMetaData sessionMetaData = transportService.registerAsyncSession(deviceSessionCtx.getSessionInfo(), TcpTransportHandler.this);
                     checkGatewaySession(sessionMetaData);
                     checkGatewaySession(sessionMetaData);
                     ctx.writeAndFlush(createTcpConnAckMsg(authEntry.getSuccess()));
                     ctx.writeAndFlush(createTcpConnAckMsg(authEntry.getSuccess()));
@@ -476,7 +475,7 @@ public class TcpTransportHandler extends ChannelInboundHandlerAdapter implements
 
 
     private void onValidateFailed(ChannelHandlerContext ctx, MqttConnectReturnCode msg) {
     private void onValidateFailed(ChannelHandlerContext ctx, MqttConnectReturnCode msg) {
         authedCounter.incrementAndGet();
         authedCounter.incrementAndGet();
-        if (TkScriptInvokeService.authScripts.size() == authedCounter.incrementAndGet()) {
+        if (TkScriptInvokeService.authScripts.size() == authedCounter.intValue()) {
             ctx.writeAndFlush(createTcpConnAckMsg(msg.name()));
             ctx.writeAndFlush(createTcpConnAckMsg(msg.name()));
             ctx.close();
             ctx.close();
         }
         }