.net8創建tcp服務接收數據通過websocket廣播

注冊TCP服務器注冊WebSocket中間件

using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Text.Json;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.AspNetCore.WebSockets;var builder = WebApplication.CreateBuilder(args);// 注冊TCP服務
builder.Services.AddSingleton<TcpServer>();
builder.Services.AddHostedService(sp => sp.GetRequiredService<TcpServer>());// 注冊WebSocket中間件
builder.Services.AddSingleton<WebSocketManager>();builder.WebHost.UseUrls("http://*:5000");//指定websocket端口號var app = builder.Build();// WebSocket中間件
app.UseWebSockets();
app.Use(async (context, next) =>
{if (context.WebSockets.IsWebSocketRequest){var webSocketManager = context.RequestServices.GetRequiredService<WebSocketManagement>();var webSocket = await context.WebSockets.AcceptWebSocketAsync();await webSocketManager.HandleWebSocketConnectionAsync(webSocket);}else{await next(context);}
});app.Run();

tcp服務實現

public class TcpServer : BackgroundService
{private readonly WebSocketManagement _webSocketManager;private const int Port = 8081;private const int PacketSize = 14;private const int CheckSumSize = 2;private TcpListener? _listener;public TcpServer(WebSocketManagement webSocketManager){_webSocketManager = webSocketManager;}protected override async Task ExecuteAsync(CancellationToken stoppingToken){_listener = new TcpListener(IPAddress.Any, Port);_listener.Start();Console.WriteLine($"TCP server started on port {Port}");try{while (!stoppingToken.IsCancellationRequested){try{var client = await _listener.AcceptTcpClientAsync(stoppingToken);_ = HandleClientAsync(client, stoppingToken);}catch (OperationCanceledException){// 服務停止時正常退出break;}}}finally{_listener.Stop();Console.WriteLine("TCP server stopped");}}private async Task HandleClientAsync(TcpClient client, CancellationToken ct){var clientId = Guid.NewGuid().ToString();Console.WriteLine($"Client connected: {clientId}");using (client){byte[] buffer = new byte[1024];var stream = client.GetStream();while (!ct.IsCancellationRequested){try{int bytesRead = await stream.ReadAsync(buffer, 0, buffer.Length);if (bytesRead > 0){byte[] receivedData = new byte[bytesRead];Array.Copy(buffer, receivedData, bytesRead);Log.Information($"收到 {bytesRead} bytes 來自儀器.");Console.WriteLine($"收到 {bytesRead} bytes 來自儀器.");// 解析數據并生成應答var result = await ParseData(receivedData/*, out byte[] response*/);if (result.success){Log.Information(result.message);Console.WriteLine(result.message);//響應發送if (result.response.Length > 0) await stream.WriteAsync(result.response, 0, result.response.Length);Log.Information($"響應發送.");Console.WriteLine("響應發送.");}else{Log.Information($"Error: {result.message}");Console.WriteLine($"Error: {result.message}");}} }catch (IOException ex){Console.WriteLine($"Client {clientId} connection error: {ex.Message}");return;}catch (ObjectDisposedException){Console.WriteLine($"Client {clientId} connection closed");return;}catch (Exception ex){Console.WriteLine(ex.Message, $"Error processing client {clientId}");return;}}}} //血透private const int ZL_PacketLength = 14;public const byte ZL_START_CODE_UPLOAD = 0x55; // 血壓計上傳數據開始碼private static readonly byte[] ZL_Header = { 0x55, 0xAA };// 解析數據包private async Task<(bool success, byte[] response, string message)> ParseData(byte[] buffer/*, out byte[] response*/){//response = null; // 檢查前導碼if (buffer.Length == ZL_PacketLength && buffer[0] == ZL_Header[0] && buffer[1] == ZL_Header[1]){//var result =await HemodialysisZLMonitor(buffer );return (result.success,new byte[0], result.message);}else{return (false, new byte[0], "前導碼錯誤");}//return (result.success, result.message);} /// <summary>/// 儀器（/// </summary>/// <param name="buffer"></param>/// <param name="response"></param>/// <returns></returns>private async Task<(bool success , string message)> HemodialysisZLMonitor(byte[] buffer){ // 計算校驗和（前12字節的累加和）ushort calculatedChecksum = 0;for (int i = 0; i < 12; i++)calculatedChecksum += buffer[i];// 讀取數據包中的校驗和（大端序）ushort packetChecksum = (ushort)((buffer[12] << 8) | buffer[13]);// 校驗和驗證if (calculatedChecksum != packetChecksum)throw new ArgumentException($"Checksum mismatch: calculated 0x{calculatedChecksum:X4}, received 0x{packetChecksum:X4}");// 解析數據var result = new ZL_ParsedData{DeviceType = buffer[2],DeviceId = (uint)((buffer[3] << 16) | (buffer[4] << 8) | buffer[5]),HasOtherAlarm = buffer[8] != 0,DataIdentifier = buffer[9]};// 處理運行模式/權值byte modeWeight = buffer[6];if (modeWeight >= 10 && modeWeight <= 17)result.OperationMode = GetModeName(modeWeight);elseresult.DataWeight = modeWeight;// 解析報警標志result.AlarmFlags = ParseAlarmFlags(buffer[7]);// 解析數據值（2字節）ushort rawValue = (ushort)((buffer[10] << 8) | buffer[11]);// 特殊處理有符號數據if (new[] { 0x0A, 0x0B, 0x0E }.Contains(result.DataIdentifier))rawValue = (ushort)(short)rawValue; // 保持二進制表示，后續轉換為double// 應用權值處理result.DataValue = ApplyDataWeight(rawValue, result.DataWeight, result.DataIdentifier);// 設置數據名稱和單位(result.DataName, result.Unit) = GetDataInfo(result.DataIdentifier);//return result;Console.WriteLine("Parsing successful!");Console.WriteLine($"設備類型: 0x{result.DeviceType:X2}");//Device TypeConsole.WriteLine($"設備id: 0x{result.DeviceId}");//十進制 Device ID   16進制：0x{result.DeviceId:X6}Console.WriteLine($"運行模式: {result.OperationMode ?? "N/A"}");//Operation ModeConsole.WriteLine($"數據權值: {result.DataWeight}");//Data WeightConsole.WriteLine($"報警標識: [漏血BloodLeak: {result.AlarmFlags.BloodLeak}, " +//Alarms$"液位LiquidLevel: {result.AlarmFlags.LiquidLevel}, " +$"氣泡Bubble: {result.AlarmFlags.Bubble}, " +$"動脈壓ArterialPressure: {result.AlarmFlags.ArterialPressure}, " +$"跨膜壓TransmembranePressure: {result.AlarmFlags.TransmembranePressure}, " +$"靜脈壓VenousPressure: {result.AlarmFlags.VenousPressure}, " +$"溫度Temperature: {result.AlarmFlags.Temperature}, " +$"電導Conductivity: {result.AlarmFlags.Conductivity}]");Console.WriteLine($"其他報警: {result.HasOtherAlarm}");//Other AlarmsConsole.WriteLine($"數據標識: 0x{result.DataIdentifier:X2} ({result.DataName})");//數據標識Console.WriteLine($"數據值: {result.DataValue} {result.Unit}");//數據值WebSocketSend webSocketSend = new WebSocketSend { Name= result.DataName,Value= result.DataValue };await _webSocketManager.BroadcastAsync(Convert.ToString(result.DeviceId), webSocketSend);return (true,"");}private ZL_AlarmFlags ParseAlarmFlags(byte flagByte){return new ZL_AlarmFlags{BloodLeak = (flagByte & 0x01) != 0,LiquidLevel = (flagByte & 0x02) != 0,Bubble = (flagByte & 0x04) != 0,ArterialPressure = (flagByte & 0x08) != 0,TransmembranePressure = (flagByte & 0x10) != 0,VenousPressure = (flagByte & 0x20) != 0,Temperature = (flagByte & 0x40) != 0,Conductivity = (flagByte & 0x80) != 0};}private string GetModeName(byte mode){return mode switch{10 => "Dialysis",12 => "LowSuper",13 => "SingleSuper",14 => "BloodReturn",15 => "Precharge",16 => "SelfTest",17 => "Disinfection",_ => "Unknown"};}private double ApplyDataWeight(ushort rawValue, int weight, byte dataId){// 特殊處理電導值（數據標識0x09）if (dataId == 0x09 && weight > 4)return rawValue; // 按整數顯示return weight switch{0 or 15 => rawValue,          // 整數> 0 and <= 4 => rawValue / Math.Pow(10, weight), // 小數處理_ => rawValue                 // 默認按整數處理};}private (string name, string unit) GetDataInfo(byte dataId){var dataMap = new Dictionary<byte, (string, string)>{{ 0x01, ("dehydration", "L") },//脫水1{ 0x02, ("currentDehydration", "L") },//當前的脫水2{ 0x03, ("dehydrationSpeed", "L/h") },//脫水速度3{ 0x04, ("bloodPumpFlow", "ml/min") },//血泵流量4{ 0x05, ("auxiliaryPump", "") },//輔助泵5{ 0x06, ("syringe", "ml/h") },//注射器6{ 0x07, ("dialysateFlow", "") },//透析液流量7{ 0x08, ("dialysateTemperature", "°C") },//透析液溫度8{ 0x09, ("dialysateConductivity", "mS/cm") },//透析液電導9{ 0x0A, ("venousPressure", "") },//靜脈壓力A{ 0x0B, ("transmembranePressure", "") },//跨膜壓力B{ 0x0C, ("dialyzedTime", "min") },//已透析時間C{ 0x0D, ("remainingTime", "min") },//剩余透析時間D{ 0x0E, ("arterialPressure", "") },//動脈壓E{ 0x0F, ("sphygmomanometerHigh", "") },//血壓計測量 高壓F{ 0x10, ("sphygmomanometerLow", "") },//血壓計測量 低壓10{ 0x11, ("heartRate", "bpm") }//心率11};return dataMap.TryGetValue(dataId, out var info)? info: ("Unknown", "");}}

WebSocket服務

public class WebSocketManagement
{private readonly ConcurrentDictionary<string, WebSocket> _sockets = new();public async Task HandleWebSocketConnectionAsync(WebSocket webSocket){var buffer = new byte[1024 * 4];var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);if (result.MessageType == WebSocketMessageType.Text){var deviceId = Encoding.UTF8.GetString(buffer, 0, result.Count);_sockets[deviceId.Trim()] = webSocket;Console.WriteLine("socket消息：" + deviceId);}while (webSocket.State == WebSocketState.Open){await Task.Delay(100);}}public async Task BroadcastAsync(string socketId, dynamic data){var json = JsonConvert.SerializeObject(data);var buffer = Encoding.UTF8.GetBytes(json);_sockets.TryGetValue(socketId, out WebSocket socket);if (socket!=null&&socket.State == WebSocketState.Open){await socket.SendAsync(new ArraySegment<byte>(buffer), WebSocketMessageType.Text, true, CancellationToken.None);}else{_sockets.TryRemove(socketId, out _);}}
}

測試數據發送接收

# PowerShell
$data = [byte[]](0x55, 0xAA, 0x00, 0x26, 0x35, 0xB2, 0x00, 0x00, 0x01, 0x0E, 0x00, 0x00, 0x02, 0x1B)
$client = New-Object System.Net.Sockets.TcpClient('localhost', 8081)
$stream = $client.GetStream()
$stream.Write($data, 0, $data.Length)
$client.Close()