From cd2cfd37366002f790a2ed1435962d4eff7d5cec Mon Sep 17 00:00:00 2001
From: zengh <123456>
Date: Tue, 01 Jun 2021 09:39:30 +0800
Subject: [PATCH] 版本合并
---
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
index f12c77c..a36ea5e 100644
--- a/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
+++ b/blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyTcpServer/TcpServerHandler.java
@@ -4,6 +4,8 @@
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.channel.SimpleChannelInboundHandler;
+import io.netty.util.ReferenceCountUtil;
import org.springblade.jfpt.alarm.service.IAlarmService;
import org.springblade.jfpt.equipment.service.IEquipmentService;
import org.springblade.jfpt.nettyServer.NettyConfig;
@@ -32,9 +34,6 @@
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("CTX:"+ctx.channel());
System.out.println("客户端与服务端连接开始...");
-// ChannelId id = ctx.channel().id();
-// String s = id.toString();
- //NettyConfig.group.add(ctx.channel());
}
/**
@@ -73,13 +72,14 @@
ByteBuf buf = (ByteBuf) info;
byte[] req = new byte[buf.readableBytes()];
buf.readBytes(req);
+ //手动释放内存
+ ReferenceCountUtil.release(info);
String body = new String(req, "UTF-8");
String content = body;
System.out.println("接收客户端数据:" + body);
- System.out.println("content.length() = " + content.length());
//获取字符串的长度
int length = content.length();
- //当字符串长度大于200时，采集体温数据，小于则采集报警数据
+ //当字符串长度大于200时，采集体温数据
//只有数据长度大于300时，采集体温数据 200-300 之间为心跳数据，当前不采集
if (length>250){
//插入数据
--
Gitblit v1.9.3