2

我有一个发送多播数据包的应用程序。

我使用 BlockingCollection 来存储我必须发送的消息，然后一个线程专用于发送只是迭代这个集合并在其中发送消息。我为每个本地 IP 都有一个套接字，因为我需要在每个 IP 上发送它。

它通常工作得很好，但最近，我的线程多次挂在 Socket.SendTo 调用上，导致我的应用程序不再响应任何外部调用。我的 BlockingCollection 变得越来越大，并且从未被处理过。

我找不到任何理由让这个 Socket.SendTo 调用阻止我的调用。如果是 TCP 调用，我可以想象另一边没有人，但在这里使用 UDP，我看不到任何可能的问题。

我的代码基本上是：

Debug.WriteLine("Sending message on local endpoint " + socket.Key + ", to " + remoteEndpoint);
int sendTo = socket.Value.SendTo(buffer, remoteEndpoint);
Debug.WriteLine("Successfully sent a packet with "+sendTo+" bytes");

在我的日志中，我看到：

[...]
Sending message on local endpoint 10.10.23.56, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 10.9.53.38, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 127.0.0.1, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 10.10.23.56, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 10.9.53.38, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 127.0.0.1, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 10.10.23.56, to 224.0.0.253:5353
Successfully sent a packet with 778 bytes
Sending message on local endpoint 10.9.53.38, to 224.0.0.253:5353¨

我像这样创建我的套接字：

Socket sendSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
sendSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.MulticastTimeToLive, 255);
sendSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
sendSocket.MulticastLoopback = true;
sendSocket.Bind(new IPEndPoint(localAddress, m_port));
sendSocket.SetSocketOption(SocketOptionLevel.IP, SocketOptionName.AddMembership,new MulticastOption(m_multicastAddress, localAddress));

我在这里看到它在发送我的所有消息之前一直处于阻塞状态，但是出于什么原因我的消息可能会像这样被阻止？但是在这里，我的电话在这里被阻止了几分钟。

怎么办？有时间处理 Socket 并在我的数据包未发送时尝试再次创建它吗？

编辑：我尝试对异步发送/接收做同样的事情，但更糟糕的是：我仍然在 EndReceiveTo 上被阻止，但此外，它阻止我终止进程（访问被拒绝，我是管理员，必须重新启动： /)

编辑 在 xaxxon 回答之后，我在发送消息之前放置了这个，以查看我是否有无法写入或错误的套接字：

List<Socket> socketWrite = socketToUse.Select(s => s.Value).ToList();
List<Socket> socketError = socketToUse.Select(s => s.Value).ToList();
Socket.Select(null, socketWrite, socketError, 1000);
Console.WriteLine("Writeable sockets: " + String.Join(", ", socketWrite.Select(s => s.LocalEndPoint.ToString())));
Console.WriteLine("Sockets in errors: " + String.Join(", ", socketError.Select(s => s.LocalEndPoint.ToString())));

But before I enter I get stuck  on my `SendTo` call, 
Writeable sockets: 10.10.23.56:5353, 10.9.53.38:5353, 127.0.0.1:5353
Sockets in errors:
Sending message on local endpoint 10.10.23.56, to 224.0.0.253:5353
Successfully sent a packet with 93 bytes
Sending message on local endpoint 10.9.53.38, to 224.0.0.253:5353
Successfully sent a packet with 93 bytes
Sending message on local endpoint 127.0.0.1, to 224.0.0.253:5353
Successfully sent a packet with 93 bytes
Writeable sockets: 10.10.23.56:5353, 10.9.53.38:5353, 127.0.0.1:5353
Sockets in errors:
Sending message on local endpoint 10.10.23.56, to 224.0.0.253:5353
Successfully sent a packet with 1162 bytes
Sending message on local endpoint 10.9.53.38, to 224.0.0.253:5353
__HERE I GET STUCK
4

2 回答 2

2

与 TCP 套接字一样，甚至 UDP 套接字也有一个传出（发送）缓冲区。如果该发送缓冲区已满，那么即使 sendTo() 调用也会阻塞。您可以尝试设置 SO_SNDBUF 套接字选项以增加传出发送缓冲区的大小。另一个原因是您是否需要解析 ARP。如果路由中的下一跳或目的地本身位于同一子网中并且没有 ARP 条目，则可能会发生这种情况。由于 ARP 解析由 ARP 请求/ARP 响应组成，因此当您收到 ARP 响应时，发送方可能已经将足够的数据包排入队列以填充发送缓冲区。我会尝试逐步增加 SO_SNDBUF 并查看您遇到的问题是否变得不那么严重 - 这将有助于确定发送缓冲区确实是阻塞问题的原因。

这是一个讨论设置 SO_SNDBUF 的链接。 http://msdn.microsoft.com/en-us/library/windows/desktop/ms740476%28v=vs.85%29.aspx

于 2013-09-13T17:06:13.190 回答
1

不要乱用套接字发送缓冲区。不可能在所有情况下都做到这一点。

相反，使用非阻塞套接字，并在发送前检查套接字是否可写。当有可用空间时，这将让您填满缓冲区。

于 2013-09-14T01:20:42.630 回答