C#学习教程:UDP服务器中接收数据包的连接重置分享


UDP服务器中接收数据包的连接重置

我正在研究一个服务器应用程序(C#,.NET 4.0),它需要每秒处理数千个UDP数据包。 所以我决定使用SocketAsyncEventArg来实现服务器。

我面临的问题是我的实现只收到一个数据包然后我得到“ConnectionReset”错误(我从未想过我会得到这个错误,因为UDP是无连接的)。 这是我的测试实现:

 using System; using System.Net; using System.Net.Sockets; static class Program { static void Main(string[] args) { UdpEchoServer.Start(); while (true) { Console.ReadLine(); SendPacket(); } } static void SendPacket() { Console.WriteLine("SendPacket"); var c = new UdpClient(); c.Send(new byte[5], 5, new IPEndPoint(IPAddress.Parse("127.0.0.1"), 445)); c.Close(); } } static class UdpEchoServer { static Socket mSocket; static byte[] mBuffer; static SocketAsyncEventArgs mRxArgs, mTxArgs; static IPEndPoint mAnyEndPoint, mLocalEndPoint; public static void Start() { mAnyEndPoint = new IPEndPoint(IPAddress.Any, 0); mLocalEndPoint = new IPEndPoint(IPAddress.Any, 445); mBuffer = new byte[1024]; mRxArgs = new SocketAsyncEventArgs(); mTxArgs = new SocketAsyncEventArgs(); mRxArgs.Completed += ReceiveComplete; mTxArgs.Completed += SendComplete; mSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); mSocket.Bind(mLocalEndPoint); ReceiveNext(); } static void ReceiveNext() { Console.WriteLine("ReceiveNext"); mRxArgs.RemoteEndPoint = mAnyEndPoint; mRxArgs.SetBuffer(mBuffer, 0, mBuffer.Length); if (!mSocket.ReceiveFromAsync(mRxArgs)) Console.WriteLine("Error in ReceiveNext: " + mRxArgs.SocketError); } static void ReceiveComplete(object sender, SocketAsyncEventArgs e) { Console.WriteLine("Receive Complete: " + mRxArgs.SocketError); if (mRxArgs.SocketError != SocketError.Success) return; mTxArgs.SetBuffer(mBuffer, 0, mRxArgs.BytesTransferred); mTxArgs.RemoteEndPoint = mRxArgs.RemoteEndPoint; Console.WriteLine("Sending reply packet"); if (!mSocket.SendToAsync(mTxArgs)) Console.WriteLine("Error in ReceiveComplete: " + mRxArgs.SocketError); } static void SendComplete(object sender, SocketAsyncEventArgs e) { Console.WriteLine("Send Complete: " + mTxArgs.SocketError); if (mTxArgs.SocketError != SocketError.Success) return; ReceiveNext(); } } 

很抱歉长代码,但它非常简单。 我等待一个数据包,回复远程终点,然后等待下一个。 这是输出:

 ReceiveNext SendPacket Receive Complete: Success Sending reply packet Send Complete: Success ReceiveNext Error in ReceiveNext: ConnectionReset 

请问您能在上面的代码片段中提出错误的建议吗?

使用UDP套接字会发生这种情况。 您需要做的就是在绑定之前更改套接字操作模式 。 在Start方法中使用此代码。

 mSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); const int SIO_UDP_CONNRESET = -1744830452; byte[] inValue = new byte[] {0}; byte[] outValue = new byte[] {0}; mSocket.IOControl(SIO_UDP_CONNRESET, inValue, outValue); mSocket.Bind(mLocalEndPoint); 

如果在UdpClient上删除或注释掉对Close的调用,则程序按预期工作。 为什么会发生这种情况我不确定,但它可能与Windows环回网络有关。

上述就是C#学习教程:UDP服务器中接收数据包的连接重置分享的全部内容,如果对大家有所用处且需要了解更多关于C#学习教程,希望大家多多关注—猴子技术宅(www.ssfiction.com)

本文来自网络收集,不代表猴子技术宅立场,如涉及侵权请点击右边联系管理员删除。

如若转载,请注明出处:https://www.ssfiction.com/ckf/960117.html

发表评论

邮箱地址不会被公开。 必填项已用*标注