修改报警器端口

zengh

2021-03-10 fa9ffa9012d7b1df7692bb99e71be6592f48cd4b

 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,6 +72,9 @@
      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);