C# TCP网络编程2
C# TCP网络编程 (二)实现异步(一)接收数据
实现多个客户端连接,实现一个客户端循环接收数据…
class Program
{
static void Main(string[] args)
{
///服务端代码
Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPAddress ip = IPAddress.Parse("192.168.1.102");
IPEndPoint ipEndPoint = new IPEndPoint(ip, 3344);
serverSocket.Bind(ipEndPoint);
serverSocket.Listen(0);//开启监听
Console.WriteLine("服务器启动");
//开始异步接收客户端
serverSocket.BeginAccept(AcceptAsyncCallBack, serverSocket);
Console.ReadKey();
}
/// <summary>
/// 异步等待客户端回调方法
/// </summary>
/// <param name="ar"></param>
private static void AcceptAsyncCallBack(IAsyncResult ar)
{
Socket serverSocket=ar.AsyncState as Socket;//传递过来的参数
Socket clientSokcet = serverSocket.EndAccept(ar); //一个客户端连接过来了
string msg =":Hello client! 你好......";
byte[] dataBytes = Encoding.UTF8.GetBytes(msg); //网络连接收发数据,只能发送byte[] 字节数组
clientSokcet.Send(dataBytes);
clientSokcet.BeginReceive(dataBuffer, 0, 1024, SocketFlags.None, ReceiveCallBack, clientSokcet); //开始异步接收数据
serverSocket.BeginAccept(AcceptAsyncCallBack, serverSocket);//循环等待客户端接收....
}
static byte[] dataBuffer = new byte[1024]; // 接收数据缓存区
/// <summary>
/// 异步接收数据回调方法
/// </summary>
/// <param name="ar"></param>
private static void ReceiveCallBack(IAsyncResult ar)
{
Socket clientSocket = ar.AsyncState as Socket;
int count = clientSocket.EndReceive(ar); //接收到的数据量
string msg = Encoding.UTF8.GetString(dataBuffer, 0, count);
Console.WriteLine(clientSocket.LocalEndPoint + ":接收到客户端的数据:" + msg);
clientSocket.BeginReceive(dataBuffer, 0, 1024, SocketFlags.None, ReceiveCallBack, clientSocket);
}
}
static void Main(string[] args)
{
///客户端代码
Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint ipEndPoint = new IPEndPoint(IPAddress.Parse("192.168.1.102"), 3344);
clientSocket.Connect(ipEndPoint);
byte[] receiveBuffer = new byte[1024];
int count = clientSocket.Receive(receiveBuffer);
string msg = Encoding.UTF8.GetString(receiveBuffer, 0, count);
Console.WriteLine("接收到服务端的消息:" + msg);
byte[] sendBytes = Encoding.UTF8.GetBytes("我是客户端");
clientSocket.Send(sendBytes);
//for (int i = 0; i < 250; i++)
//{
// sendBytes = Encoding.UTF8.GetBytes(i.ToString());
// clientSocket.Send(sendBytes);
//}
while (true)
{
string s = Console.ReadLine();
sendBytes = Encoding.UTF8.GetBytes(s);
clientSocket.Send(sendBytes);
}
Console.ReadKey();
}
}