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;