UDP与多个发送者和一个单一的接收者

本文关键字:一个 单一 接收者 发送者 UDP | 更新日期: 2023-09-27 18:16:43

在一个项目中,我有多个UDP数据发送者,但只有一个接收者。

如果流量变大,接收端会"忘记"很多数据包。我知道这是UDP固有的问题,但我想尽量减少丢失的数据包数量。

我以前看过这个问题!

这是我的代码(请原谅大量的代码块,但我希望这个例子是自包含的)

发送方

:

public class UdpSender
{
    private static int portNumber = 15000;
    public void Send(string data)
    {
        var udpServer = new UdpClient();
        var ipEndPoint = new IPEndPoint(IPAddress.Broadcast, portNumber);
        byte[] bytes = Encoding.ASCII.GetBytes(data);
        udpServer.Send(bytes, bytes.Length, ipEndPoint);
        udpServer.Close();
    }
}

class Program
{
    static void Main(string[] args)
    {
        var sender = new UdpSender();
        var count = 100000;
        for (var i = 0; i < count; ++i)
        {
            sender.Send(i.ToString());
        }
        Console.ReadKey();
    }
}

接收机:

public class UDPListener
{
    private static int portNumber = 15000;
    private readonly UdpClient udp = new UdpClient(portNumber);
    public volatile int CountOfReceived = 0;
    public void StartListening()
    {
        this.udp.BeginReceive(Receive, new object());
    }
    private void Receive(IAsyncResult ar)
    {
        Interlocked.Increment(ref CountOfReceived);
        IPEndPoint ip = new IPEndPoint(IPAddress.Any, portNumber);
        byte[] bytes = udp.EndReceive(ar, ref ip);
        string message = Encoding.ASCII.GetString(bytes);
        StartListening();
    }
}
class Program
{
    static void Main(string[] args)
    {
        var listener = new UDPListener();
        listener.StartListening();
        while (true)
        {
            Console.WriteLine(listener.CountOfReceived.ToString("000,000,000"));
        }
    }
}

现在,如果我并行启动5个发送者应用程序,只有大约四分之一的消息被接收。

我能做些什么来减少数据包丢失?

UDP与多个发送者和一个单一的接收者

考虑到您在旅途中发送数据包的速度,我会说水槽缓冲区可能会在一段时间内被填满-我猜增加缓冲区大小(如图所示)可以解决这个问题。