Merge pull request #61 from Tuntii/performance-fix

Optimize bench server for performance benchmarking

Author: Tuntii

Cargo.lock

@@ -14,8 +14,9 @@ members = [
     "crates/rustapi-jobs",
     "crates/cargo-rustapi",
 
-
-
+    # Benchmark servers
+    "benches/bench_server",
+    "benches/actix_bench_server",
     "benches/toon_bench",
     "benches/rustapi_bench",
 ]
@@ -100,6 +101,7 @@ indicatif = "0.17"
 console = "0.15"
 
 # Internal crates
+rustapi-rs = { path = "crates/rustapi-rs", version = "0.1.188", default-features = false }
 rustapi-core = { path = "crates/rustapi-core", version = "0.1.188", default-features = false }
 rustapi-macros = { path = "crates/rustapi-macros", version = "0.1.188" }
 rustapi-validate = { path = "crates/rustapi-validate", version = "0.1.188" }
@@ -119,6 +121,29 @@ rustls = { version = "0.23", default-features = false, features = ["ring", "std"
 rustls-pemfile = "2.2"
 rcgen = "0.13"
 
+# ============================================
+# Release Profile - Maximum Performance
+# ============================================
+[profile.release]
+opt-level = 3
+lto = "fat"
+codegen-units = 1
+panic = "abort"
+strip = true
+debug = false
+
+# Benchmark Profile - Even more aggressive
+[profile.bench]
+inherits = "release"
+lto = "fat"
+codegen-units = 1
+
+# Release with debug symbols for profiling
+[profile.release-with-debug]
+inherits = "release"
+debug = true
+strip = false
+
 
 
 

Cargo.toml

@@ -39,7 +39,7 @@ We optimize for **Developer Joy** without sacrificing **Req/Sec**.
 
 | Feature | **RustAPI** | Actix-web | Axum | FastAPI (Python) |
 |:-------|:-----------:|:---------:|:----:|:----------------:|
-| **Performance** | **~220k req/s** 🚀 | ~178k | ~165k | ~12k |
+| **Performance** | **~92k req/s** | ~105k | ~100k | ~12k |
 | **DX (Simplicity)** | 🟢 **High** | 🔴 Low | 🟡 Medium | 🟢 High |
 | **Boilerplate** | **Zero** | High | Medium | Zero |
 | **AI/LLM Native** | ✅ **Yes** | ❌ No | ❌ No | ❌ No |

README.md

@@ -106,7 +106,7 @@ async fn list_users() -> impl Responder {
             is_active: id % 2 == 0,
         })
         .collect();
-    
+
     HttpResponse::Ok().json(UsersListResponse {
         total: 100,
         page: 1,

benches/actix_bench_server/src/main.rs

@@ -9,7 +9,11 @@ name = "bench-server"
 path = "src/main.rs"
 
 [dependencies]
-rustapi-rs.workspace = true
+# RustAPI with minimum features for benchmarking:
+# - No swagger-ui overhead
+# - No tracing overhead
+# - simd-json for faster JSON parsing
+rustapi-rs = { workspace = true, default-features = false, features = ["simd-json"] }
 tokio.workspace = true
 serde.workspace = true
 serde_json.workspace = true

benches/bench_server/Cargo.toml

@@ -1,27 +1,24 @@
 //! RustAPI Benchmark Server
 //!
 //! A minimal server for HTTP load testing (hey, wrk, etc.)
+//! Optimized for maximum performance benchmarks.
 //!
 //! Run with: cargo run --release -p bench-server
 //! Then test with: hey -n 100000 -c 50 http://127.0.0.1:8080/
 
 use rustapi_rs::prelude::*;
 
-// ============================================
-// Response types
-// ============================================
-
 #[derive(Serialize, Schema)]
 struct HelloResponse {
-    message: String,
+    message: &'static str,
 }
 
 #[derive(Serialize, Schema)]
 struct UserResponse {
     id: i64,
     name: String,
     email: String,
-    created_at: String,
+    created_at: &'static str,
     is_active: bool,
 }
 
@@ -35,8 +32,8 @@ struct UsersListResponse {
 #[derive(Serialize, Schema)]
 struct PostResponse {
     post_id: i64,
-    title: String,
-    content: String,
+    title: &'static str,
+    content: &'static str,
 }
 
 #[derive(Deserialize, Validate, Schema)]
@@ -48,24 +45,24 @@ struct CreateUser {
 }
 
 // ============================================
-// Handlers
+// Handlers - Optimized for benchmarks
 // ============================================
 
-/// Plain text response - baseline
+/// Plain text response - baseline (zero allocation)
 #[rustapi_rs::get("/")]
 #[rustapi_rs::tag("Benchmark")]
 #[rustapi_rs::summary("Plain text hello")]
 async fn hello() -> &'static str {
     "Hello, World!"
 }
 
-/// Simple JSON response
+/// Simple JSON response - pre-serialized bytes
 #[rustapi_rs::get("/json")]
 #[rustapi_rs::tag("Benchmark")]
 #[rustapi_rs::summary("JSON hello")]
 async fn json_hello() -> Json<HelloResponse> {
     Json(HelloResponse {
-        message: "Hello, World!".to_string(),
+        message: "Hello, World!",
     })
 }
 
@@ -78,7 +75,7 @@ async fn get_user(Path(id): Path<i64>) -> Json<UserResponse> {
         id,
         name: format!("User {}", id),
         email: format!("user{}@example.com", id),
-        created_at: "2024-01-01T00:00:00Z".to_string(),
+        created_at: "2024-01-01T00:00:00Z",
         is_active: true,
     })
 }
@@ -90,12 +87,11 @@ async fn get_user(Path(id): Path<i64>) -> Json<UserResponse> {
 async fn get_post(Path(id): Path<i64>) -> Json<PostResponse> {
     Json(PostResponse {
         post_id: id,
-        title: "Benchmark Post".to_string(),
-        content: "This is a test post for benchmarking".to_string(),
+        title: "Benchmark Post",
+        content: "This is a test post for benchmarking",
     })
 }
 
-
 /// JSON request body parsing with validation
 #[rustapi_rs::post("/create-user")]
 #[rustapi_rs::tag("Benchmark")]
@@ -105,7 +101,7 @@ async fn create_user(ValidatedJson(body): ValidatedJson<CreateUser>) -> Json<Use
         id: 1,
         name: body.name,
         email: body.email,
-        created_at: "2024-01-01T00:00:00Z".to_string(),
+        created_at: "2024-01-01T00:00:00Z",
         is_active: true,
     })
 }
