1

我对 UDP 套接字相当陌生，我的大部分套接字经验都是使用 TCP。

我正在使用 C# 创建一个 UDP 套接字，绑定它，然后不断地监听来自 IP 的数据包。但是，当客户端发送数据包时，套接字会抛出异常：“现有连接被远程主机强制关闭”。

这就是我创建 UDP 套接字的方式：

Socket UDPSocket = new Socket(SocketType.Dgram, ProtocolType.Udp); //Create UDP socket
UDPSocket.Bind(new IPEndPoint(IPAddress.Any, 1338)); //Bind port 1338 from any IP

创建套接字后，我异步接收数据：

UDPSocket.BeginReceiveFrom(newClient.bufferu, 0, AbstractServerClient.BUFFER_SIZE, 0, ref newClient.remoteEndpoint,new AsyncCallback(ReceiveCallbackUDP), newClient);

newClient.remoteEndpoint来自 TCP 套接字的端点，因此 UDP 有效地接收来自 TCP 连接到的同一 IP 的数据包。假设其余参数有效（它们在 TCP 上工作正常）。

该ReceiveCallbackUDP方法如下所示：

public void ReceiveCallbackUDP(IAsyncResult ar)
{
    AbstractServerClient client = (AbstractServerClient)ar.AsyncState;
    int bytesRead = UDPSocket.EndReceive(ar);

    if (bytesRead > 0)
    {
        Bitstream data = new Bitstream(client.bufferu, 12);
        int bytesProcessed = 12;
        while (bytesProcessed < bytesRead)
        {
            ushort messageLength = data.ReadUInt16(); //Read the message length
            byte messageID = data.ReadByte(); //Read the message ID
            // Logger.Log("Received message ID: " + messageID.ToString() + " (Size: " + messageLength + " bytes)");
            bytesProcessed += messageLength + sizeof(UInt16);
            client.GetPacketHandler(messageID).HandlePacket(data); //Process the message
            bytesProcessed += 12;
            data.Seek(bytesProcessed); //Seek to the next message
        }
    }
    UDPSocket.BeginReceiveFrom(client.bufferu, 0, AbstractServerClient.BUFFER_SIZE, 0, ref client.remoteEndpoint, new AsyncCallback(ReceiveCallbackUDP), client);
}

该函数调用EndReceive()套接字读取数据，并对其进行处理，并调用BeginReceiveFrom以等待更多数据（异步）。抛出异常就行了int bytesRead = UDPSocket.EndReceive(ar);

为什么会这样？据我了解，UDP 是一个无连接套接字，因此“现有连接已关闭”异常没有意义。我在这里做错了吗？

4

1 回答 1

0

在BeginReceiveFrom您的 remoteEP 中应该识别正在侦听的套接字，大部分与您用于Bind.

在您的回调方法中ReceiveCallbackUDP，您应该调用EndReceiveFrom，因为这是对应的方法BeginReceiveFrom：

EndPoint tempRemoteEP = (EndPoint)client.remoteEndpoint;
int bytesRead = UDPSocket.EndReceiveFrom(ar, ref tempRemoteEP);

请参阅http://msdn.microsoft.com/en-us/library/system.net.sockets.socket.beginreceivefrom.aspx中的示例，其中tempRemoteEP传递给的端点与传递给BeginReceiveFrom的端点相同。senderBind

于 2013-08-30T09:32:37.400 回答