diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java index a674b00..fdd159f 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java +++ b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java @@ -150,6 +150,13 @@ public class NettyServer { //发送消息 public void flushMsgToDevice(String uuid, String clientKey, boolean request, String xml) { if (tcpClientMap.containsKey(clientKey)) { + if(clientKey.startsWith("areaPatrolServer")) { + xml = xml.replace("", ""); + xml = xml.replace("", ""); + } else { + xml = xml.replace("", ""); + xml = xml.replace("", ""); + } ByteBuf byteBuf = Unpooled.copiedBuffer(xml, CharsetUtil.UTF_8); int length = byteBuf.readableBytes(); ByteBuf allBuf = Unpooled.buffer(length + ConfigType.dataLength); @@ -173,6 +180,13 @@ public class NettyServer { public void flushMsgToDeviceBroadcast(String uuid, String clientKey, boolean request, String xml) { for (Map.Entry entry : tcpClientMap.entrySet()) { + if(clientKey.startsWith("areaPatrolServer")) { + xml = xml.replace("", ""); + xml = xml.replace("", ""); + } else { + xml = xml.replace("", ""); + xml = xml.replace("", ""); + } ByteBuf byteBuf = Unpooled.copiedBuffer(xml, CharsetUtil.UTF_8); int length = byteBuf.readableBytes(); ByteBuf allBuf = Unpooled.buffer(length + ConfigType.dataLength);