SAEA.Http 26.4.23.1

SAEA.Http - 轻量级高性能 HTTP 服务器 🌐

English Version | 中文版

基于 .NET Standard 2.0 的高性能 HTTP 服务器，采用 IOCP 完成端口技术，支持 RESTful API、静态文件服务、文件上传等功能。

快速导航 🧭

30秒快速开始 ⚡

最快上手方式，只需3步即可运行 HTTP 服务器：

Step 1: 安装 NuGet 包

dotnet add package SAEA.Http

Step 2: 创建 HTTP 服务器（仅需5行代码）

using SAEA.Http;

var server = new WebHost(new WebConfig { Port = 28080 });
server.OnRequestDelegate += (ctx) => {
    ctx.Response.SetContent("{\"msg\": \"Hello SAEA.Http!\"}", "application/json");
    return true;
};
server.Start();

Step 3: 测试访问

curl http://localhost:28080/api/test
# 输出: {"msg": "Hello SAEA.Http!"}

就这么简单！ 🎉 你已经实现了一个支持万级并发的高性能 HTTP 服务器。

核心特性 🎯

架构设计 📐

组件架构图

┌─────────────────────────────────────────────────────────────┐
│                     SAEA.Http 架构                           │
├─────────────────────────────────────────────────────────────┤
│                                                             │
│  ┌──────────────────────────────────────────────────────┐  │
│  │                    WebHost                           │  │
│  │                 (HTTP 服务器入口)                     │  │
│  └──────────────────────────────────────────────────────┘  │
│                            │                                │
│         ┌──────────────────┼──────────────────┐           │
│         │                  │                  │            │
│  ┌──────▼──────┐   ┌───────▼───────┐   ┌─────▼─────┐     │
│  │ HttpContext │   │  HttpSession  │   │ WebConfig │     │
│  │  (上下文)   │   │  (会话管理)   │   │  (配置)   │     │
│  └──────┬──────┘   └───────────────┘   └───────────┘     │
│         │                                                   │
│  ┌──────┴──────┐                                           │
│  │             │                                           │
│  ▼             ▼                                           │
│ ┌─────────┐ ┌──────────┐                                   │
│ │Request  │ │Response  │                                   │
│ │(请求)   │ │(响应)    │                                   │
│ └────┬────┘ └────┬─────┘                                   │
│      │           │                                          │
│      └─────┬─────┘                                          │
│            │                                                │
│  ┌─────────▼─────────┐                                     │
│  │     HttpSocket    │                                     │
│  │   (底层通信层)    │                                     │
│  └─────────┬─────────┘                                     │
│            │                                                │
│  ┌─────────▼─────────┐                                     │
│  │   SAEA.Sockets    │                                     │
│  │   (IOCP 引擎)     │                                     │
│  └───────────────────┘                                     │
│                                                             │
└─────────────────────────────────────────────────────────────┘

请求处理流程图

HTTP 请求处理流程:

客户端 ──► HTTP Request ──► WebHost 接收
                                    │
                                    ▼
                          ┌─────────────────┐
                          │ RequestDataReader│
                          │   解析 HTTP 请求 │
                          └─────────────────┘
                                    │
                                    ▼
                          ┌─────────────────┐
                          │   HttpContext   │
                          │  创建请求上下文  │
                          └─────────────────┘
                                    │
                    ┌───────────────┼───────────────┐
                    │               │               │
                    ▼               ▼               ▼
            ┌───────────┐   ┌───────────┐   ┌───────────┐
            │静态文件?  │   │API请求?   │   │上传文件?  │
            └─────┬─────┘   └─────┬─────┘   └─────┬─────┘
                  │               │               │
                  ▼               ▼               ▼
            ┌───────────┐   ┌───────────┐   ┌───────────┐
            │StaticCache│   │OnRequest  │   │Multipart  │
            │缓存/传输  │   │Delegate   │   │ 解析器    │
            └─────┬─────┘   └─────┬─────┘   └─────┬─────┘
                  │               │               │
                  └───────────────┼───────────────┘
                                  │
                                  ▼
                        ┌─────────────────┐
                        │  HttpResponse   │
                        │   构建响应数据   │
                        └─────────────────┘
                                  │
                                  ▼
                        ┌─────────────────┐
                        │ GZIP 压缩?      │
                        │ (可选)          │
                        └─────────────────┘
                                  │
                                  ▼
                          HttpSocket 发送
                                  │
                                  ▼
                            客户端响应

