fix: HTTP/1.0 connection not closing causes ab benchmark to hang

- Add HTTP version detection in parse_http_request_usockets
- Return Connection: close header for HTTP/1.0 requests
- Call shutdown() for graceful connection close after HTTP/1.0 response
- Fix missing is_http11 parameter in WebSocket upgrade handler

Root cause: ab uses HTTP/1.0 by default, but server always returned
Connection: keep-alive, causing ab to wait for server to close connection.

README.md

@@ -50,8 +50,13 @@ cd v-hono
 ### Standard Build (picoev backend)
 
 ```bash
-v your_app.v -o app.exe
-./app.exe
+# macOS / Linux
+v -prod -o app your_app.v
+./app
+
+# Windows
+v -o app.exe your_app.v
+.\app.exe
 ```
 
 ### High-Performance Build (uSockets backend)
@@ -59,25 +64,33 @@ v your_app.v -o app.exe
 For maximum performance with uSockets backend:
 
 ```bash
-v -enable-globals -cc gcc -ldflags "-ldbghelp" your_app.v -o app.exe
-./app.exe
+# macOS / Linux
+v -enable-globals -prod -o app your_app.v
+./app
+
+# Windows (must use gcc, tcc does not support .a static library format)
+v -enable-globals -cc gcc -ldflags "-ldbghelp" -o app.exe your_app.v
+.\app.exe
 ```
 
-**Note**: The `-enable-globals` flag is required for uSockets backend. The `-ldflags "-ldbghelp"` fixes Windows linking issues.
+**Important Notes:**
+- The `-enable-globals` flag is required for uSockets backend
+- On Windows, you **must** use `-cc gcc` because V's default compiler (tcc) does not support MinGW `.a` static library format
+- The `-ldflags "-ldbghelp"` is required on Windows for libuv linking
 
 #### Windows Prerequisites
 
 To use uSockets backend on Windows, you need:
 
-1. **GCC (MinGW-w64)** - C compiler
+1. **GCC (MinGW-w64)** - C compiler (required, tcc is not supported)
    ```powershell
-   # Install via Scoop
+   # Install via Scoop (recommended)
    scoop install mingw
    
    # Or via Chocolatey
    choco install mingw
    
-   # Or download from: https://www.mingw-w64.org/downloads/
+   # Or download w64devkit from: https://github.com/skeeto/w64devkit/releases
    ```
 
 2. **V Compiler** - Version 0.4.x or later
