From d48d3126fc174b6631d4076fac866158b4a4addc Mon Sep 17 00:00:00 2001
From: zwc401 <lavender0501@163.com>
Date: Thu, 3 Aug 2023 19:58:01 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3sslSock=E5=AF=B9=E8=B1=A1?=
 =?UTF-8?q?=E8=B5=84=E6=BA=90=E6=9C=AA=E9=87=8A=E6=94=BE=E7=9A=84=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

增加对sslSock变量的释放操作，防止资源未释放导致内存溢出
---
 .../km/common/utils/zookeeper/FourLetterWordUtil.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java
index 5c798b7c3..e6492c974 100644
--- a/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java
+++ b/km-common/src/main/java/com/xiaojukeji/know/streaming/km/common/utils/zookeeper/FourLetterWordUtil.java
@@ -93,6 +93,16 @@ private static String send4LetterWord(
                     sslSock.connect(hostaddress, timeout);
                     sslSock.startHandshake();
                     socket = sslSock;
+                     if (sslSock != null) {
+                        try {
+                            sslSock.close();
+                        } catch (IOException e) {
+                            LOGGER.error(
+                                    "method=send4LetterWord||host={}||port={}||cmd={}||secure={}||timeout={}||errMsg=exception!",
+                                    host, port, cmd, secure, timeout, e
+                            );
+                        }
+                    }
                 }
             } else {
                 socket = new Socket();