异步通信的tcp程序（IOS AsyncSocket异步TCP编程中，didReadData 不接收数据）

本文目录

• IOS AsyncSocket异步TCP编程中，didReadData 不接收数据
• C# TcpClient异步通信编程
• TCP应用编程的TCP应用编程各种操作方法简介
• C#TCP异步服务器和客户端咋连接
• TCP使用单独线程进行同步通讯与使用TCP异步通信有什么不同
• C# 网络编程 TCP 异步通信
• C#的异步TCP，如何把数据操作和通信部分分开
• C#的TCP异步通讯接受连接的线程的同步问题！WaitOne()方法
• C#socket异步怎么实现 线程间通信如何实现

IOS AsyncSocket异步TCP编程中，didReadData 不接收数据

如果我没猜错的话，问题出在你的C#服务端！看一下你代码中的这条语句;参数表示读取至"\r\n"查查你的C#服务端在返回数据时结尾有没有追加"\r\n"，没有的话加上，否则didReadData永远不会执行。另，使用开源三方库前，有文档的话好好看一下，没有的话就看一下头文件，大部分规范的开源代码在头文件中都会加入说明，这个问题头文件里说的很清楚/*** Reads bytes until (and including) the passed "data" parameter, which acts as a separator.** If the timeout value is negative, the read operation will not use a timeout.* * If you pass nil or zero-length data as the "data" parameter, * the method will do nothing, and the delegate will not be called. * * To read a line from the socket, use the line separator (e.g. CRLF for HTTP, see below) as the "data" parameter. * Note that this method is not character-set aware, so if a separator can occur naturally as part of the encoding for * a character, the read will prematurely end.**/- (void)readDataToData:(NSData *)data withTimeout:(NSTimeInterval)timeout tag:(long)tag;

C# TcpClient异步通信编程

Tcp协议是基于“流”的，它只负责所有字节的发送顺序和接收顺序相同、中间没有重复或遗漏。在Tcp协议之上编程，不能依赖于它每次发送的“数据包”这个概念，就是每次发送长度是不可以直接获取的。

TCP应用编程的TCP应用编程各种操作方法简介

BeginAcceptTcpClient和EndAcceptTcpClient方法包含在System .Net.Sockets命名空间下的TcpListener类中。在异步TCP应用编程中，服务端可以使用TcpListener类提供的BeginAcceptTcpClient方法开始接收新的客户端连接请求。在这个方法中，系统自动自用线程池创建需要的线程，并在操作完成时利用异步回调机制调用提供给它的方法，同时返回相应的状态参数。其方法原型为：public IAsyncResult BeginAcceptTcpClient(AsyncCallback callback,Object state)其中：参数1为AsyncCallback类型的委托；参数2为Object类型，用于将状态信息传递给委托提供的方法。例如：AsyncCallback callback=new AsyncCallback(AcceptTcpClientCallback);tcpListener.BeginAcceptTcpClient(callback,tcpListener);程序执行BeginAcceptTcpClient方法后，立即在线程池中创建需要的线程，同时在创建的线程中监听客户的连接需求。一旦接受了客户端的连接请求，就自动通过委托执行相应的方法，并返回状态信息。例子中我们将此方法命名为AcceptTcpClientCallback，状态信息为TcpListener类型的实例tcpListener。定义异步回调方法的格式：void AcceptTcpClientCallback(IAsyncResult ar){ 回调代码 }在回调方法中，必须调用EndAcceptTcpClient方法才能完成客户端连接，关键代码如下：void AcceptTcpClientCallback(IAsyncResult ar){......TcpListener myListener=(TcpListener)ar.AsyncState;TcpClient client=myListener.EndAcceptTcpClient(ar);......}程序执行EndAcceptTcpClient方法后，会自动完成客户端连接请求，并返回包含底层套接字的TcpClient对象，接下来我们就可以利用这个对象与客户端进行通信了。默认情况下，程序执行BeginAcceptTcpClient方法后，在返回状态信息前，不会像同步TCP方式那样阻塞线程等待用户连接，如果我们希望在返回状态信息前阻塞当前线程，就要调用ManualResetEvent对象的WaitOne方法。 BeginConnect 方法和EndConnect方法包含在命名空间System. Net.Sockets下的TcpClient类和Socket类中，这里我们只讨论TcpClient类中的方法。在异步TCP应用程序编程中，BeginConnect方法通过异步方式向远程主机发出连接请求，有三种重载形式，方法原型为：public IAsyncResult BeginConnect(IPAddress address,int port,AsyncCallback requestCallback,Object state);public IAsyncResult BeginConnect(IPAddress addresses,int port,AsyncCallback requestCallback,Object state);public IAsyncResult BeginConnect(string host,int port,AsyncCallback requestCallback,Object state);其中address为远程主机的IPAddress对象；port为远程主机端口号；requestCallback为AsyncCallback类型的委托；state为包含连接操作的相关信息，当操作完成时，此对象传递给requestCallback委托。在BeginConnect方法操作完成前，调用该方法的线程不会阻塞，系统会自动调用独立的线程来执行该方法，直到与远程主机连接成功或抛出异常。如果希望在调用BeginConnect方法之后阻塞线程，可以调用ManualResetEvent对象的WaitOnet方法。异步BeginConnect方法也只有在调用了EndConnect方法之后才算执行完毕，因此程序中需要在提供给requestCallback委托调用的方法中调用TcpClient对象的EndConnect方法。关键代码为：......AsyncCallback requestCallback=new AsyncCallback(RequestCallback);tcpClient.BeginConnect(远程主机IP或域名，远程主机端口号，requestCallback,tcpClient);......void RequestCallback(IAsyncResult ar){......tcpClient=(TcpClient)ar.AsyncState;client.EndConnect(ar);.......}

