From 6d5ff381cafca9b82e11407dc67bf6b74f1397ee Mon Sep 17 00:00:00 2001
From: 826220679@qq.com <826220679@qq.com>
Date: 星期一, 11 八月 2025 23:15:40 +0800
Subject: [PATCH] 20250811
---
src/publicsWay/PacketProcessingSystem.java | 15 +++++++++++----
1 files changed, 11 insertions(+), 4 deletions(-)
diff --git a/src/udptcp/PacketProcessingSystem.java b/src/publicsWay/PacketProcessingSystem.java
similarity index 88%
rename from src/udptcp/PacketProcessingSystem.java
rename to src/publicsWay/PacketProcessingSystem.java
index 7a31faf..24dcf5c 100644
--- a/src/udptcp/PacketProcessingSystem.java
+++ b/src/publicsWay/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;
@@ -62,8 +64,7 @@
isRunning.set(true);
parserThread = new Thread(() -> {
- PacketParser bufferManager = new PacketParser();
-
+ 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);
+ }
// 其他类型处理方法...
}
--
Gitblit v1.9.3