| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | 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()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | 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){ |
|---|
| | | //插入数据 |
|---|
