快捷導(dǎo)航

高效的.Net UDP異步編程實(shí)現(xiàn)分析

更新時(shí)間：2012年11月30日 11:36:54 作者：

重點(diǎn)是怎么建立一種高效的UDP機(jī)制來(lái)實(shí)時(shí)接收服務(wù)器發(fā)送過(guò)來(lái)的數(shù)據(jù)包.本文將介紹.Net UDP異步編程如何實(shí)現(xiàn)解決方案,有需求的朋友可以參考下

因?yàn)橐獙?xiě)一個(gè)網(wǎng)絡(luò)程序要用到UDP協(xié)議,UDP這東西比較麻煩,又不像TCP一樣提供可靠的連接,發(fā)送接收的超時(shí)實(shí)在不好設(shè)計(jì),最后只要用Timer來(lái)檢測(cè)有沒(méi)有想要的數(shù)據(jù)包-_#,不過(guò)這不是這次的重點(diǎn),重點(diǎn)是怎么建立一種高效的UDP機(jī)制來(lái)實(shí)時(shí)接收服務(wù)器發(fā)送過(guò)來(lái)的數(shù)據(jù)包.

CodeProject上有個(gè)例子是開(kāi)個(gè)線程去同步接收,這樣倒是可以滿足我的程序需求,不過(guò)實(shí)際中遇到幾個(gè)問(wèn)題:
1.程序開(kāi)銷大,內(nèi)存狂飆,接一次數(shù)據(jù)就要重新開(kāi)一次線程
2.由于主界面和底層是完全隔離只是通過(guò)中間的接口來(lái)通訊,導(dǎo)致線程總是不能正常的結(jié)束,程序結(jié)束后還有一個(gè)進(jìn)程在那里不知道干什么.
于是翻閱MSDN,查找自己以前寫(xiě)的代碼,最后還是決定用異步來(lái)接收,MSDN上UDP異步的例子不太好,有點(diǎn)敷衍的意思,用異步很好的解決了以上的問(wèn)題,高效完成效率,代碼如下:

復(fù)制代碼代碼如下:

 
UdpClient qq_client; //Udp客戶端 
qq_client = new UdpClient(); 
IPEndPoint remoteQQEP = new IPEndPoint(remotehost, remoteport); 
qq_client.Connect(remoteQQEP); 
AsyncCallback GetRecvBuffer = new AsyncCallback(ReceiveCallback); 
qq_client.BeginReceive(GetRecvBuffer, null); 
這里用一個(gè)GetRecvBuffer的回掉來(lái)實(shí)現(xiàn)異步 
private void ReceiveCallback(IAsyncResult ar) 
{ 
try 
{ 
lock (this) 
{ 
byte[] recvbytes = qq_client.EndReceive(ar, ref remoteQQEP); 
//QQFunction.DebugDump(recvbytes); 
if (recvbytes[0] != QQDef.QQ_IM_HEAD && recvbytes[0] != 0x03) 
{ 
//非QQ數(shù)據(jù)包 
return; 
} 
switch (Pop16(recvbytes, 3)) 
{ 
case QQDef.QQ_REQUEST_TOKEN: 
DoGetToken(recvbytes); 
break; 
case QQDef.QQ_REQUEST_LOGIN: 
DoGetLogin(recvbytes); 
break; 
case QQDef.QQ_GET_ONLINE_FRIEND: 
DoGetOnline(recvbytes); 
break; 
case QQDef.QQ_KEEP_ALIVE: 
CheckAlive(recvbytes); 
break; 
case QQDef.QQ_SEND_IM_MSG: 
// Do SomeThing 
break; 
case QQDef.QQ_RECV_IM_MSG: 
DoRecvMsg(recvbytes); 
break; 
default: 
QQFunction.DebugDump("UnKnow Command"); 
QQFunction.DebugDump(recvbytes); 
break; 
} 
} 
lock (this) 
{ 
AsyncCallback GetRecvBuffer = new AsyncCallback(ReceiveCallback); 
qq_client.BeginReceive(GetRecvBuffer, null); 
} 
} 
catch 
{ 
} 
} 