From 6f5c7fc65553f2f49fc5e8771791862c2773c6fa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=99=BD=E5=87=A4=E5=90=89?= Date: Thu, 20 Feb 2025 15:01:21 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8DByteBuf=E5=86=85=E5=AD=98?= =?UTF-8?q?=E6=B3=84=E9=9C=B2=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/qyft/gd/device/client/TcpClient.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/qyft/gd/device/client/TcpClient.java b/src/main/java/com/qyft/gd/device/client/TcpClient.java index faedc4c..078382f 100644 --- a/src/main/java/com/qyft/gd/device/client/TcpClient.java +++ b/src/main/java/com/qyft/gd/device/client/TcpClient.java @@ -90,8 +90,12 @@ public class TcpClient { public boolean send(String request) { if (channel != null && channel.isActive()) { ByteBuf byteBuf = Unpooled.copiedBuffer(request, CharsetUtil.UTF_8); - channel.writeAndFlush(byteBuf); - return true; + try { + channel.writeAndFlush(byteBuf); + return true; + } finally { + byteBuf.release(); // 确保释放资源 + } } else { log.error("TCP服务未连接,无法发送请求: {}", request); return false;