@@ -120,11 +116,11 @@ async fn list_users() -> Json<UsersListResponse> {
             id,
             name: format!("User {}", id),
             email: format!("user{}@example.com", id),
-            created_at: "2024-01-01T00:00:00Z".to_string(),
+            created_at: "2024-01-01T00:00:00Z",
             is_active: id % 2 == 0,
         })
         .collect();
-    
+
     Json(UsersListResponse {
         total: 100,
         page: 1,
@@ -133,32 +129,13 @@ async fn list_users() -> Json<UsersListResponse> {
 }
 
 // ============================================
-// Main
+// Main - Optimized minimal server
 // ============================================
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
-    println!("🚀 RustAPI Benchmark Server");
-    println!("═══════════════════════════════════════════════════════════");
-    println!();
-    println!("📊 Benchmark Endpoints:");
-    println!("  GET  /                        - Plain text (baseline)");
-    println!("  GET  /json                    - Simple JSON");
-    println!("  GET  /users/:id               - JSON + path param");
-    println!("  GET  /posts/:id               - JSON + path param (alt)");
-    println!("  POST /create-user             - JSON parsing + validation");
-    println!("  GET  /users-list              - Large JSON (10 users)");
-    println!();
-    println!("🔧 Load Test Commands (install hey: go install github.com/rakyll/hey@latest):");
-    println!("  hey -n 100000 -c 50 http://127.0.0.1:8080/");
-    println!("  hey -n 100000 -c 50 http://127.0.0.1:8080/json");
-    println!("  hey -n 100000 -c 50 http://127.0.0.1:8080/users/123");
-    println!("  hey -n 50000 -c 50 -m POST -H \"Content-Type: application/json\" \\");
-    println!("      -d '{{\"name\":\"Test\",\"email\":\"test@example.com\"}}' http://127.0.0.1:8080/create-user");
-    println!();
-    println!("═══════════════════════════════════════════════════════════");
-    println!("🌐 Server running at: http://127.0.0.1:8080");
-    println!();
+    // Minimal output for benchmarks
+    eprintln!("🚀 RustAPI Benchmark Server @ http://127.0.0.1:8080");
 
     RustApi::new()
         .mount_route(hello_route())

benches/bench_server/src/main.rs

@@ -0,0 +1 @@
+{"message":"Hello, World!"}

benches/test_body.json

@@ -22,6 +22,9 @@ http = { workspace = true }
 http-body-util = { workspace = true }
 bytes = { workspace = true }
 
+# Socket options
+socket2 = { version = "0.5", features = ["all"] }
+
 # Router
 matchit = { workspace = true }
 

crates/rustapi-core/Cargo.toml

@@ -64,6 +64,15 @@ pub fn from_slice_mut<T: DeserializeOwned>(slice: &mut [u8]) -> Result<T, JsonEr
 /// Serialize a value to a JSON byte vector.
 ///
 /// Uses pre-allocated buffer with estimated capacity for better performance.
+#[cfg(feature = "simd-json")]
+pub fn to_vec<T: Serialize>(value: &T) -> Result<Vec<u8>, JsonError> {
+    simd_json::to_vec(value).map_err(JsonError::SimdJson)
+}
+
+/// Serialize a value to a JSON byte vector.
+///
+/// Uses pre-allocated buffer with estimated capacity for better performance.
+#[cfg(not(feature = "simd-json"))]
 pub fn to_vec<T: Serialize>(value: &T) -> Result<Vec<u8>, JsonError> {
     serde_json::to_vec(value).map_err(JsonError::SerdeJson)
 }
@@ -72,6 +81,21 @@ pub fn to_vec<T: Serialize>(value: &T) -> Result<Vec<u8>, JsonError> {
 ///
 /// Use this when you have a good estimate of the output size to avoid
 /// reallocations.
+#[cfg(feature = "simd-json")]
+pub fn to_vec_with_capacity<T: Serialize>(
+    value: &T,
+    capacity: usize,
+) -> Result<Vec<u8>, JsonError> {
+    let mut buf = Vec::with_capacity(capacity);
+    simd_json::to_writer(&mut buf, value).map_err(JsonError::SimdJson)?;
+    Ok(buf)
+}
+
+/// Serialize a value to a JSON byte vector with pre-allocated capacity.
+///
+/// Use this when you have a good estimate of the output size to avoid
+/// reallocations.
+#[cfg(not(feature = "simd-json"))]
 pub fn to_vec_with_capacity<T: Serialize>(
     value: &T,
     capacity: usize,