UDPClient Async BeginReceive非常慢
UDPClient Async BeginReceive非常慢
提问于 2011-05-17 15:38:38
我正在使用UDPClient发送多播请求，并从网络上的各种客户端接收响应。我可以发送请求，也可以获得响应，但我得到的响应非常慢。从所有客户端获取响应需要2-3分钟。当我在WireShark中检查网络上的发送请求时，我只在测试程序中看到来自所有客户端的毫秒级的响应。这需要花费大量的时间。有没有人能指点我可能犯的错误？以下是代码。请在这方面给我指点一下。在过去的两天里，我一直被这个问题所困扰。
public class Trinity_WSDiscovery : IDiscoveryService
{
#region IDiscoveryService Members
public event EventHandler FoundNewDevice;
public event EventHandler EndOfDiscovery;
DeviceBinding m_DeviceBinding;
bool IsFindComplete = false;
Thread receiveThread;
UdpClient sock ;
IPEndPoint RemoteIpEndPoint = new IPEndPoint(System.Net.IPAddress.Any, 0);
IPEndPoint iep = new IPEndPoint(System.Net.IPAddress.Parse("239.255.255.250"), 3702);
UdpState udpState = new UdpState();
XmlDocument xmlDoc = new XmlDocument();
public void Start()
{
//Need to create new object every time we start discovery because
//every time udp buffer needs to be flushed and restarted
sock = new UdpClient();
string str = "<?xml version='1.0' encoding='utf-8'?><soap:Envelope xmlns:soap=\"http://www.w3.org/2003/05/soap-envelope\" xmlns:d=\"http://schemas.xmlsoap.org/ws/2005/04/discovery\" xmlns:wsadis=\"http://schemas.xmlsoap.org/ws/2004/08/addressing\" xmlns:dn=\"http://www.onvif.org/ver10/network/wsdl\"><soap:Header><wsadis:MessageID>uuid:" + System.Guid.NewGuid().ToString() + "</wsadis:MessageID><wsadis:To>urn:schemas-xmlsoap-org:ws:2005:04:discovery</wsadis:To><wsadis:Action>http://schemas.xmlsoap.org/ws/2005/04/discovery/Probe</wsadis:Action></soap:Header><soap:Body><d:Probe><d:Types /> <d:Scopes/></d:Probe></soap:Body></soap:Envelope>";
byte[] data = Encoding.ASCII.GetBytes(str);
sock.Send(data, data.Length, iep);
sock.JoinMulticastGroup(System.Net.IPAddress.Parse("239.255.255.250"));
IPEndPoint iep1 = new IPEndPoint(System.Net.IPAddress.Any, 0);
udpState.ipEndpt = RemoteIpEndPoint;
udpState.udpClient = sock;
BeginReceive();
}
public void BeginReceive()
{
Thread.Sleep(100);
if (sock.Available > 0)
{
sock.BeginReceive(new AsyncCallback(ReceiveCallback), udpState);
}
else
{
FindComplete();
}
}
public void ReceiveCallback(IAsyncResult ar)
{
UdpClient udpClient = (UdpClient)((UdpState)(ar.AsyncState)).udpClient;
IPEndPoint ipEndpt = (IPEndPoint)((UdpState)(ar.AsyncState)).ipEndpt;
Byte[] receiveBytes = udpClient.EndReceive(ar, ref ipEndpt);
string receiveString = Encoding.ASCII.GetString(receiveBytes);
if (receiveString.Contains("NetworkVideoTransmitter"))
{
xmlDoc.LoadXml(receiveString);
XmlNodeList list = xmlDoc.GetElementsByTagName("XAddrs", "http://schemas.xmlsoap.org/ws/2005/04/discovery");
XmlNode node = list[0];
string strEndPoints = node.FirstChild.Value;
string[] strEndPointList = Regex.Split(strEndPoints, " ");
OnFoundDevice(strEndPointList);
}
BeginReceive();
}}`
回答 3
Stack Overflow用户
发布于 2011-05-17 15:42:43
为什么需要Thread.Sleep？
这可能会导致延迟。
Stack Overflow用户
发布于 2011-09-05 16:01:46
我认为您的问题有两个可能的原因。
- 看起来你已经在你的设计中为来自每个响应客户端的每个响应建立了一个100ms的延迟。在BeginReceive方法中，您要做的第一件事就是休眠，无论是否有数据。对于每个响应，您(正确地)调用BeginReceive来注册新的接收回调。但由于一次只有一个注册的ReceiveCallback，因此处理每个响应至少需要100毫秒。如果您同时收到30个传入客户端调用，则最后一个将延迟3秒。
- 在您的ReceiveCallback中，您可以调用您的方法OnFoundDevice。这看起来像一个回调或事件处理程序。此回调花费的任何执行时间都会延迟下一次处理的答案。如果回调耗时为1分钟，则下一次响应将延迟1分钟(加上您的BeginReceive方法中的100ms)。
建议的解决方案: 1.从BeginReceive中删除延迟和条件，如下所示。
public void BeginReceive()
{
sock.BeginReceive(new AsyncCallback(ReceiveCallback), udpState);
}- 回顾OnFoundDevice所做的工作。如果这很耗时，请将调用编组到另一个线程(例如，通过在线程池上执行QueueUserWorkItem )。
如果您在BeginReceive中使用sleep的原因是为了找到何时停止侦听数据的标准，那么您可以在Start方法中为此启动一个计时器，并在预定时间后或在设置的时间范围内未收到数据时调用套接字上的Close。
我希望这能帮到你。
Stack Overflow用户
发布于 2014-09-27 08:04:46
您可以使用超时与阻塞调用，而不是像这样…因为你的程序在等待的时候似乎不想做任何其他的工作..这样，如果响应不到100ms，您就不必等待那么长时间。
udpAdmin.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 100)
receiveBytes = sock.Receive(RemoteIpEndPoint) 'waits here till you get a response or until timeout, whichever comes first.页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/6027706
复制相关文章
相似问题
腾讯云开发者
