From f320569f2c46ebca8ea88c4bbbe23d9b63539e94 Mon Sep 17 00:00:00 2001
From: puhui999 <puhui999@163.com>
Date: Wed, 21 Jan 2026 21:21:07 +0800
Subject: [PATCH] =?UTF-8?q?perf=EF=BC=9A=E3=80=90iot=E3=80=91=E4=BC=98?=
 =?UTF-8?q?=E5=8C=96=20IotTcpClient=20=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/rule/data/action/IotTcpDataRuleAction.java   | 1 -
 .../iot/service/rule/data/action/tcp/IotTcpClient.java   | 9 +++------
 2 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/IotTcpDataRuleAction.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/IotTcpDataRuleAction.java
index 53a3b71480..74385d08dd 100644
--- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/IotTcpDataRuleAction.java
+++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/IotTcpDataRuleAction.java
@@ -43,7 +43,6 @@ public class IotTcpDataRuleAction extends
                 config.getConnectTimeoutMs(),
                 config.getReadTimeoutMs(),
                 config.getSsl(),
-                config.getSslCertPath(),
                 config.getDataFormat()
         );
         // 2.2 连接服务器
diff --git a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/tcp/IotTcpClient.java b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/tcp/IotTcpClient.java
index 15b57b5405..faf59d3fbc 100644
--- a/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/tcp/IotTcpClient.java
+++ b/yudao-module-iot/yudao-module-iot-biz/src/main/java/cn/iocoder/yudao/module/iot/service/rule/data/action/tcp/IotTcpClient.java
@@ -1,5 +1,6 @@
 package cn.iocoder.yudao.module.iot.service.rule.data.action.tcp;
 
+import cn.hutool.core.util.ObjUtil;
 import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
 import cn.iocoder.yudao.module.iot.core.mq.message.IotDeviceMessage;
 import cn.iocoder.yudao.module.iot.dal.dataobject.rule.config.IotDataSinkTcpConfig;
@@ -31,8 +32,6 @@ public class IotTcpClient {
     private final Integer connectTimeoutMs;
     private final Integer readTimeoutMs;
     private final Boolean ssl;
-    // TODO @puhui999：sslCertPath 是不是没在用？
-    private final String sslCertPath;
     private final String dataFormat;
 
     private Socket socket;
@@ -41,15 +40,13 @@ public class IotTcpClient {
     private final AtomicBoolean connected = new AtomicBoolean(false);
 
     public IotTcpClient(String host, Integer port, Integer connectTimeoutMs, Integer readTimeoutMs,
-                        Boolean ssl, String sslCertPath, String dataFormat) {
+                        Boolean ssl, String dataFormat) {
         this.host = host;
         this.port = port;
         this.connectTimeoutMs = connectTimeoutMs != null ? connectTimeoutMs : IotDataSinkTcpConfig.DEFAULT_CONNECT_TIMEOUT_MS;
         this.readTimeoutMs = readTimeoutMs != null ? readTimeoutMs : IotDataSinkTcpConfig.DEFAULT_READ_TIMEOUT_MS;
         this.ssl = ssl != null ? ssl : IotDataSinkTcpConfig.DEFAULT_SSL;
-        this.sslCertPath = sslCertPath;
-        // TODO @puhui999：可以使用 StrUtil.defaultIfBlank 方法简化
-        this.dataFormat = dataFormat != null ? dataFormat : IotDataSinkTcpConfig.DEFAULT_DATA_FORMAT;
+        this.dataFormat = ObjUtil.defaultIfBlank(dataFormat, IotDataSinkTcpConfig.DEFAULT_DATA_FORMAT);
     }
 
     /**