From ccb681ec3a4ef38da878ac3a01c498853e9be4ca Mon Sep 17 00:00:00 2001
From: 826220679@qq.com <826220679@qq.com>
Date: 星期六, 09 八月 2025 16:34:19 +0800
Subject: [PATCH] 修改
---
src/udptcp/UDPPortBReceiver.java | 21 ++++++---------------
1 files changed, 6 insertions(+), 15 deletions(-)
diff --git a/src/udptcp/UDPPortBReceiver.java b/src/udptcp/UDPPortBReceiver.java
index 4e8a5cd..9e006a4 100644
--- a/src/udptcp/UDPPortBReceiver.java
+++ b/src/udptcp/UDPPortBReceiver.java
@@ -2,22 +2,21 @@
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
-import java.text.SimpleDateFormat;
-import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicLong;
-import dell_system.MessageViewPanel;
public class UDPPortBReceiver {
public static final int PORT = 7000;
- private static final int MAX_DEVICES = 50000;
+ @SuppressWarnings("unused")
+ private static final int MAX_DEVICES = 50000;
private static final AtomicLong packetCount = new AtomicLong(0);
private static final ExecutorService executor = Executors.newFixedThreadPool(10);
private static DatagramSocket socket;
private static volatile boolean isRunning = false;
private static Thread receiverThread;
- private static final int LOCAL_PORT = PORT; // 定义本地端口
+ @SuppressWarnings("unused")
+ private static final int LOCAL_PORT = PORT; // 定义本地端口
// 启动接收器的静态方法
public static void startReceiver() {
if (isRunning) return;
@@ -37,15 +36,8 @@
String ip = packet.getAddress().getHostAddress();
int port = packet.getPort();
String hexData = bytesToHex(packet.getData(), packet.getLength());
- packetCount.incrementAndGet();
- // 获取当前时间和时间戳
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- String time = sdf.format(new Date());
- int timestamp = (int)(System.currentTimeMillis() / 1000);
-
- // 保存到HexBaowen集合
- // 调用时添加本地端口参数
- HexBaowen.intsert(ip, hexData, time, port, LOCAL_PORT, timestamp);
+ // 调用时添加本地端口参数
+ PacketProcessingSystem.storePacket(ip, port, hexData);
} catch (Exception e) {
System.err.println("Error processing UDP-A packet: " + e.getMessage());
@@ -74,7 +66,6 @@
}
// 发送数据到指定设备
- // 发送数据到指定设备
public static void sendData(String ip, int port, String data, boolean isHex) {
try {
byte[] sendBytes;
--
Gitblit v1.9.3