SikongJueluo/FPGA_WebLab
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'master' of ssh://git.swordlost.top:222/SikongJueluo/FPGA_WebLab

Browse Source
This commit is contained in:
alivender
2025-07-14 17:15:37 +08:00
parent d901a440a7 6500c1ce2d
commit 683d918d30
11 changed files with 4852 additions and 3588 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
server/src/UdpServer.cs
View File

@@ -346,25 +346,28 @@ public class UDPServer
return retPack.Value;
}
private void ReceiveHandler(byte[] data, IPEndPoint endPoint)
private async Task ReceiveHandler(byte[] data, IPEndPoint endPoint, DateTime time)
{
// Handle RemoteEP
if (endPoint is null)
// 异步锁保护 udpData
await Task.Run(() =>
{
logger.Debug($"Receive Data from Unknown at {DateTime.Now.ToString()}:");
logger.Debug($" Original Data : {BitConverter.ToString(data).Replace("-", " ")}");
return;
}
lock (udpData)
{
// Handle RemoteEP
if (endPoint is null)
{
logger.Debug($"Receive Data from Unknown at {DateTime.Now.ToString()}:");
logger.Debug($" Original Data : {BitConverter.ToString(data).Replace("-", " ")}");
return;
}
// 异步处理数据包
Task.Run(() =>
{
var udpData = RecordUDPData(data, endPoint, Convert.ToInt32(data[1]));
PrintData(udpData);
var udpDataObj = RecordUDPData(data, endPoint, time, Convert.ToInt32(data[1]));
PrintData(udpDataObj);
}
});
}
private UDPData RecordUDPData(byte[] bytes, IPEndPoint remoteEP, int taskID)
private UDPData RecordUDPData(byte[] bytes, IPEndPoint remoteEP, DateTime time, int taskID)
{
var remoteAddress = remoteEP.Address.ToString();
var remotePort = remoteEP.Port;
@@ -374,7 +377,7 @@ public class UDPServer
Port = remotePort,
TaskID = taskID,
Data = bytes,
DateTime = DateTime.Now,
DateTime = time,
HasRead = false,
};
@@ -482,7 +485,7 @@ public class UDPServer
try
{
UdpReceiveResult result = await client.ReceiveAsync();
ReceiveHandler(result.Buffer, result.RemoteEndPoint);
ReceiveHandler(result.Buffer, result.RemoteEndPoint, DateTime.Now);
}
catch (Exception ex)
{
@@ -510,6 +513,7 @@ public class UDPServer
item.Close();
}
this.isRunning = false;
}
}