| | |
| | | import java.util.concurrent.ConcurrentLinkedQueue; |
| | | import java.util.concurrent.atomic.AtomicBoolean; |
| | | import dell55AAData.Dell55AA01Parser; |
| | | import dell55AAData.Dell55AA02Parser; |
| | | import dell55AAData.Dell55AA12HighPerf; |
| | | |
| | | import java.util.concurrent.ExecutorService; |
| | |
| | | // 处理解析后的数据包 |
| | | for (PacketParser.DataPacket p : parsedPackets) { |
| | | // 根据包头类型路由到不同解析器 |
| | | // System.out.println(p.getPacketType()); |
| | | switch (p.getPacketType()) { |
| | | case 0x01: |
| | | processType01(p,ip,port);break; |
| | |
| | | |
| | | private static void processType02(PacketParser.DataPacket packet,String ip,int port) { |
| | | String hexData = PacketParser.bytesToHexString(packet.getPacket()); |
| | | System.out.println("处理55AA02包: " + packet); |
| | | Dell55AA02Parser.parse(hexData,ip,port); |
| | | // 实际业务逻辑 |
| | | } |
| | | |