【发布时间】:2013-09-02 15:57:05
【问题描述】:
我对 UDP 套接字相当陌生,我的大部分套接字经验都是使用 TCP。
我正在使用 C# 创建一个 UDP 套接字,绑定它,然后不断地侦听来自 IP 的数据包。但是,当客户端发送数据包时,socket 会抛出异常:“An existing connection was forced by the remote host”。
这就是我创建 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
创建socket后,我异步接收数据:
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 是一个无连接套接字,因此“现有 connection 已关闭”异常没有意义。我在这里做错了吗?
【问题讨论】:
-
您可能遇到了与此处提到的相同的问题:stackoverflow.com/questions/7201862/…