chore: update v.mod version

- Organize lib directory by platform: windows/, macos-arm64/, macos-x64/, linux/
- Update build.sh to support unified build process for Windows/macOS/Linux
- Compile libuv + uSockets and merge into complete static library
- Update usockets.v conditional compilation to point to new directory structure
- Optimize benchmark tests with connection pooling for high concurrency testing
- Clean up unused legacy library files

Performance test results (Windows):
- 1000 concurrent, 1M requests: 35,223 req/s
- 10000 concurrent, 1M requests: 26,884 req/s

.gitignore

@@ -2,7 +2,6 @@
 *.exe
 *.out
 *.o
-*.a
 *.so
 *.dll
 

benchmark/usockets_verify.go

@@ -448,21 +448,49 @@ func checkKeepAlive(client *http.Client) bool {
 
 func checkThroughput(client *http.Client) float64 {
 	start := time.Now()
-	success := 0
-	requests := 200
+	concurrency := 1000
+	totalRequests := 1000000
+	requestsPerWorker := totalRequests / concurrency
 
-	for i := 0; i < requests; i++ {
-		resp, err := client.Get(baseURL + "/health")
-		if err != nil {
-			continue
-		}
-		io.Copy(io.Discard, resp.Body)
-		resp.Body.Close()
-		if resp.StatusCode == 200 {
-			success++
-		}
+	// 创建共享的 Transport，启用连接池复用
+	transport := &http.Transport{
+		MaxIdleConns:        concurrency,
+		MaxIdleConnsPerHost: concurrency,
+		IdleConnTimeout:     30 * time.Second,
+		DisableKeepAlives:   false,
+	}
+
+	results := make(chan int, concurrency)
+
+	for i := 0; i < concurrency; i++ {
+		go func() {
+			localSuccess := 0
+			// 每个 goroutine 使用独立 Client，但共享 Transport（连接池）
+			localClient := &http.Client{
+				Timeout:   10 * time.Second,
+				Transport: transport,
+			}
+			for j := 0; j < requestsPerWorker; j++ {
+				resp, err := localClient.Get(baseURL + "/health")
+				if err != nil {
+					continue
+				}
+				io.Copy(io.Discard, resp.Body)
+				resp.Body.Close()
+				if resp.StatusCode == 200 {
+					localSuccess++
+				}
+			}
+			results <- localSuccess
+		}()
+	}
+
+	success := 0
+	for i := 0; i < concurrency; i++ {
+		success += <-results
 	}
 
 	elapsed := time.Since(start).Seconds()
+	fmt.Printf("\n    [并发: %d, 总请求: %d, 成功: %d, 耗时: %.2fs]\n    ", concurrency, totalRequests, success, elapsed)
 	return float64(success) / elapsed
 }

picoev_server.v

@@ -583,8 +583,8 @@ fn send_picoev_response(mut res picohttpparser.Response, ctx Context, response h
 
 // handle_picoev_streaming_response - Handle a streaming response using PicoevStreamWriter
 // This function:
-// 1. Sends the HTTP headers for streaming
-// 2. Creates a PicoevStreamWriter
+// 1. Sends the HTTP headers for streaming directly to socket fd
+// 2. Creates a PicoevStreamWriter with the socket fd
 // 3. Executes the streaming callback
 // 4. Handles errors and cleanup
 fn handle_picoev_streaming_response(mut res picohttpparser.Response, ctx Context, config PicoevConfig) {
@@ -601,14 +601,10 @@ fn handle_picoev_streaming_response(mut res picohttpparser.Response, ctx Context
 	// Determine status code
 	status_code := if ctx.status_code != 0 { ctx.status_code } else { 200 }
 	
-	// Send HTTP response line
-	if status_code == 200 {
-		res.http_ok()
-	} else {
-		res.raw('HTTP/1.1 ${status_code} ${get_status_text(status_code)}\r\n')
-	}
+	// Build HTTP headers string for direct socket write
+	mut headers_str := 'HTTP/1.1 ${status_code} ${get_status_text(status_code)}\r\n'
 	
-	// Send headers from context
+	// Add headers from context
 	mut has_transfer_encoding := false
 	mut has_connection := false
 	
@@ -618,7 +614,7 @@ fn handle_picoev_streaming_response(mut res picohttpparser.Response, ctx Context
 		if key_len == 14 && eq_ignore_case(key, 'content-length') {
 			continue
 		}
-		res.header(key, value)
+		headers_str += '${key}: ${value}\r\n'
 		if key_len == 17 && eq_ignore_case(key, 'transfer-encoding') {
 			has_transfer_encoding = true
 		} else if key_len == 10 && eq_ignore_case(key, 'connection') {
@@ -628,20 +624,27 @@ fn handle_picoev_streaming_response(mut res picohttpparser.Response, ctx Context
 	
 	// Ensure Transfer-Encoding: chunked is set
 	if !has_transfer_encoding {
-		res.header('Transfer-Encoding', 'chunked')
+		headers_str += 'Transfer-Encoding: chunked\r\n'
 	}
 	
 	// Ensure Connection header is set for streaming
 	if !has_connection {
-		res.header('Connection', 'keep-alive')
-		res.header('Keep-Alive', 'timeout=${config.timeout_secs}')
+		headers_str += 'Connection: keep-alive\r\n'
+		headers_str += 'Keep-Alive: timeout=${config.timeout_secs}\r\n'
 	}
 	
-	// End headers section (empty body to signal headers are complete)
-	// Note: We don't call res.body() or res.end() here because we're streaming
-	res.raw('\r\n')
+	// End headers section
+	headers_str += '\r\n'
 	
-	// Create PicoevStreamWriter for streaming
+	// Write headers directly to socket fd for immediate delivery
+	fd := res.fd
+	write_to_socket_fd(fd, headers_str.bytes()) or {
+		eprintln('[Picoev Stream Error] Failed to write headers: ${err.msg()}')
+		cleanup_stream_config(ctx)
+		return
+	}
+	
+	// Create PicoevStreamWriter for streaming (uses fd directly)
 	mut writer := PicoevStreamWriter.new(res)
 	
 	// Create StreamContext with the writer
@@ -665,6 +668,27 @@ fn handle_picoev_streaming_response(mut res picohttpparser.Response, ctx Context
 	cleanup_stream_config(ctx)
 }
 
+// write_to_socket_fd - Helper function to write bytes directly to socket fd
+// Used for sending HTTP headers before streaming begins
+fn write_to_socket_fd(fd int, data []u8) ! {
+	if data.len == 0 {
+		return
+	}
+	mut total_written := 0
+	for total_written < data.len {
+		remaining := data.len - total_written
+		ptr := unsafe { &u8(data.data) + total_written }
+		written := C.send(fd, ptr, remaining, 0)
+		if written < 0 {
+			return error('Failed to write to socket')
+		}
+		if written == 0 {
+			return error('Connection closed by peer')
+		}
+		total_written += written
+	}
+}
+
 // 获取状态码文本
 fn get_status_text(code int) string {
 	return match code {

streaming.v

@@ -8,6 +8,9 @@ import time
 import picohttpparser
 import usockets
 
+// C function declaration for direct socket writes
+fn C.send(sockfd int, buf voidptr, len int, flags int) int
+
 // ============================================================================
 // SSE Event Structure
 // ============================================================================
@@ -184,23 +187,26 @@ pub fn (mut ctx StreamContext) trigger_abort() {
 
 // PicoevStreamWriter - StreamWriter implementation for picoev server
 // Supports chunked transfer encoding for streaming responses
+// Uses direct socket fd writes for immediate data delivery (true streaming)
 @[heap]
 pub struct PicoevStreamWriter {
 mut:
-	res       &picohttpparser.Response
+	fd        int  // Socket file descriptor for direct writes
 	connected bool
 }
 
 // PicoevStreamWriter.new - Create a new PicoevStreamWriter with the given response
+// Extracts the fd from picohttpparser.Response for direct socket writes
 pub fn PicoevStreamWriter.new(res &picohttpparser.Response) &PicoevStreamWriter {
 	return &PicoevStreamWriter{
-		res: unsafe { res }
+		fd: res.fd
 		connected: true
 	}
 }
 
 // write - Write raw bytes to the stream using chunked transfer encoding
 // Format: {hex_size}\r\n{data}\r\n
+// Writes directly to socket fd for immediate delivery
 pub fn (mut w PicoevStreamWriter) write(data []u8) ! {
 	if !w.connected {
 		return error('Connection closed')
@@ -210,9 +216,10 @@ pub fn (mut w PicoevStreamWriter) write(data []u8) ! {
 	}
 	// Write chunked format: size in hex, CRLF, data, CRLF
 	chunk_header := format_chunk_size(data.len)
-	w.res.raw(chunk_header)
-	w.res.raw(data.bytestr())
-	w.res.raw('\r\n')
+	// Write directly to socket fd
+	w.write_to_fd(chunk_header.bytes())!
+	w.write_to_fd(data)!
+	w.write_to_fd('\r\n'.bytes())!
 }
 
 // write_string - Write a string to the stream using chunked transfer encoding
@@ -225,15 +232,40 @@ pub fn (mut w PicoevStreamWriter) write_string(data string) ! {
 	}
 	// Write chunked format: size in hex, CRLF, data, CRLF
 	chunk_header := format_chunk_size(data.len)
-	w.res.raw(chunk_header)
-	w.res.raw(data)
-	w.res.raw('\r\n')
+	// Write directly to socket fd
+	w.write_to_fd(chunk_header.bytes())!
+	w.write_to_fd(data.bytes())!
+	w.write_to_fd('\r\n'.bytes())!
 }
 
-// flush - Flush the buffer (picoev handles this automatically)
+// write_to_fd - Write bytes directly to the socket file descriptor
+// This ensures immediate delivery without buffering
+@[inline]
+fn (mut w PicoevStreamWriter) write_to_fd(data []u8) ! {
+	if data.len == 0 {
+		return
+	}
+	mut total_written := 0
+	for total_written < data.len {
+		remaining := data.len - total_written
+		ptr := unsafe { &u8(data.data) + total_written }
+		written := C.send(w.fd, ptr, remaining, 0)
+		if written < 0 {
+			w.connected = false
+			return error('Failed to write to socket')
+		}
+		if written == 0 {
+			w.connected = false
+			return error('Connection closed by peer')
+		}
+		total_written += written
+	}
+}
+
+// flush - Flush the buffer (direct fd writes are already unbuffered)
 pub fn (mut w PicoevStreamWriter) flush() ! {
-	// picoev automatically flushes data
-	// No explicit flush needed
+	// Direct fd writes are unbuffered, no explicit flush needed
+	// But we can use TCP_NODELAY to disable Nagle's algorithm if needed
 }
 
 // close - Close the stream by sending the final chunk
@@ -241,9 +273,9 @@ pub fn (mut w PicoevStreamWriter) flush() ! {
 pub fn (mut w PicoevStreamWriter) close() ! {
 	if w.connected {
 		// Write the final chunk (zero-length chunk) to signal end of stream
-		w.res.raw('0\r\n\r\n')
-		w.res.end()
+		w.write_to_fd('0\r\n\r\n'.bytes()) or {}
 		w.connected = false
+		// Note: Don't close the fd here, picoev manages the connection lifecycle
 	}
 }
 

usockets/build.sh

@@ -1,13 +1,36 @@
 #!/bin/bash
 # uSockets 编译脚本
-# 用于重新编译 libusockets_full.a
+# 用于重新编译 libusockets_full.a (包含 uSockets + libuv)
+# 支持: Windows (Git Bash/MSYS2), macOS (Intel/Apple Silicon), Linux
+# 输出到: usockets/lib/{platform}/libusockets_full.a
 
 set -e
 
 SCRIPT_DIR="$(cd "$(dirname "$0")" && pwd)"
 USOCKETS_DIR="/tmp/uSockets"
+LIBUV_DIR="/tmp/libuv"
+MERGE_DIR="/tmp/merge_libs"
 
 echo "=== uSockets 编译脚本 ==="
+echo "检测到系统: $OSTYPE"
+
+# 确定输出目录
+if [[ "$OSTYPE" == "darwin"* ]]; then
+    if [[ $(uname -m) == "arm64" ]]; then
+        OUTPUT_DIR="$SCRIPT_DIR/lib/macos-arm64"
+    else
+        OUTPUT_DIR="$SCRIPT_DIR/lib/macos-x64"
+    fi
+elif [[ "$OSTYPE" == "msys" || "$OSTYPE" == "cygwin" || "$OSTYPE" == "mingw"* ]]; then
+    OUTPUT_DIR="$SCRIPT_DIR/lib/windows"
+elif [[ "$OSTYPE" == "linux"* ]]; then
+    OUTPUT_DIR="$SCRIPT_DIR/lib/linux"
+else
+    OUTPUT_DIR="$SCRIPT_DIR/lib/linux"
+fi
+
+echo "输出目录: $OUTPUT_DIR"
+mkdir -p "$OUTPUT_DIR"
 
 # 检查是否有 uSockets 源码
 if [ ! -d "$USOCKETS_DIR" ]; then
@@ -15,41 +38,85 @@ if [ ! -d "$USOCKETS_DIR" ]; then
     git clone --depth 1 https://github.com/uNetworking/uSockets.git "$USOCKETS_DIR"
 fi
 
+# 检查是否有 libuv 源码
+if [ ! -d "$LIBUV_DIR" ]; then
+    echo "克隆 libuv..."
+    git clone --depth 1 --branch v1.48.0 https://github.com/libuv/libuv.git "$LIBUV_DIR"
+fi
+
 # 应用 backlog 修改
 echo "应用 backlog=16384 修改..."
 if [ -f "$SCRIPT_DIR/src/bsd.c" ]; then
     cp "$SCRIPT_DIR/src/bsd.c" "$USOCKETS_DIR/src/bsd.c"
 else
-    # 如果没有本地修改的源码，直接修改
     sed -i.bak 's/listen(listenFd, 512)/listen(listenFd, 16384)/g' "$USOCKETS_DIR/src/bsd.c"
 fi
 
-# 编译
-echo "编译 uSockets..."
-cd "$USOCKETS_DIR"
-make clean
+# 编译 libuv
+compile_libuv() {
+    echo "编译 libuv..."
+    cd "$LIBUV_DIR"
+    rm -rf build 2>/dev/null || true
+    mkdir -p build
+    cd build
     
-# 根据系统选择编译参数
-if [[ "$OSTYPE" == "darwin"* ]]; then
-    # macOS
-    if [[ $(uname -m) == "arm64" ]]; then
-        # Apple Silicon
-        WITH_LIBUV=1 CFLAGS="-I/opt/homebrew/include" make
-    else
-        # Intel Mac
-        WITH_LIBUV=1 CFLAGS="-I/usr/local/include" make
+    if ! command -v cmake &> /dev/null; then
+        echo "错误: 需要安装 cmake"
+        echo "  macOS: brew install cmake"
+        echo "  Linux: sudo apt install cmake 或 sudo yum install cmake"
+        echo "  Windows: scoop install cmake 或 choco install cmake"
+        exit 1
     fi
-else
-    # Linux
-    WITH_LIBUV=1 make
-fi
     
-# 复制到 v-hono
-echo "复制库文件..."
-cp "$USOCKETS_DIR/uSockets.a" "$SCRIPT_DIR/../lib/libusockets_full.a"
+    if [[ "$OSTYPE" == "msys" || "$OSTYPE" == "cygwin" || "$OSTYPE" == "mingw"* ]]; then
+        cmake .. -G "MinGW Makefiles" -DCMAKE_BUILD_TYPE=Release -DBUILD_TESTING=OFF -DLIBUV_BUILD_SHARED=OFF
+    else
+        cmake .. -DCMAKE_BUILD_TYPE=Release -DBUILD_TESTING=OFF -DLIBUV_BUILD_SHARED=OFF
+    fi
     
-echo "=== 编译完成 ==="
-echo "库文件: $SCRIPT_DIR/../lib/libusockets_full.a"
+    cmake --build . --config Release
+}
+
+# 编译 uSockets
+compile_usockets() {
+    echo "编译 uSockets..."
+    cd "$USOCKETS_DIR"
+    rm -f *.o *.a 2>/dev/null || true
+    
+    gcc -DLIBUS_NO_SSL -DLIBUS_USE_LIBUV -std=c11 -Isrc -I"$LIBUV_DIR/include" -O3 -c src/*.c src/eventing/*.c src/crypto/*.c
+    ar rcs uSockets.a *.o
+    rm -f *.o
+}
+
+# 合并库文件
+merge_libraries() {
+    echo "合并库文件..."
+    rm -rf "$MERGE_DIR"
+    mkdir -p "$MERGE_DIR"
+    
+    cd "$MERGE_DIR"
+    ar x "$USOCKETS_DIR/uSockets.a"
+    ar x "$LIBUV_DIR/build/libuv.a"
+    
+    ar rcs "$OUTPUT_DIR/libusockets_full.a" *.o
+    
+    rm -rf "$MERGE_DIR"
+}
+
+# 执行编译
+compile_libuv
+compile_usockets
+merge_libraries
+
+# 显示结果
+LIB_SIZE=$(ls -lh "$OUTPUT_DIR/libusockets_full.a" | awk '{print $5}')
 echo ""
-echo "重新编译 v-hono 应用:"
-echo "  v -enable-globals -prod -o your_app your_app.v"
+echo "=== 编译完成 ==="
+echo "库文件: $OUTPUT_DIR/libusockets_full.a ($LIB_SIZE)"
+echo ""
+echo "编译 v-hono 应用:"
+if [[ "$OSTYPE" == "msys" || "$OSTYPE" == "cygwin" || "$OSTYPE" == "mingw"* ]]; then
+    echo "  v -enable-globals -cc gcc -ldflags \"-ldbghelp\" -o app.exe app.v"
+else
+    echo "  v -enable-globals -prod -o app app.v"
+fi

usockets/usockets.v

@@ -2,41 +2,36 @@ module usockets
 
 // 条件编译：根据操作系统选择正确的路径和库
 // @VMODROOT 指向包含 v.mod 的模块根目录 (v-hono/)
+// 预编译库按平台存放在 usockets/lib/{platform}/ 目录
 
 $if windows {
 	#flag -DLIBUS_USE_LIBUV
 	#flag -DLIBUS_NO_SSL
 	#flag -I@VMODROOT/usockets/include
-	#flag -L@VMODROOT/lib
-	#flag @VMODROOT/lib/libusockets_full.a
-	#flag -lws2_32 -liphlpapi -lpsapi -luserenv -lole32
+	#flag -L@VMODROOT/usockets/lib/windows
+	#flag @VMODROOT/usockets/lib/windows/libusockets_full.a
+	#flag -lws2_32 -liphlpapi -lpsapi -luserenv -lole32 -ldbghelp
 } $else $if macos {
-	// macOS: 支持 Apple Silicon (M1/M2/M3) 和 Intel Mac
 	#flag -DLIBUS_USE_LIBUV
 	#flag -DLIBUS_NO_SSL
-	
-	// libuv 路径 - 根据架构选择 Homebrew 路径
-	$if arm64 {
-		#flag -I/opt/homebrew/include
-		#flag -L/opt/homebrew/lib
-	} $else {
-		#flag -I/usr/local/include
-		#flag -L/usr/local/lib
-	}
-	
-	// uSockets 库路径
 	#flag -I@VMODROOT/usockets/include
-	#flag -L@VMODROOT/lib
-	#flag @VMODROOT/lib/libusockets_full.a
-	#flag -luv
+	
+	$if arm64 {
+		// Apple Silicon (M1/M2/M3)
+		#flag -L@VMODROOT/usockets/lib/macos-arm64
+		#flag @VMODROOT/usockets/lib/macos-arm64/libusockets_full.a
+	} $else {
+		// Intel Mac
+		#flag -L@VMODROOT/usockets/lib/macos-x64
+		#flag @VMODROOT/usockets/lib/macos-x64/libusockets_full.a
+	}
 } $else {
 	// Linux 和其他平台
 	#flag -DLIBUS_USE_LIBUV
 	#flag -DLIBUS_NO_SSL
 	#flag -I@VMODROOT/usockets/include
-	#flag -L@VMODROOT/lib
-	#flag @VMODROOT/lib/libusockets_full.a
-	#flag -luv
+	#flag -L@VMODROOT/usockets/lib/linux
+	#flag @VMODROOT/usockets/lib/linux/libusockets_full.a
 }
 
 #include "libusockets.h"
@@ -105,8 +100,6 @@ pub fn (ctx SocketContext) on_writable(h voidptr) { C.us_socket_context_on_writa
 pub fn (ctx SocketContext) on_timeout(h voidptr) { C.us_socket_context_on_timeout(0, ctx, h) }
 pub fn (ctx SocketContext) on_end(h voidptr) { C.us_socket_context_on_end(0, ctx, h) }
 pub fn (ctx SocketContext) listen(port int) ListenSocket {
-	// 参数: ssl=0, context, host=nil, port, options=LIBUS_LISTEN_DEFAULT(0), socket_ext_size=0
-	// 注意: backlog 是在 uSockets 库内部硬编码的，不通过此函数传递
 	return C.us_socket_context_listen(0, ctx, unsafe { nil }, port, 0, 0)
 }
 

v.mod

@@ -1,7 +1,7 @@
 Module {
 	name: 'hono'
 	description: 'A high-performance V language web framework inspired by Hono.js, featuring hybrid routing, LRU cache, middleware support, and more.'
-	version: '0.7.0'
+	version: '0.7.4'
 	license: 'MIT'
 	dependencies: []
 }