.NET 高性能异步套接字库，支持多协议、跨平台、高并发

namespace TcpChatServer {     class ChatSession : TcpSession     {         public ChatSession(TcpServer server) : base(server) {}          protected override void OnConnected()         {             Console.WriteLine($"Chat TCP session with Id {Id} connected!");              // 发送欢迎消息             string message = "Hello from TCP chat! Please send a message or '!' to disconnect the client!";             SendAsync(message);         }          protected override void OnDisconnected()         {             Console.WriteLine($"Chat TCP session with Id {Id} disconnected!");         }          protected override void OnReceived(byte[] buffer, long offset, long size)         {             string message = Encoding.UTF8.GetString(buffer, (int)offset, (int)size);             Console.WriteLine("Incoming: " + message);              // 向所有已连接的会话广播消息             Server.Multicast(message);              // 如果接收到的消息为 '!'，则断开当前会话             if (message == "!")                 Disconnect();         }          protected override void OnError(SocketError error)         {             Console.WriteLine($"Chat TCP session caught an error with code {error}");         }     }      class ChatServer : TcpServer     {         public ChatServer(IPAddress address, int port) : base(address, port) {}          protected override TcpSession CreateSession() { return new ChatSession(this); }          protected override void OnError(SocketError error)         {             Console.WriteLine($"Chat TCP server caught an error with code {error}");         }     }      class Program     {         static void Main(string[] args)         {             // TCP 服务器端口             int port = 1111;             if (args.Length > 0)                 port = int.Parse(args[0]);              Console.WriteLine($"TCP 服务器端口: {port}");              Console.WriteLine();              // 创建一个新的 TCP 聊天服务器             var server = new ChatServer(IPAddress.Any, port);              // 启动服务器             Console.Write("服务器启动中...");             server.Start();             Console.WriteLine("完成!");              Console.WriteLine("按 Enter 停止服务器或输入 '!' 重启服务器...");              // 执行文本输入             for (;;)             {                 string line = Console.ReadLine();                 if (string.IsNullOrEmpty(line))                     break;                  // 重启服务器                 if (line == "!")                 {                     Console.Write("服务器重启中...");                     server.Restart();                     Console.WriteLine("完成!");                     continue;                 }                  // 向所有会话广播管理员消息                 line = "(admin) " + line;                 server.Multicast(line);             }              // 停止服务器             Console.Write("服务器停止中...");             server.Stop();             Console.WriteLine("完成!");         }     } }

namespace TcpChatClient {     class ChatClient : TcpClient     {         public ChatClient(string address, int port) : base(address, port) {}          public void DisconnectAndStop()         {             _stop = true;             DisconnectAsync();             while (IsConnected)                 Thread.Yield();         }          protected override void OnConnected()         {             Console.WriteLine($"Chat TCP client connected a new session with Id {Id}");         }          protected override void OnDisconnected()         {             Console.WriteLine($"Chat TCP client disconnected a session with Id {Id}");              //等待一段时间...             Thread.Sleep(1000);              // 尝试再次连接             if (!_stop)                 ConnectAsync();         }          protected override void OnReceived(byte[] buffer, long offset, long size)         {             Console.WriteLine(Encoding.UTF8.GetString(buffer, (int)offset, (int)size));         }          protected override void OnError(SocketError error)         {             Console.WriteLine($"Chat TCP client caught an error with code {error}");         }          private bool _stop;     }      class Program     {         static void Main(string[] args)         {             // TCP 服务器地址             string address = "127.0.0.1";             if (args.Length > 0)                 address = args[0];              // TCP 服务器端口             int port = 1111;             if (args.Length > 1)                 port = int.Parse(args[1]);              Console.WriteLine($"TCP server address: {address}");             Console.WriteLine($"TCP server port: {port}");              Console.WriteLine();              // 创建一个新的 TCP 聊天客户端             var client = new ChatClient(address, port);             // 连接客户端             Console.Write("Client connecting...");             client.ConnectAsync();             Console.WriteLine("Done!");              Console.WriteLine("Press Enter to stop the client or '!' to reconnect the client...");              // 执行文本输入             for (;;)             {                 string line = Console.ReadLine();                 if (string.IsNullOrEmpty(line))                     break;                  // 断开客户端连接                 if (line == "!")                 {                     Console.Write("Client disconnecting...");                     client.DisconnectAsync();                     Console.WriteLine("Done!");                     continue;                 }                  // 将输入的文本发送到聊天服务器                 client.SendAsync(line);             }              // 断开客户端连接             Console.Write("Client disconnecting...");             client.DisconnectAndStop();             Console.WriteLine("Done!");         }     } }