c# tcp异步连接
服务端
public NetTcpServer(string ip,int port, SensorType type) {//启动监听 m_ServerConnecType = type; m_listen = new TcpListener(IPAddress.Parse(ip), port); m_listen.Start(); m_listen.BeginAcceptTcpClient(AcceptTcpClient, m_listen); //接收连接 }
private void AcceptTcpClient(IAsyncResult ar) {//建立连接 TcpClient recClient = m_listen.EndAcceptTcpClient(ar); try{ if(envSetWindowsData!=null) envSetWindowsData(DataType.NetConnected, ClassByteConvert.Class2Byte(recClient.Client.LocalEndPoint)); m_listen.BeginAcceptTcpClient(AcceptTcpClient, m_listen); Task.Run(new Action(() => {//接收线程 byte[] recData = new byte[1024];//不要用成员变量，异步不能只有一个缓冲区 recClient.Client.BeginReceive(recData, 0, recData.Length, SocketFlags.None, RecieveDataAsyn, recClient);//接收连接 }));//两个异步函数不能在一个线程中执行 Task.Run(new Action(() => {//发送线程 if (envSetWindowsData != null)
