阅读量:0
在C#中，使用Socket进行异步通信可以提高程序的性能和响应能力
- 引入必要的命名空间：
using System; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; - 创建一个类，用于处理异步通信：
public class AsyncSocketServer { private Socket _serverSocket; private const int BufferSize = 1024; public void StartListening(int port) { // 创建一个TCP/IP套接字 _serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); // 绑定到本地端口 IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, port); _serverSocket.Bind(localEndPoint); // 开始监听客户端连接 _serverSocket.Listen(100); Console.WriteLine($"服务器正在监听端口 {port}..."); // 等待客户端连接 _serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), _serverSocket); } private void AcceptCallback(IAsyncResult ar) { // 获取服务器套接字 Socket serverSocket = (Socket)ar.AsyncState; // 接受客户端连接 Socket clientSocket = serverSocket.EndAccept(ar); // 打印客户端信息 Console.WriteLine($"客户端 {clientSocket.RemoteEndPoint} 已连接"); // 准备接收数据的缓冲区 byte[] buffer = new byte[BufferSize]; // 开始异步接收数据 clientSocket.BeginReceive(buffer, 0, BufferSize, SocketFlags.None, new AsyncCallback(ReceiveCallback), clientSocket); // 继续等待其他客户端连接 serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), serverSocket); } private void ReceiveCallback(IAsyncResult ar) { // 获取客户端套接字 Socket clientSocket = (Socket)ar.AsyncState; try { // 结束异步接收操作 int bytesRead = clientSocket.EndReceive(ar); if (bytesRead > 0) { // 解码接收到的数据 string receivedData = Encoding.ASCII.GetString(buffer, 0, bytesRead); // 打印接收到的数据 Console.WriteLine($"从客户端 {clientSocket.RemoteEndPoint} 接收到数据: {receivedData}"); // 准备发送的数据 byte[] sendBuffer = Encoding.ASCII.GetBytes("你好，我是服务器！"); // 开始异步发送数据 clientSocket.BeginSend(sendBuffer, 0, sendBuffer.Length, SocketFlags.None, new AsyncCallback(SendCallback), clientSocket); } } catch (Exception ex) { Console.WriteLine($"接收数据时出错: {ex.Message}"); clientSocket.Close(); } } private void SendCallback(IAsyncResult ar) { // 获取客户端套接字 Socket clientSocket = (Socket)ar.AsyncState; try { // 结束异步发送操作 int bytesSent = clientSocket.EndSend(ar); // 打印发送的数据长度 Console.WriteLine($"向客户端 {clientSocket.RemoteEndPoint} 发送了 {bytesSent} 字节的数据"); // 准备接收下一批数据的缓冲区 byte[] buffer = new byte[BufferSize]; // 开始异步接收数据 clientSocket.BeginReceive(buffer, 0, BufferSize, SocketFlags.None, new AsyncCallback(ReceiveCallback), clientSocket); } catch (Exception ex) { Console.WriteLine($"发送数据时出错: {ex.Message}"); clientSocket.Close(); } } } - 在主程序中使用
AsyncSocketServer类：
class Program { static void Main(string[] args) { AsyncSocketServer server = new AsyncSocketServer(); server.StartListening(8080); Console.WriteLine("按任意键退出..."); Console.ReadKey(); } } 这个示例展示了如何使用C# Socket进行异步通信。当客户端连接到服务器时，服务器会异步接收客户端发送的数据，并将数据原样发送回客户端。你可以根据需要修改此示例以实现更复杂的通信功能。