C#TCP异步服务器和客户端咋连接

TCP服务器端的客户端使用的方法不一样，服务器被叫，客户端主叫。服务器程序，设定一个端口用于客户端呼叫连接，声明一个socket绑定到这个端口，侦听客户端呼叫即可。客户端声明一个socket，通过客户端socket对服务器指定端口发出连接请求（主叫），服务器相应此连接请求，建立连接，然后就可以互相通讯了。服务器和客户端，就是在主叫与被叫上有区别，建立连接后，数据的收发都是一样的。

TCP使用单独线程进行同步通讯与使用TCP异步通信有什么不同

同步通讯需要等待返回，此时线程会阻塞。举个例子，如果你是在UI线程中发起这个同步通讯的，那么你的界面将不再响应（阻塞），直到有返回为止。而异步通信不等待返回，只要发出请求立即就会返回。而结果可能会在一段时间之后（几毫秒，几秒，几小时，……）返回。还是刚才的例子，如果你是从UI线程发起这个异步通讯的，那么你的界面将不受任何影响，能继续响应。那样将建立一个长连接。

C# 网络编程 TCP 异步通信

IAsyncResult是.net框架中定义的接口，用于返回异步操作的结果tcpclient相当于是放在IAsyncResult.AsyncState中的，通过这个属性传递iar是函数RequsetCallBack的参数啊，这是回调函数，回调函数是.net调用你的函数，普通函数是你调用.net的函数EndConnect的定义如此，微软的Begin...，End...都是采用统一的形式

C#的异步TCP，如何把数据操作和通信部分分开

之前做socket的时候是这样的，当服务器监听到一个客户端发来请求的时候，就开一条线程给这个客户端。这样只要是有新的客户端来访问，就会新开一条线程。无论有多少客户端，都是独立的线程。数据操作和通信的话可以用函数封装起来。

C#的TCP异步通讯接受连接的线程的同步问题！WaitOne()方法

