.NET 高性能异步套接字库，支持多协议、跨平台、高并发 - IT评测·应用市场-qidao123.com

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!");
}
}
}

复制代码