826220679@qq.com
20 小时以前 1bda9524add969e315d870f284046ecf1097f956
src/publicsWay/PacketProcessingSystem.java
@@ -3,6 +3,7 @@
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;
@@ -84,6 +85,7 @@
                    // 处理解析后的数据包
                    for (PacketParser.DataPacket p : parsedPackets) {
                        // 根据包头类型路由到不同解析器
//                       System.out.println(p.getPacketType());
                        switch (p.getPacketType()) {
                            case 0x01:
                                processType01(p,ip,port);break;
@@ -122,7 +124,7 @@
    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);
        // 实际业务逻辑
    }