楼主的isExit是个全局bool变量吗 这样的话一开始楼主一定已经赋给了false不然执行不下去 isExit==false是逻辑判断语句 结果是true 要不然不可能执行第一步骤的 你如果在循环体中没有再设置isExit取值为true 那么将会无限循环的 allDone.WaitOne();阻止当前线程，直到当前的 WaitHandle 收到信号。回楼主提问：1.首先说明下 我没说清楚 是由于你没写清楚 所以才会答非所问 你异步编程当中的那个回调函数应该用到了 listener.EndAcceptTcpClient(iar);在它的前面或它的后面你必须有的是allDone.Set();释放信号,这样当回调函数的这个线程结束后，allDone.WaitOne();由于得到了信号就继续循环执行，然后又由于allDone.Reset();将allDone.WaitOne()设置为等待状态 这样就形成了循环2.你这里的allDone应该是一个全局字段 这样状态就可以得到保证 因此你在回调函数中发出信号 在主线程中仍然可以得到，因为allDone是相同的一个字段********************************************你说的没错 是这样的*****************************

C#socket异步怎么实现 线程间通信如何实现

基于C#的socket编程的TCP异步实现一、摘要　　本篇博文阐述基于TCP通信协议的异步实现。二、实验平台　　Visual Studio 2010三、异步通信实现原理及常用方法3.1 建立连接　　　在同步模式中，在服务器上使用Accept方法接入连接请求，而在客户端则使用Connect方法来连接服务器。相对地，在异步模式下，服务器可以使用BeginAccept方法和EndAccept方法来完成连接到客户端的任务，在客户端则通过BeginConnect方法和EndConnect方法来实现与服务器的连接。　　BeginAccept在异步方式下传入的连接尝试，它允许其他动作而不必等待连接建立才继续执行后面程序。在调用BeginAccept之前，必须使用Listen方法来侦听是否有连接请求，BeginAccept的函数原型为：BeginAccept(AsyncCallback AsyncCallback, Ojbect state)参数：AsyncCallBack：代表回调函数state：表示状态信息，必须保证state中包含socket的句柄　　使用BeginAccept的基本流程是：(1)创建本地终节点，并新建套接字与本地终节点进行绑定；(2)在端口上侦听是否有新的连接请求；(3)请求开始接入新的连接，传入Socket的实例或者StateOjbect的实例。　　参考代码：复制代码//定义IP地址IPAddress local = IPAddress.Parse("127.0,0,1");IPEndPoint iep = new IPEndPoint(local,13000);//创建服务器的socket对象Socket server = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp);server.Bind(iep);server.Listen(20);server.BeginAccecpt(new AsyncCallback(Accept),server);复制代码　　当BeginAccept()方法调用结束后，一旦新的连接发生，将调用回调函数，而该回调函数必须包括用来结束接入连接操作的EndAccept()方法。该方法参数列表为 Socket EndAccept(IAsyncResult iar)下面为回调函数的实例：复制代码void Accept(IAsyncResult iar){ //还原传入的原始套接字 Socket MyServer = (Socket)iar.AsyncState; //在原始套接字上调用EndAccept方法，返回新的套接字 Socket service = MyServer.EndAccept(iar);}复制代码　　至此，服务器端已经准备好了。客户端应通过BeginConnect方法和EndConnect来远程连接主机。在调用BeginConnect方法时必须注册相应的回调函数并且至少传递一个Socket的实例给state参数，以保证EndConnect方法中能使用原始的套接字。下面是一段是BeginConnect的调用：Socket socket=new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp)IPAddress ip=IPAddress.Parse("127.0.0.1");IPEndPoint iep=new IPEndPoint(ip,13000);socket.BeginConnect(iep, new AsyncCallback(Connect),socket);　　EndConnect是一种阻塞方法，用于完成BeginConnect方法的异步连接诶远程主机的请求。在注册了回调函数后必须接收BeginConnect方法返回的IASynccReuslt作为参数。下面为代码演示：复制代码void Connect(IAsyncResult iar){ Socket client=(Socket)iar.AsyncState; try { client.EndConnect(iar); } catch (Exception e) { Console.WriteLine(e.ToString()); } finally { }}复制代码　　除了采用上述方法建立连接之后，也可以采用TcpListener类里面的方法进行连接建立。下面是服务器端对关于TcpListener类使用BeginAccetpTcpClient方法处理一个传入的连接尝试。以下是使用BeginAccetpTcpClient方法和EndAccetpTcpClient方法的代码：复制代码public static void DoBeginAccept(TcpListener listner){ //开始从客户端监听连接 Console.WriteLine("Waitting for a connection"); //接收连接 //开始准备接入新的连接，一旦有新连接尝试则调用回调函数DoAcceptTcpCliet listner.BeginAcceptTcpClient(new AsyncCallback(DoAcceptTcpCliet), listner);}//处理客户端的连接public static void DoAcceptTcpCliet(IAsyncResult iar){ //还原原始的TcpListner对象 TcpListener listener = (TcpListener)iar.AsyncState; //完成连接的动作，并返回新的TcpClient TcpClient client = listener.EndAcceptTcpClient(iar); Console.WriteLine("连接成功");}复制代码　　代码的处理逻辑为：(1)调用BeginAccetpTcpClient方法开开始连接新的连接，当连接视图发生时，回调函数被调用以完成连接操作；(2)上面DoAcceptTcpCliet方法通过AsyncState属性获得由BeginAcceptTcpClient传入的listner实例；(3)在得到listener对象后，用它调用EndAcceptTcpClient方法，该方法返回新的包含客户端信息的TcpClient。　　BeginConnect方法和EndConnect方法可用于客户端尝试建立与服务端的连接，这里和第一种方法并无区别。下面看实例：复制代码public void doBeginConnect(IAsyncResult iar){ Socket client=(Socket)iar.AsyncState; //开始与远程主机进行连接 client.BeginConnect(serverIP,13000,requestCallBack,client); Console.WriteLine("开始与服务器进行连接");}private void requestCallBack(IAsyncResult iar){ try { //还原原始的TcpClient对象 TcpClient client=(TcpClient)iar.AsyncState; // client.EndConnect(iar); Console.WriteLine("与服务器{0}连接成功",client.Client.RemoteEndPoint); } catch(Exception e) { Console.WriteLine(e.ToString()); } finally { }}复制代码　　以上是建立连接的两种方法。可根据需要选择使用。3.2 发送与接受数据　　在建立了套接字的连接后，就可以服务器端和客户端之间进行数据通信了。异步套接字用BeginSend和EndSend方法来负责数据的发送。注意在调用BeginSend方法前要确保双方都已经建立连接，否则会出异常。下面演示代码：复制代码private static void Send(Socket handler, String data){ // Convert the string data to byte data using ASCII encoding. byte byteData = Encoding.ASCII.GetBytes(data); // Begin sending the data to the remote device. handler.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallback), handler);}private static void SendCallback(IAsyncResult ar){ try { // Retrieve the socket from the state object. Socket handler = (Socket)ar.AsyncState; // Complete sending the data to the remote device. int bytesSent = handler.EndSend(ar); Console.WriteLine("Sent {0} bytes to client.", bytesSent); handler.Shutdown(SocketShutdown.Both); handler.Close(); } catch (Exception e) { Console.WriteLine(e.ToString()); }}复制代码　　接收数据是通过BeginReceive和EndReceive方法：复制代码private static void Receive(Socket client){ try { // Create the state object. StateObject state = new StateObject(); state.workSocket = client; // Begin receiving the data from the remote device. client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state); } catch (Exception e) { Console.WriteLine(e.ToString()); }}private static void ReceiveCallback(IAsyncResult ar){ try { // Retrieve the state object and the client socket // from the asynchronous state object. StateObject state = (StateObject)ar.AsyncState; Socket client = state.workSocket; // Read data from the remote device. int bytesRead = client.EndReceive(ar); if (bytesRead 》 0) { // There might be more data, so store the data received so far. state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead)); // Get the rest of the data. client.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReceiveCallback), state); } else { // All the data has arrived; put it in response. if (state.sb.Length 》 1) { response = state.sb.ToString(); } // Signal that all bytes have been received. receiveDone.Set(); } } catch (Exception e) { Console.WriteLine(e.ToString()); }}复制代码　　上述代码的处理逻辑为：(1)首先处理连接的回调函数里得到的通讯套接字client，接着开始接收数据；(2)当数据发送到缓冲区中，BeginReceive方法试图从buffer数组中读取长度为buffer.length的数据块，并返回接收到的数据量bytesRead。最后接收并打印数据。　　　　除了上述方法外，还可以使用基于NetworkStream相关的异步发送和接收方法，下面是基于NetworkStream相关的异步发送和接收方法的使用介绍。　　NetworkStream使用BeginRead和EndRead方法进行读操作，使用BeginWreite和EndWrete方法进行写操作，下面看实例：复制代码static void DataHandle(TcpClient client){ TcpClient tcpClient = client; //使用TcpClient的GetStream方法获取网络流 NetworkStream ns = tcpClient.GetStream(); //检查网络流是否可读 if(ns.CanRead) { //定义缓冲区 byte; ns.BeginRead(read,0,read.Length,new AsyncCallback(myReadCallBack),ns); } else { Console.WriteLine("无法从网络中读取流数据"); }}public static void myReadCallBack(IAsyncResult iar){ NetworkStream ns = (NetworkStream)iar.AsyncState; byte; String data = ""; int recv; recv = ns.EndRead(iar); data = String.Concat(data, Encoding.ASCII.GetString(read, 0, recv)); //接收到的消息长度可能大于缓冲区总大小，反复循环直到读完为止 while (ns.DataAvailable) { ns.BeginRead(read, 0, read.Length, new AsyncCallback(myReadCallBack), ns); } //打印 Console.WriteLine("您收到的信息是" + data);}复制代码3.3 程序阻塞与异步中的同步问题　　.Net里提供了EventWaitHandle类来表示一个线程的同步事件。EventWaitHandle即事件等待句柄，他允许线程通过操作系统互发信号和等待彼此的信号来达到线程同步的目的。这个类有2个子类，分别为AutoRestEevnt(自动重置)和ManualRestEvent(手动重置)。下面是线程同步的几个方法：(1)Rset方法：将事件状态设为非终止状态，导致线程阻塞。这里的线程阻塞是指允许其他需要等待的线程进行阻塞即让含WaitOne()方法的线程阻塞；(2)Set方法：将事件状态设为终止状态，允许一个或多个等待线程继续。该方法发送一个信号给操作系统，让处于等待的某个线程从阻塞状态转换为继续运行，即WaitOne方法的线程不在阻塞；(3)WaitOne方法：阻塞当前线程，直到当前的等待句柄收到信号。此方法将一直使本线程处于阻塞状态直到收到信号为止，即当其他非阻塞进程调用set方法时可以继续执行。复制代码public static void StartListening(){ // Data buffer for incoming data. byte; // Establish the local endpoint for the socket. // The DNS name of the computer // running the listener is "host.contoso.com". //IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName()); //IPAddress ipAddress = ipHostInfo.AddressList; IPAddress ipAddress = IPAddress.Parse("127.0.0.1"); IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000); // Create a TCP/IP socket. Socket listener = new Socket(AddressFamily.InterNetwork,SocketType.Stream, ProtocolType.Tcp); // Bind the socket to the local //endpoint and listen for incoming connections. try { listener.Bind(localEndPoint); listener.Listen(100); while (true) { // Set the event to nonsignaled state. allDone.Reset(); // Start an asynchronous socket to listen for connections. Console.WriteLine("Waiting for a connection..."); listener.BeginAccept(new AsyncCallback(AcceptCallback),listener); // Wait until a connection is made before continuing. allDone.WaitOne(); } } catch (Exception e) { Console.WriteLine(e.ToString()); } Console.WriteLine("\nPress ENTER to continue..."); Console.Read();}复制代码　　上述代码的逻辑为：(1)试用了ManualRestEvent对象创建一个等待句柄，在调用BeginAccept方法前使用Rest方法允许其他线程阻塞；(2)为了防止在连接完成之前对套接字进行读写操作，务必要在BeginAccept方法后调用WaitOne来让线程进入阻塞状态。　　当有连接接入后系统会自动调用会调用回调函数，所以当代码执行到回调函数时说明连接已经成功，并在函数的第一句就调用Set方法让处于等待的线程可以继续执行。