UDP многоадресный поток внезапно останавливается в течение 1-30 секунд и автоматически начинается снова ⇐ C#

[Anonymous]

Я пытаюсь получить многоадресный поток данных UDP с UDPClient (C# .net 8). Сообщения представляют собой двоичные кодированные сообщения, размер ок. 90 байтов каждый, ок. 50-60 сообщений в секунду. < /P>
Получение потока данных начинается быстро, но внезапно останавливается через несколько минут. Тогда сообщения не получены для 1 ... 30 секунд. Тогда прием сообщений автоматически продолжается. < /P>
приемник работает так: < /p>
using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;

public class TestUDPReceiver
{
static void Main(string[] args)
{
UDPReceiver test = new UDPReceiver();
test.Init();
test.Start();

bool end = false;
while (!end)
{
if (Console.KeyAvailable) end = true;
Thread.Sleep(1000);
}

test.Stop();
}
}

public class UDPReceiver
{
public void Init()
{
// compose IP address and port of local end point
IPAddress.TryParse("0.0.0.0", out IPAddress ip);
int.TryParse("33021", out int port);
IPEndPoint LocalEndPoint = new IPEndPoint(ip, port);

// create UdpClient
C = new UdpClient(LocalEndPoint);

// join multicast group
IPAddress.TryParse("239.255.20.1", out IPAddress multicast);
C.JoinMulticastGroup(multicast);

// set socket options
C.Client.SetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.ReceiveTimeout, 500);
C.Client.SetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.ReceiveBuffer, 10000000);
}

public void Processing()
{
Last = DateTime.UtcNow;
while (!Cancel)
{
try
{
// if data is available, receive it
if (C.Available > 0)
{
// temp variable for endpoint from which the datagram was received
IPEndPoint endPoint = new IPEndPoint(new IPAddress(0), 0);

// receive a message
Byte[] data = C.Receive(ref endPoint);
DateTime rcvTime = DateTime.UtcNow;

// test output
if (rcvTime > Last + TimeSpan.FromMilliseconds(1000))
{
Console.WriteLine($"----------- transmission gap of {(rcvTime-Last).TotalSeconds:F2} secs detected ------------");
}
Console.WriteLine($"msg of {data.Length} bytes received at {rcvTime:HH:mm:ss.fff}");
Last = rcvTime;
}
// if not, sleep a bit
else
{
Thread.Sleep(5);
}
}
catch (Exception ex)
{
Console.WriteLine($"exception caught in worker thread: {ex}");
}
}
}

public void Start()
{
Worker = Task.Run(Processing);
}

public void Stop()
{
Cancel = true;
Worker.Wait();
}

private Task Worker { get; set; } = null;
private UdpClient C { get; set; } = null;
private bool Cancel { get; set; } = false;
private DateTime Last { get; set; }
}
< /code>
Я попытался получить многоадресный поток данных UDP параллельно на двух компьютерах и зарегистрировался, когда произойдут разрывы передачи 1 ... 30sec. В файле журнала я вижу аналогичный шаблон на обоих компьютерах. 90 байтов, скорость сообщений 100 сообщений в всплесках каждые 100 мс. В этом случае> 500.000 сообщений были успешно получены без единой потери сообщения. Является ли UDPClient, анализирующий каким -то образом содержание сообщения и отбрасывает его? /> Тем временем мы проверили приведенный выше код, а также под Linux с тем же эффектом. Операционная система, кажется, не является проблемой, их ошибка в Dotnet?

Подробнее здесь: https://stackoverflow.com/questions/797 ... arts-again