(1) 使用异步方式进行服务器监听
通过异步方式进行服务器监听,无需阻塞,只要调用BeginAccept方法后,就可以继续执行后面的代码了。BeginAccept方法中,需要指定一个委托,当有连接请求到来时,由它来处理,代码如下:
serverSock = new Socket (AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp);
serverSock.Bind (new IPEndPoint (IPAddress.Parse (_ip),_port));
serverSock.Listen(10);
serverSock.BeginAccept(new AsyncCallback(OnConnectRequest),serverSock);
异步的连接事件处理中,将为请求的连接建立一个新的连接:
private void OnConnectRequest(IAsyncResult ar){
Socket listener = (Socket)ar.AsyncState;
Socket link = listener.EndAccept(ar);//新的连接
……
(2) 异步的数据发送和接收
当建立连接后,需要为连接指定异步的接收方法和异步发送方法。由于发送过程往往是主动的,可以由用户控制,而接收过程则需要等待,所以异步接收更有实际意义。异步的接收方法是:
AsyncCallback recieveData = new AsyncCallback (OnRecievedData);
sock.BeginReceive (msgBuff, 0, msgBuff.Length, Socket-Flags.None, recieveData, sock);
而指定的异步接收委托方法是:
private void OnRecievedData(IAsyncResult ar){
Socket sock = (Socket)ar.AsyncState;
int nBytesRec = sock.EndReceive(ar);
string sRecieved = Encoding.ASCII.GetString(msgBuff, 0, nBytesRec);
对于发送,既可以用同步的发送方法Send,也可以用异步的方法BeginSend,其处理方法和接收相似。
(3) 连接过程
对客户端而言,可以用异步方法BeginConnect连接到服务器端。
_sock.BeginConnect(epServer, new AsyncCallback(OnConnect),_sock);
该方法设定的连接建立处理OnConnect中,可以从参数中获得建立的连接。
Socket sock = (Socket)ar.AsyncState;
sock.EndConnect(ar);
3. 基于WCF消息推送服务的设计 基于WCF的消息推送服务研究与实现(5):http://www.751com.cn/jisuanji/lunwen_5903.html