c#中异步基于消息通信的完成端口的tcpip协议的组件实现(源代码)

《c#中异步基于消息通信的完成端口的tcpip协议的组件实现(源代码)》由会员上传分享，免费在线阅读，更多相关内容在工程资料-天天文库。

1、源代码:客户端:usingSystem;usingSystem.IO;usingSystem.ComponentModel;usingSystem.Collections;usingSystem.Diagnostics;usingSystem.Net;usingSystem.Net.Sockets;usingSystem.Threading;namespaceMyKJ{?///?///MyTcpIpClient提供在NetTCP_IP协议上基于消息的客户端?///?publicclassMyTcpIpClient:System.ComponentModel.Com

2、ponent?{??privateintbufferSize=2048;??privatcstringtcpIpScrvcrIP="127.0.0.1??privateinttcplpServerPort=11000;??privateSocketClientSocket=null;??privateManualResetEventconnectDone=newManualResetEvent(false);??privateManualResetEventsendDone=newManualResetEvent(false);99••??privatevoidC

3、onnectCallback(IAsyncResultar)??{???try???{????Socketclient=(Socket)ar.AsyncState;????client.EndConnect(ar);9999••••???calch(Exceptione)???{????OnErrorEvent(newErrorEventArgs(e));???}???finally???{????connectDone.Set();???}??)??privatevoidSendCallback(IAsyncResultar)??{???try???{????S

4、ocketclient=(Socket)ar.AsyncState;????intbytesSent=client.EndSend(ar);????//Console.WriteLine(bytesSent);???}???catch(Exceptione)????OnErrorEvent(newErrorEventArgs(e));???finally???{????sendDone.Set();???}??}??privatevoidReceiveCallback(lAsyncResultar)??{???Sockethandler=null;???try??

5、?{????lock(ar)9999(?????StateObjectstate=(StateObject)ar.AsyncState;?????handler=state.workSocket;??????????intbytesRead=handler.EndReceive(ar);99999?????讦(bytesRead>0)??????intReadPiont=0;???????while(ReadPiont??????{????????if(state.Cortrol==()&&ReadPiont???????{????????longbi1=stat

6、e.buffer[ReadPiont];????????bi1=(bil«24)&0xff000000;????????statc.packSizc=bi1;????????ReadPiont++;????????state.Cortrol=l;???????}?????????????if(state.Cortrol==l&&ReadPiont???????{????????longbi1=state.buffer[ReadPiont];????????bi1=(bil«16)&OxOOffOOOO;????????state.packSize=state.pa

7、ckSize+bil;????????ReadPiont++;????????state.Cortrol=2;???????}999999???????if(state.Cortrol==2&&ReadPiont???????{????????longbil=state.buffer[ReadPiont];????????bil=(bil«8)&OxOOOOffOO;????????state.packSize=state.packSize+bi1:????????ReadPiont++;????????state.Cortrol=3;???????}999999

8、9????