应用场景 💡

✅ 适合使用 SAEA.Http 的场景

❌ 不适合的场景

性能对比 📊

与其他 HTTP 服务器对比

特性对比

💡 提示: SAEA.Http 适合需要轻量级、高性能 HTTP 服务的场景，特别适合嵌入式、游戏后端、IoT 等对资源敏感的应用。

常见问题 ❓

Q1: SAEA.Http 与 ASP.NET Core 有什么区别？

A: SAEA.Http 是一个轻量级的 HTTP 服务器组件：

• 更小的内存占用和更快的启动时间
• 内置静态文件缓存、Session、文件上传解析
• 适合嵌入式、游戏后端、微服务等轻量级场景
• ASP.NET Core 更适合复杂的企业级 Web 应用

Q2: 如何处理跨域 CORS 请求？

A: SAEA.Http 内置 CORS 支持，在 OnRequestDelegate 中处理：

server.OnRequestDelegate += (ctx) =>
{
    ctx.Response.Headers["Access-Control-Allow-Origin"] = "*";
    ctx.Response.Headers["Access-Control-Allow-Methods"] = "GET,POST,PUT,DELETE";
    ctx.Response.Headers["Access-Control-Allow-Headers"] = "Content-Type";
    
    if (ctx.Request.Method == "OPTIONS")
    {
        ctx.Response.SetContent("", "text/plain");
        return true;
    }
    // ... 其他处理
    return false;
};

Q3: 如何实现大文件上传？

A: 使用流式处理避免内存溢出：

server.OnRequestDelegate += (ctx) =>
{
    var files = ctx.Request.PostFiles;
    foreach (var file in files)
    {
        var savePath = Path.Combine("uploads", file.FileName);
        File.WriteAllBytes(savePath, file.Data);
    }
    ctx.Response.SetContent("{\"uploaded\": true}", "application/json");
    return true;
};

Q4: 如何开启 GZIP 压缩？

A: 在 WebConfig 中配置：

var config = new WebConfig
{
    Port = 28080,
    IsZiped = true  // 启用 GZIP 压缩
};
var server = new WebHost(config);

Q5: 如何配置 Session 超时时间？

A: 使用 HttpSessionManager 自定义配置：

// Session 默认超时 20 分钟
// 可通过 HttpSessionManager 调整
var session = ctx.Session;  // 自动获取或创建 Session
session["key"] = "value";   // 设置值

Q6: 如何实现 SSE（服务器推送）？

A: 使用 text/event-stream 内容类型：

server.OnRequestDelegate += (ctx) =>
{
    ctx.Response.ContentType = "text/event-stream";
    ctx.Response.SendHeader();
    
    for (int i = 0; i < 10; i++)
    {
        ctx.Response.SendData($"data: Message {i}\n\n");
        Thread.Sleep(1000);
    }
    ctx.Response.SendEnd();
    return true;
};

Q7: 静态文件缓存如何工作？

A: SAEA.Http 自动处理静态文件缓存：

• 小文件（默认 < 1MB）自动缓存到内存
• 支持 Cache-Control、Last-Modified 头
• 支持 If-Modified-Since 条件请求
• 通过 WebConfig.IsStaticsCached 控制开关

核心类 🔧

HTTP 结果类型

使用示例 📝

启动 HTTP 服务器

using SAEA.Http;

var config = new WebConfig
{
    Root = "wwwroot",
    Port = 28080,
    BufferSize = 1024 * 64,
    MaxConnects = 1000,
    IsStaticsCached = true,
    IsZiped = true
};