@@ -94,7 +107,11 @@ To use uSockets backend on Windows, you need:
    v version       # Should show V 0.4.x
    ```
 
-The uSockets library and libuv are pre-compiled and included in the `usockets/lib/` directory.
+The uSockets library and libuv are pre-compiled and included in the `usockets/lib/{platform}/` directory:
+- `usockets/lib/windows/` - Windows x64
+- `usockets/lib/linux/` - Linux x64
+- `usockets/lib/macos-arm64/` - macOS Apple Silicon
+- `usockets/lib/macos-x64/` - macOS Intel
 
 ### Using uSockets Backend
 

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
 }

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
-
-# 根据系统选择编译参数
-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
+# 编译 libuv
+compile_libuv() {
+    echo "编译 libuv..."
+    cd "$LIBUV_DIR"
+    rm -rf build 2>/dev/null || true
+    mkdir -p build
+    cd build
+    
+    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
+    
+    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
+    
+    cmake --build . --config Release
+}
 
-# 复制到 v-hono
-echo "复制库文件..."
-cp "$USOCKETS_DIR/uSockets.a" "$SCRIPT_DIR/../lib/libusockets_full.a"
+# 编译 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
+}
 
-echo "=== 编译完成 ==="
-echo "库文件: $SCRIPT_DIR/../lib/libusockets_full.a"
+# 合并库文件
+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/usockets/lib
-	#flag @VMODROOT/usockets/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/usockets/lib
-	#flag @VMODROOT/usockets/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/usockets/lib
-	#flag @VMODROOT/usockets/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)
 }
 

usockets_server.v

@@ -183,7 +183,7 @@ fn handle_usockets_ws_upgrade(s usockets.Socket, raw_data string, route_match Co
 	// Check if this is a WebSocket upgrade response
 	if response.status_code != 101 {
 		// Not a WebSocket upgrade, send the response as-is
-		send_usockets_response(s, mutable_ctx, response)
+		send_usockets_response(s, mutable_ctx, response, true)
 		return false
 	}
 	
@@ -227,7 +227,7 @@ fn usockets_on_data(s usockets.Socket, data &char, length int) usockets.Socket {
 
 	// 解析 HTTP 请求
 	raw_data := unsafe { tos(&u8(data), length) }
-	method, path, query_map, body := parse_http_request_usockets(raw_data)
+	method, path, query_map, body, is_http11 := parse_http_request_usockets(raw_data)
 	
 	if method.len == 0 {
 		s.write_bytes('HTTP/1.1 400 Bad Request\r\nContent-Length: 11\r\n\r\nBad Request')
@@ -259,11 +259,11 @@ fn usockets_on_data(s usockets.Socket, data &char, length int) usockets.Socket {
 			// 优化1：零中间件快速路径
 			if !g_usockets_app.has_middlewares {
 				response := route_match.handler.handle(mut hono_ctx)
-				send_usockets_response(s, hono_ctx, response)
+				send_usockets_response(s, hono_ctx, response, is_http11)
 			} else {
 				middlewares := get_middlewares_for_path_usockets_optimized(g_usockets_app, path)
 				response := exec_middlewares_usockets(0, middlewares, mut hono_ctx, route_match.handler)
-				send_usockets_response(s, hono_ctx, response)
+				send_usockets_response(s, hono_ctx, response, is_http11)
 			}
 			response_sent = true
 		}
@@ -289,11 +289,11 @@ fn usockets_on_data(s usockets.Socket, data &char, length int) usockets.Socket {
 			// 优化1：零中间件快速路径
 			if !g_usockets_app.has_middlewares {
 				response := route_match.handler.handle(mut hono_ctx)
-				send_usockets_response(s, hono_ctx, response)
+				send_usockets_response(s, hono_ctx, response, is_http11)
 			} else {
 				middlewares := get_middlewares_for_path_usockets_optimized(g_usockets_app, path)
 				response := exec_middlewares_usockets(0, middlewares, mut hono_ctx, route_match.handler)
-				send_usockets_response(s, hono_ctx, response)
+				send_usockets_response(s, hono_ctx, response, is_http11)
 			}
 			response_sent = true
 		}
@@ -305,9 +305,13 @@ fn usockets_on_data(s usockets.Socket, data &char, length int) usockets.Socket {
 
 		if handler := g_usockets_app.not_found_handler {
 			response := handler(mut hono_ctx)
-			send_usockets_response(s, hono_ctx, response)
+			send_usockets_response(s, hono_ctx, response, is_http11)
 		} else {
-			s.write_bytes('HTTP/1.1 404 Not Found\r\nContent-Type: text/plain\r\nContent-Length: 9\r\nConnection: keep-alive\r\n\r\nNot Found')
+			conn_header := if is_http11 { 'keep-alive' } else { 'close' }
+			s.write_bytes('HTTP/1.1 404 Not Found\r\nContent-Type: text/plain\r\nContent-Length: 9\r\nConnection: ${conn_header}\r\n\r\nNot Found')
+			if !is_http11 {
+				s.shutdown()
+			}
 		}
 	}
 
@@ -334,15 +338,17 @@ fn usockets_on_end(s usockets.Socket) usockets.Socket {
 
 // 解析 HTTP 请求 - 零分配优化版
 // 使用指针遍历避免创建临时数组
-fn parse_http_request_usockets(raw string) (string, string, map[string]string, string) {
+// 返回: (method, path, query_map, body, is_http11)
+fn parse_http_request_usockets(raw string) (string, string, map[string]string, string, bool) {
 	mut method := ''
 	mut path := ''
 	mut query_map := map[string]string{}
 	mut body := ''
+	mut is_http11 := true
 	
 	len := raw.len
 	if len == 0 {
-		return method, path, query_map, body
+		return method, path, query_map, body, is_http11
 	}
 	
 	// 1. 查找第一行结束位置（\r\n）
@@ -354,7 +360,7 @@ fn parse_http_request_usockets(raw string) (string, string, map[string]string, s
 		}
 	}
 	if line_end == -1 {
-		return method, path, query_map, body
+		return method, path, query_map, body, is_http11
 	}
 	
 	// 2. 解析 method（到第一个空格）
@@ -363,7 +369,7 @@ fn parse_http_request_usockets(raw string) (string, string, map[string]string, s
 		method_end++
 	}
 	if method_end == 0 || method_end >= line_end {
-		return method, path, query_map, body
+		return method, path, query_map, body, is_http11
 	}
 	method = raw[..method_end]
 	
@@ -391,7 +397,18 @@ fn parse_http_request_usockets(raw string) (string, string, map[string]string, s
 		path = raw[path_start..path_end]
 	}
 	
-	// 4. 查找 body（\r\n\r\n 之后）
+	// 4. 检测 HTTP 版本 - "HTTP/1.0" vs "HTTP/1.1"
+	// 请求行格式: "GET /path HTTP/1.1\r\n"
+	mut version_start := path_end + 1
+	for version_start < line_end && raw[version_start] == ` ` {
+		version_start++
+	}
+	if version_start < line_end {
+		version_str := raw[version_start..line_end]
+		is_http11 = !version_str.contains('1.0')
+	}
+	
+	// 5. 查找 body（\r\n\r\n 之后）
 	for i in line_end .. len - 3 {
 		if raw[i] == `\r` && raw[i + 1] == `\n` && raw[i + 2] == `\r` && raw[i + 3] == `\n` {
 			if i + 4 < len {
@@ -401,7 +418,7 @@ fn parse_http_request_usockets(raw string) (string, string, map[string]string, s
 		}
 	}
 	
-	return method, path, query_map, body
+	return method, path, query_map, body, is_http11
 }
 
 // 快速解析 query string（单次遍历，避免 split）
@@ -576,7 +593,7 @@ fn exec_middlewares_usockets(idx int, middlewares []ContextMiddleware, mut ctx C
 }
 
 // 发送 uSockets 响应 - 优化版
-fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response) {
+fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response, is_http11 bool) {
 	// Check if this is a streaming response
 	if is_streaming_response(ctx) {
 		// Handle streaming response
@@ -630,14 +647,25 @@ fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response
 	resp.write_string(response.body.len.str())
 	resp.write_string('\r\n')
 
-	// Connection
-	resp.write_string('Connection: keep-alive\r\n')
+	// Connection - HTTP/1.0 用 close，HTTP/1.1 用 keep-alive
+	if is_http11 {
+		resp.write_string('Connection: keep-alive\r\n')
+	} else {
+		resp.write_string('Connection: close\r\n')
+	}
 
 	// 空行 + body
 	resp.write_string('\r\n')
 	resp.write_string(response.body)
 
 	s.write_bytes(resp.str())
+	
+	// HTTP/1.0 请求完成后关闭连接
+	// 只调用 shutdown() 发送 FIN，让 on_end 回调处理 close()
+	// 这样可以确保发送缓冲区的数据完全发送
+	if !is_http11 {
+		s.shutdown()
+	}
 }
 
 // ============================================================================

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.2'
+	version: '0.7.7'
 	license: 'MIT'
 	dependencies: []
 }