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

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

特性

• o 跨平台支持：适用于 Linux、MacOS 和 Windows。
• o 异步通信：提供高效的异步通信能力。
• o 丰富的协议支持：
• o 传输协议：TCP、SSL、UDP、Unix Domain Socket。
• o Web 协议：HTTP、HTTPS、WebSocket。
• o 集成 Swagger OpenAPI 文档：支持生成交互式 API 文档。
• o 高性能：经过优化，能够处理大量并发连接。

示例

示例 1：TCP 聊天服务器

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using NetCoreServer;

namespace TcpChatServer
{
    class ChatSession : TcpSession
    {
        public ChatSession(TcpServer server) : base(server) {}

        protected override void OnConnected()
        {
            Console.WriteLine(#34;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(#34;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(#34;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() => new ChatSession(this);

        protected override void OnError(SocketError error)
        {
            Console.WriteLine(#34;Chat TCP server caught an error with code {error}");
        }
    }

    class Program
    {
        static void Main(string[] args)
        {
            int port = 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;

namespace WsChatServer
{
    class ChatSession : WsSession
    {
        public ChatSession(WsServer server) : base(server) {}

        public override void OnWsConnected(HttpRequest request)
        {
            Console.WriteLine(#34;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(#34;Chat WebSocket session with Id {Id} disconnected!");
        }

        public override void OnWsReceived(byte[] buffer, long offset, long size)
        {
            string message = 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(#34;Chat WebSocket session caught an error with code {error}");
        }
    }

    class ChatServer : WsServer
    {
        public ChatServer(IPAddress address, int port) : base(address, port) {}

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

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

    class Program
    {
        static void Main(string[] args)
        {
            int port = 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 Echo1,000,000+< 0.1SSL Echo500,000+< 0.2UDP Echo1,500,000+< 0.05

多播测试

协议吞吐量 (msg/s)延迟 (ms)TCP Multicast800,000+< 0.1SSL Multicast400,000+< 0.2UDP Multicast2,000,000+< 0.05

总结

NetCoreServer 是一个功能强大且灵活的网络通信库，适用于需要高性能和低延迟的应用场景。无论是简单的聊天应用，还是复杂的分布式系统，NetCoreServer 都能为您提供可靠的解决方案。