var server = new WebHost(config);

server.OnRequestDelegate += (ctx) =>
{
    if (ctx.Request.Url.StartsWith("/api/"))
    {
        var json = $"{{\"time\": \"{DateTime.Now}\"}}";
        ctx.Response.SetContent(json, "application/json");
        return true;
    }
    return false;
};

server.OnException += (ctx, ex) =>
{
    Console.WriteLine($"错误: {ex.Message}");
};

server.Start();
Console.WriteLine($"HTTP 服务器已启动，端口: {config.Port}");

处理 GET 请求

server.OnRequestDelegate += (ctx) =>
{
    var request = ctx.Request;
    
    Console.WriteLine($"GET {request.Url}");
    Console.WriteLine($"Query: {request.Query["id"]}");
    Console.WriteLine($"Headers: {request.Headers["User-Agent"]}");
    
    ctx.Response.SetContent("{\"status\": \"ok\"}", "application/json");
    return true;
};

处理 POST 请求

server.OnRequestDelegate += (ctx) =>
{
    var request = ctx.Request;
    
    if (request.Method == "POST")
    {
        var username = request.Forms["username"];
        var password = request.Forms["password"];
        var jsonBody = request.Json;
        var files = request.PostFiles;
        
        foreach (var file in files)
        {
            Console.WriteLine($"文件: {file.FileName}, 大小: {file.Data.Length}");
        }
        
        ctx.Response.SetContent("{\"success\": true}", "application/json");
        return true;
    }
    return false;
};

使用 Session

server.OnRequestDelegate += (ctx) =>
{
    var session = ctx.Session;
    
    var userId = session["UserId"];
    session["UserId"] = "12345";
    session["LoginTime"] = DateTime.Now.ToString();
    
    ctx.Response.SetContent($"Session ID: {session.SessionID}");
    return true;
};

使用 Cookie

server.OnRequestDelegate += (ctx) =>
{
    var request = ctx.Request;
    var response = ctx.Response;
    
    var token = request.Cookies["token"];
    
    response.Cookies.Add(new HttpCookie
    {
        Name = "token",
        Value = "abc123",
        Expires = DateTime.Now.AddDays(7)
    });
    
    ctx.Response.SetContent("Cookie 已设置");
    return true;
};

返回文件

server.OnRequestDelegate += (ctx) =>
{
    var filePath = ctx.Server.MapPath("/files/document.pdf");
    ctx.Response.SetCached(filePath);
    return true;
};

server.OnRequestDelegate += (ctx) =>
{
    var filePath = ctx.Server.MapPath("/videos/movie.mp4");
    
    ctx.Response.ContentType = "video/mp4";
    ctx.Response.SendHeader();
    
    using (var fs = new FileStream(filePath, FileMode.Open))
    {
        var buffer = new byte[1024 * 64];
        int read;
        while ((read = fs.Read(buffer, 0, buffer.Length)) > 0)
        {
            ctx.Response.SendData(buffer, 0, read);
        }
    }
    
    ctx.Response.SendEnd();
    return true;
};

SSE 服务器推送

server.OnRequestDelegate += (ctx) =>
{
    ctx.Response.ContentType = "text/event-stream";
    ctx.Response.SendHeader();
    
    for (int i = 0; i < 10; i++)
    {
        ctx.Response.SendData($"data: Message {i}\n\n");
        Thread.Sleep(1000);
    }
    
    ctx.Response.SendEnd();
    return true;
};

配置项

var config = new WebConfig
{
    Root = "wwwroot",           // 网站根目录
    Port = 28080,               // 监听端口
    BufferSize = 1024 * 64,     // 缓冲区大小（64KB）
    MaxConnects = 1000,         // 最大连接数
    IsStaticsCached = true,     // 静态文件缓存
    IsZiped = false,            // GZIP 压缩
    ConnectTimeout = 6000       // 连接超时（毫秒）
};

依赖项

更多资源

• GitHub 仓库
• NuGet 包
• 作者博客

许可证

Apache License 2.0