wuyanchen/XNet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

`

Browse Source
This commit is contained in:
wuyanchen 2025-12-25 15:48:30 +08:00
parent 2b28969d27
commit e43ea79f91
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
XNet.Business/WsConnectionManager.cs
View File

@ -256,25 +256,25 @@ namespace XNet.Business
}
}
private async Task SendToSingleConnAsync(WebSocket socket, byte[] data, string connId, List<string> deadConnIds)
{
try
{
if (socket.State == WebSocketState.Open)
{
await socket.SendAsync(new ArraySegment<byte>(data), WebSocketMessageType.Binary, true, CancellationToken.None);
}
else
{
deadConnIds.Add(connId);
}
}
catch (Exception ex)
{
Console.WriteLine($"[WS .NET 10] 发送失败 {connId}：{ex.Message}");
deadConnIds.Add(connId);
}
}
//private async Task SendToSingleConnAsync(WebSocket socket, byte[] data, string connId, List<string> deadConnIds)
//{
// try
// {
// if (socket.State == WebSocketState.Open)
// {
// await socket.SendAsync(new ArraySegment<byte>(data), WebSocketMessageType.Binary, true, CancellationToken.None);
// }
// else
// {
// deadConnIds.Add(connId);
// }
// }
// catch (Exception ex)
// {
// Console.WriteLine($"[WS .NET 10] 发送失败 {connId}：{ex.Message}");
// deadConnIds.Add(connId);
// }
//}
public async ValueTask DisposeAsync()
{