package org.springblade.jfpt.nettyTcpServer;
|
|
import io.netty.buffer.ByteBuf;
|
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;
|
import org.springblade.jfpt.animalheat.service.AnimalHeatService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import javax.annotation.PostConstruct;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
@Component
|
public class TcpServerHandler extends ChannelInboundHandlerAdapter {
|
|
private static TcpServerHandler tcpServerHandler;
|
|
@Autowired
|
private AnimalHeatService animalHeatService;
|
|
@PostConstruct
|
public void init() {
|
tcpServerHandler = this;
|
}
|
/**
|
* 客户端与服务端创建连接的时候调用
|
*/
|
@Override
|
public void channelActive(ChannelHandlerContext ctx) throws Exception {
|
System.out.println("CTX:"+ctx.channel());
|
System.out.println("客户端与服务端连接开始...");
|
}
|
|
/**
|
* 客户端与服务端断开连接时调用
|
*/
|
@Override
|
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
|
System.out.println("客户端与服务端连接关闭...");
|
NettyConfig.group.remove(ctx.channel());
|
}
|
|
/**
|
* 服务端接收客户端发送过来的数据结束之后调用
|
*/
|
@Override
|
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
|
ctx.flush();
|
System.out.println("信息接收完毕...");
|
}
|
|
/**
|
* 工程出现异常的时候调用
|
*/
|
@Override
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
|
cause.printStackTrace();
|
ctx.close();
|
}
|
|
/**
|
* 服务端处理客户端websocket请求的核心方法，这里接收了客户端发来的信息
|
*/
|
@Override
|
public void channelRead(ChannelHandlerContext channelHandlerContext, Object info) throws Exception {
|
System.out.println("接收到了："+info);
|
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);
|
//获取字符串的长度
|
int length = content.length();
|
//当字符串长度大于200时，采集体温数据
|
//只有数据长度大于300时，采集体温数据 200-300 之间为心跳数据，当前不采集
|
if (length>250){
|
//插入数据
|
tcpServerHandler.animalHeatService.save(body);
|
}
|
}
|
|
|
}
|
