👁 Image
SAEA.Http 26.4.23.1

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

👁 NuGet version
👁 License

| 中文版

基于 .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