C#通讯编程(吐血整理)

《C#通讯编程(吐血整理)》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、C#通讯编程（整理）Socket通讯:publicclassXmlSocket{//异步socket诊听//Incomingdatafromclient.从客户端传来的数据publicstaticstringdata=null;//Threadsignal.线程用一个指示是否将初始状态设置为终止的布尔值初始化ManualResetEvent类的新实例。publicstaticManualResetEventallDone=newManualResetEvent(false);//staticvoid

2、Main(string[]args)//{//StartListening();//}publicstaticvoidStartListening(){//Databufferforincomingdata.传入数据缓冲byte[]bytes=newByte[1024];//Establishthelocalendpointforthesocket.建立本地端口//TheDNSnameofthecomputer//runningthelisteneris"host.contoso.com".IPAd

3、dressipAddress;StringipString=ConfigurationManager.AppSettings.Get("SocketIP");if(ipString==null

4、

5、ipString==String.Empty){IPHostEntryipHostInfo=Dns.GetHostEntry(Dns.GetHostName());ipAddress=ipHostInfo.AddressList[0];}else{ipAddress=IPAddress.Parse(ipSt

6、ring);}intport;StringportString=ConfigurationManager.AppSettings.Get("SocketPort");if(portString==null

7、

8、portString==String.Empty){40/40port=11001;}else{port=int.Parse(portString);}IPEndPointlocalEndPoint=newIPEndPoint(ipAddress,port);//CreateaTCP/IPsoc

9、ket.Socketlistener=newSocket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);//Bindthesockettothelocalendpointandlistenforincomingconnections.绑定端口和数据try{listener.Bind(localEndPoint);listener.Listen(100);while(true){//Settheeventtononsign

10、aledstate.设置无信号状态的事件allDone.Reset();//Startanasynchronoussockettolistenforconnections.重新启动异步连接listener.BeginAccept(newAsyncCallback(AcceptCallback),listener);//Waituntilaconnectionismadebeforecontinuing.等待连接创建后继续allDone.WaitOne();}}catch(Exceptione){//

11、}}publicstaticvoidAcceptCallback(IAsyncResultar){try{//Signalthemainthreadtocontinue.接受回调方法该方法的此节向主应用程序线程发出信号，//让它继续处理并建立与客户端的连接allDone.Set();//Getthesocketthathandlestheclientrequest.获取客户端请求句柄Socketlistener=(Socket)ar.AsyncState;Sockethandler=listener

12、.EndAccept(ar);40/40//Createthestateobject.StateObjectstate=newStateObject();state.workSocket=handler;handler.BeginReceive(state.buffer,0,StateObject.BufferSize,0,newAsyncCallback(ReadCallback),state);}catch(Exceptione){//}}///