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个发送者应用程序,只有大约四分之一的消息被接收。
我能做些什么来减少数据包丢失?
考虑到您在旅途中发送数据包的速度,我会说水槽缓冲区可能会在一段时间内被填满-我猜增加缓冲区大小(如图所示)可以解决这个问题。