20250811

826220679@qq.com

9 天以前 6d5ff381cafca9b82e11407dc67bf6b74f1397ee

 src/publicsWay/PacketProcessingSystem.java

ÎļþÃû´Ó src/udptcp/PacketProcessingSystem.java ÐÞ¸Ä
@@ -1,8 +1,10 @@
package udptcp;
package publicsWay;
import java.util.List;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.atomic.AtomicBoolean;
import dell55AAData.Dell55AA01Parser;
import dell55AAData.Dell55AA12HighPerf;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@@ -63,7 +65,6 @@
        isRunning.set(true);
        parserThread = new Thread(() -> {
            PacketParser bufferManager = new PacketParser();
            
            while (isRunning.get()) {
                HexPacket packet = packetQueue.poll();
                if (packet == null) {
@@ -88,7 +89,8 @@
                                processType01(p,ip,port);break;
                            case 0x02:
                                processType02(p,ip,port);break;
                            
                            case 0x12:
                               processType12(p,ip,port);break;
                            default:
                                System.err.println("未知包类型: " + p.getPacketType());
                        }
@@ -119,9 +121,14 @@
    }

    private static void processType02(PacketParser.DataPacket packet,String ip,int port) {
       String hexData = PacketParser.bytesToHexString(packet.getPacket());
        System.out.println("处理55AA02包: " + packet);
        // å®žé™…业务逻辑
    }
    
    private static void processType12(PacketParser.DataPacket packet,String ip,int port) {
       String hexData = PacketParser.bytesToHexString(packet.getPacket());
       Dell55AA12HighPerf.parse(hexData,ip,port);
    }
    // å…¶ä»–类型处理方法...
}