From 3341000ec5a7530358e8a374f41524b3fc5fac2a 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 19:44:29 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E8=A7=A3=E5=86=B3ByteBuf=E5=86=85=E5=AD=98?= =?UTF-8?q?=E6=BA=A2=E5=87=BA=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 | 10 ++-------- 1 file changed, 2 insertions(+), 8 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 92e8ce4..d7e2458 100644 --- a/src/main/java/com/qyft/gd/device/client/TcpClient.java +++ b/src/main/java/com/qyft/gd/device/client/TcpClient.java @@ -91,14 +91,8 @@ public class TcpClient { public boolean send(String request) { if (channel != null && channel.isActive()) { - ByteBuf byteBuf = Unpooled.copiedBuffer(request, CharsetUtil.UTF_8); - try { - channel.writeAndFlush(byteBuf); - return true; - } catch (Exception e) { - log.error("TCP发送请求失败: {}", request, e); - return false; - } + channel.writeAndFlush(Unpooled.copiedBuffer(request, CharsetUtil.UTF_8)); + return true; } else { log.error("TCP服务未连接,无法发送请求: {}", request); return false;