Browse Source

fix:修复ByteBuf内存泄露问题

master
白凤吉 6 months ago
parent
commit
6f5c7fc655
  1. 8
      src/main/java/com/qyft/gd/device/client/TcpClient.java

8
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;

Loading…
Cancel
Save