NetCoreServer：超低延迟的异步Socket服务器与客户端库

摘要：在现代软件开发中，高性能和低延迟的网络通信是许多应用的核心需求。NetCoreServer 是一个基于 .NET Core 的开源库，专注于实现超快且低延迟的异步 Socket 服务器与客户端功能。它支持多种传输协议（如 TCP、SSL、UDP、Unix Do

在现代软件开发中，高性能和低延迟的网络通信是许多应用的核心需求。NetCoreServer 是一个基于 .NET Core 的开源库，专注于实现超快且低延迟的异步 Socket 服务器与客户端功能。它支持多种传输协议（如 TCP、SSL、UDP、Unix Domain Socket）以及 Web 协议（如 HTTP、HTTPS、WebSocket），并提供了对 10K 连接问题的解决方案。

此外，NetCoreServer 还集成了基于 Fast Binary Encoding的高效消息协议，适合处理大规模并发连接和复杂的数据交互场景。

• 跨平台支持：适用于 Linux、MacOS 和 Windows。

• 异步通信：提供高效的异步通信能力。

• 丰富的协议支持：

• 传输协议：TCP、SSL、UDP、Unix Domain Socket。

• Web 协议：HTTP、HTTPS、WebSocket。

• 集成 Swagger OpenAPI 文档：支持生成交互式 API 文档。

• 高性能：经过优化，能够处理大量并发连接。

示例 1：TCP 聊天服务器using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using NetCoreServer;

namespaceTcpChatServer
{
classChatSession : TcpSession
{
public ChatSession(TcpServer server) : base(server) {}

protected override void OnConnected
{
Console.WriteLine($"Chat TCP session with Id {Id} connected!");
SendAsync("Hello from TCP chat! Please send a message or '!' to disconnect.");
}

protected override void OnDisconnected
{
Console.WriteLine($"Chat TCP session with Id {Id} disconnected!");
}

protected override void OnReceived(byte buffer,longoffset,longsize)
{
stringmessage = 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}");
}
}

classChatServer : TcpServer
{
public ChatServer(IPAddress address,intport) : base(address, port) {}

protected override TcpSession CreateSession => new ChatSession(this);

{
Console.WriteLine($"Chat TCP server caught an error with code {error}");
}
}

classProgram
{
static void Main(string args)
{
intport =1111;
if (args.Length >0)
port =int.Parse(args[0]);

var server = new ChatServer(IPAddress.Any, port);
server.Start;

Console.WriteLine("Press Enter to stop the server...");
Console.ReadLine;

server.Stop;
}
}
}示例 2：WebSocket 聊天服务器using System;
using System.Net;
using System.Text;
using NetCoreServer;

namespaceWsChatServer
{
classChatSession : WsSession
{
public ChatSession(WsServer server) : base(server) {}

public override void OnWsConnected(Httprequest request)
{
Console.WriteLine($"Chat WebSocket session with Id {Id} connected!");
SendTextAsync("Hello from WebSocket chat! Please send a message or '!' to disconnect.");
}

public override void OnWsDisconnected
{
Console.WriteLine($"Chat WebSocket session with Id {Id} disconnected!");
}

public override void OnWsReceived(byte buffer,longoffset,longsize)
{
stringmessage = Encoding.UTF8.GetString(buffer, (int)offset, (int)size);
Console.WriteLine("Incoming: " + message);

((WsServer)Server).MulticastText(message);

if (message == "!")
Close(1000);
}

protected override void OnError(SocketError error)
{
Console.WriteLine($"Chat WebSocket session caught an error with code {error}");
}
}

classChatServer : WsServer
{
public ChatServer(IPAddress address,intport) : base(address, port) {}

protected override TcpSession CreateSession => new ChatSession(this);

{
Console.WriteLine($"Chat WebSocket server caught an error with code {error}");
}
}

classProgram
{
static void Main(string args)
{
intport =8080;
if (args.Length >0)
port =int.Parse(args[0]);

var server = new ChatServer(IPAddress.Any, port);
server.Start;

Console.WriteLine("Press Enter to stop the server...");
Console.ReadLine;

server.Stop;
}
}
}

NetCoreServer 提供了详细的性能测试数据，涵盖多种协议和场景。以下是部分测试结果：

圆程延迟测试

协议

吞吐量 (msg/s)

延迟 (ms)

TCP Echo

1,000,000+

SSL Echo

500,000+

UDP Echo

1,500,000+

多播测试