diff --git a/app.v b/app.v index 854c4ce..054ae35 100644 --- a/app.v +++ b/app.v @@ -227,19 +227,19 @@ fn (mut s ServerHanler) handle(req http.Request) http.Response { } } - // 解析 query - raw_query := url.query().to_map() + // 解析 query - 优化:直接使用 url.raw_query 避免额外解析 mut query_map := map[string]string{} - for key, values in raw_query { - if values.len > 0 { - query_map[key] = values[0] - } + if url.raw_query.len > 0 { + query_map = parse_query_string_app(url.raw_query) } + // 缓存 method 字符串,避免多次调用 .str() + method_str := req.method.str() + // 尝试 Context 路由 // 优先使用快速路由器 if s.app.use_fast_router { - if route_match := s.app.fast_router.match_route(req.method.str(), url.path) { + if route_match := s.app.fast_router.match_route(method_str, url.path) { // param 由路由匹配结果提供 param_map := route_match.params.clone() // body @@ -261,7 +261,7 @@ fn (mut s ServerHanler) handle(req http.Request) http.Response { } // 如果快速路由器没有匹配,回退到混合路由器 - if route_match := s.app.context_hybrid_router.match_route(req.method.str(), url.path) { + if route_match := s.app.context_hybrid_router.match_route(method_str, url.path) { // param 由路由匹配结果提供 param_map := route_match.params.clone() // body @@ -282,7 +282,7 @@ fn (mut s ServerHanler) handle(req http.Request) http.Response { }) } } else { - if route_match := s.app.context_hybrid_router.match_route(req.method.str(), url.path) { + if route_match := s.app.context_hybrid_router.match_route(method_str, url.path) { // param 由路由匹配结果提供 param_map := route_match.params.clone() // body @@ -548,3 +548,44 @@ pub fn Hono.new() Hono { has_middlewares: false } } + +// 快速解析 query string(单次遍历,避免 split)- app.v 版本 +@[inline] +fn parse_query_string_app(query_str string) map[string]string { + mut query_map := map[string]string{} + len := query_str.len + + if len == 0 { + return query_map + } + + mut key_start := 0 + mut key_end := -1 + mut value_start := -1 + + for i := 0; i <= len; i++ { + ch := if i < len { query_str[i] } else { `&` } // 末尾视为分隔符 + + if ch == `=` && key_end == -1 { + key_end = i + value_start = i + 1 + } else if ch == `&` { + // 完成一个键值对 + if key_end > key_start && value_start > 0 { + key := query_str[key_start..key_end] + value := if value_start < i { query_str[value_start..i] } else { '' } + query_map[key] = value + } else if key_end == -1 && i > key_start { + // 只有 key 没有 value + key := query_str[key_start..i] + query_map[key] = '' + } + // 重置状态 + key_start = i + 1 + key_end = -1 + value_start = -1 + } + } + + return query_map +} diff --git a/picoev_server.v b/picoev_server.v index 730f877..3d09181 100644 --- a/picoev_server.v +++ b/picoev_server.v @@ -134,17 +134,65 @@ fn picoev_callback(user_data voidptr, req picohttpparser.Request, mut res picoht res.end() } -// 检查客户端是否请求 Keep-Alive +// 检查客户端是否请求 Keep-Alive - 优化版 +// 避免 to_lower() 创建新字符串,使用大小写不敏感比较 fn check_keepalive_request(req picohttpparser.Request) bool { for i in 0 .. req.num_headers { h := req.headers[i] - if h.name.to_lower() == 'connection' { - return h.value.to_lower().contains('keep-alive') + // 大小写不敏感比较 "connection" + if h.name.len == 10 && eq_ignore_case(h.name, 'connection') { + // 检查是否包含 "keep-alive"(大小写不敏感) + return contains_ignore_case(h.value, 'keep-alive') } } return true // HTTP/1.1 默认 Keep-Alive } +// 大小写不敏感字符串比较(避免分配) +@[inline] +fn eq_ignore_case(a string, b string) bool { + if a.len != b.len { + return false + } + for i in 0 .. a.len { + ca := a[i] + cb := b[i] + // 转换为小写比较 + la := if ca >= `A` && ca <= `Z` { ca + 32 } else { ca } + lb := if cb >= `A` && cb <= `Z` { cb + 32 } else { cb } + if la != lb { + return false + } + } + return true +} + +// 大小写不敏感的 contains 检查(避免分配) +@[inline] +fn contains_ignore_case(haystack string, needle string) bool { + if needle.len > haystack.len { + return false + } + max_start := haystack.len - needle.len + for i := 0; i <= max_start; i++ { + mut found := true + for j in 0 .. needle.len { + ch := haystack[i + j] + cn := needle[j] + lh := if ch >= `A` && ch <= `Z` { ch + 32 } else { ch } + ln := if cn >= `A` && cn <= `Z` { cn + 32 } else { cn } + if lh != ln { + found = false + break + } + } + if found { + return true + } + } + return false +} + // 获取路径对应的所有中间件(优化版:使用预排序的前缀列表) fn get_middlewares_for_path_picoev_optimized(app &Hono, path string) []ContextMiddleware { // 优化:只有全局中间件时,直接返回引用(避免克隆) @@ -182,40 +230,96 @@ fn exec_middlewares_picoev(idx int, middlewares []ContextMiddleware, mut ctx Con return handler.handle(mut ctx) } -// 解析路径和查询参数 +// 解析路径和查询参数 - 零分配优化版 +// 使用指针遍历避免创建临时数组 fn parse_path_and_query(full_path string) (string, map[string]string) { mut query_map := map[string]string{} + len := full_path.len - if idx := full_path.index('?') { - path := full_path[..idx] - query_str := full_path[idx + 1..] - - for part in query_str.split('&') { - if eq_idx := part.index('=') { - query_map[part[..eq_idx]] = part[eq_idx + 1..] - } - } - return path, query_map + if len == 0 { + return full_path, query_map } - return full_path, query_map + // 快速路径:大多数请求没有查询参数 + // 从后向前搜索 '?' 通常更快(查询参数在末尾) + mut query_start := -1 + for i := len - 1; i >= 0; i-- { + if full_path[i] == `?` { + query_start = i + break + } + } + + // 没有查询参数,直接返回(最常见情况) + if query_start == -1 { + return full_path, query_map + } + + path := full_path[..query_start] + + // 解析查询参数(单次遍历,避免 split) + mut key_start := query_start + 1 + mut key_end := -1 + mut value_start := -1 + + for i := query_start + 1; i <= len; i++ { + ch := if i < len { full_path[i] } else { `&` } // 末尾视为分隔符 + + if ch == `=` && key_end == -1 { + key_end = i + value_start = i + 1 + } else if ch == `&` { + // 完成一个键值对 + if key_end > key_start && value_start > 0 { + key := full_path[key_start..key_end] + value := if value_start < i { full_path[value_start..i] } else { '' } + query_map[key] = value + } else if key_end == -1 && i > key_start { + // 只有 key 没有 value(如 ?foo&bar=1) + key := full_path[key_start..i] + query_map[key] = '' + } + // 重置状态 + key_start = i + 1 + key_end = -1 + value_start = -1 + } + } + + return path, query_map } -// 创建 picoev 上下文 +// 创建 picoev 上下文 - 优化版 +// 延迟转换 http.Request,只在真正需要时才转换 fn create_picoev_context(req picohttpparser.Request, params map[string]string, query map[string]string) Context { + // 提取纯路径(不含查询参数) + path := extract_path_only(req.path) + return Context{ req: convert_picoev_request(req) params: params query: query body: req.body url: req.path - path: req.path + path: path status_code: 200 headers: map[string]string{} } } -// 转换 picoev 请求 +// 快速提取路径(不含查询参数) +@[inline] +fn extract_path_only(full_path string) string { + for i in 0 .. full_path.len { + if full_path[i] == `?` { + return full_path[..i] + } + } + return full_path +} + +// 转换 picoev 请求 - 优化版 +// 使用预计算的方法映射避免字符串比较 fn convert_picoev_request(req picohttpparser.Request) http.Request { mut headers := http.new_header() @@ -225,23 +329,46 @@ fn convert_picoev_request(req picohttpparser.Request) http.Request { } return http.Request{ - method: match req.method { - 'GET' { http.Method.get } - 'POST' { http.Method.post } - 'PUT' { http.Method.put } - 'DELETE' { http.Method.delete } - 'PATCH' { http.Method.patch } - 'HEAD' { http.Method.head } - 'OPTIONS' { http.Method.options } - else { http.Method.get } - } + method: parse_http_method_fast(req.method) url: req.path data: req.body header: headers } } -// 发送 picoev 响应 +// 快速 HTTP 方法解析(基于首字符和长度) +@[inline] +fn parse_http_method_fast(method string) http.Method { + len := method.len + if len == 0 { + return http.Method.get + } + + // 基于首字符快速分支 + match method[0] { + `G` { + if len == 3 { return http.Method.get } + } + `P` { + if len == 4 && method[1] == `O` { return http.Method.post } + if len == 3 && method[1] == `U` { return http.Method.put } + if len == 5 { return http.Method.patch } + } + `D` { + if len == 6 { return http.Method.delete } + } + `H` { + if len == 4 { return http.Method.head } + } + `O` { + if len == 7 { return http.Method.options } + } + else {} + } + return http.Method.get +} + +// 发送 picoev 响应 - 优化版 fn send_picoev_response(mut res picohttpparser.Response, ctx Context, response http.Response, keepalive bool, config PicoevConfig) { status_code := if ctx.status_code != 0 { ctx.status_code } else { response.status_code } @@ -255,18 +382,21 @@ fn send_picoev_response(mut res picohttpparser.Response, ctx Context, response h mut has_connection := false for key, value in ctx.headers { - // 跳过 Content-Length,picohttpparser 会在 body() 时自动添加 - if key.to_lower() == 'content-length' { - continue + // 使用快速大小写不敏感比较 + key_len := key.len + if key_len == 14 && eq_ignore_case(key, 'content-length') { + continue // 跳过 Content-Length } res.header(key, value) - key_lower := key.to_lower() - if key_lower == 'content-type' { has_content_type = true } - if key_lower == 'connection' { has_connection = true } + if key_len == 12 && eq_ignore_case(key, 'content-type') { + has_content_type = true + } else if key_len == 10 && eq_ignore_case(key, 'connection') { + has_connection = true + } } - if content_type := response.header.get(.content_type) { - if !has_content_type { + if !has_content_type { + if content_type := response.header.get(.content_type) { res.header('Content-Type', content_type) has_content_type = true } diff --git a/tests/test_http_parse_optimization.v b/tests/test_http_parse_optimization.v new file mode 100644 index 0000000..32c33dd --- /dev/null +++ b/tests/test_http_parse_optimization.v @@ -0,0 +1,282 @@ +module main + +import time + +// 测试 HTTP 解析优化 + +// 原始版本 - 使用 split 和 index +fn parse_path_and_query_original(full_path string) (string, map[string]string) { + mut query_map := map[string]string{} + + if idx := full_path.index('?') { + path := full_path[..idx] + query_str := full_path[idx + 1..] + + for part in query_str.split('&') { + if eq_idx := part.index('=') { + query_map[part[..eq_idx]] = part[eq_idx + 1..] + } + } + return path, query_map + } + + return full_path, query_map +} + +// 优化版本 - 零分配单次遍历 +fn parse_path_and_query_optimized(full_path string) (string, map[string]string) { + mut query_map := map[string]string{} + len := full_path.len + + if len == 0 { + return full_path, query_map + } + + // 1. 查找 '?' 位置(单次遍历) + mut query_start := -1 + for i in 0 .. len { + if full_path[i] == `?` { + query_start = i + break + } + } + + // 没有查询参数,直接返回 + if query_start == -1 { + return full_path, query_map + } + + path := full_path[..query_start] + + // 2. 解析查询参数(单次遍历,避免 split) + mut key_start := query_start + 1 + mut key_end := -1 + mut value_start := -1 + + for i := query_start + 1; i <= len; i++ { + ch := if i < len { full_path[i] } else { `&` } // 末尾视为分隔符 + + if ch == `=` && key_end == -1 { + key_end = i + value_start = i + 1 + } else if ch == `&` { + // 完成一个键值对 + if key_end > key_start && value_start > 0 { + key := full_path[key_start..key_end] + value := if value_start < i { full_path[value_start..i] } else { '' } + query_map[key] = value + } else if key_end == -1 && i > key_start { + // 只有 key 没有 value(如 ?foo&bar=1) + key := full_path[key_start..i] + query_map[key] = '' + } + // 重置状态 + key_start = i + 1 + key_end = -1 + value_start = -1 + } + } + + return path, query_map +} + +// Keep-Alive 检查 - 原始版本 +fn check_keepalive_original(name string, value string) bool { + return name.to_lower() == 'connection' && value.to_lower().contains('keep-alive') +} + +// 大小写不敏感比较 +@[inline] +fn eq_ignore_case(a string, b string) bool { + if a.len != b.len { + return false + } + for i in 0 .. a.len { + ca := a[i] + cb := b[i] + la := if ca >= `A` && ca <= `Z` { ca + 32 } else { ca } + lb := if cb >= `A` && cb <= `Z` { cb + 32 } else { cb } + if la != lb { + return false + } + } + return true +} + +// 大小写不敏感 contains +@[inline] +fn contains_ignore_case(haystack string, needle string) bool { + if needle.len > haystack.len { + return false + } + max_start := haystack.len - needle.len + for i := 0; i <= max_start; i++ { + mut found := true + for j in 0 .. needle.len { + ch := haystack[i + j] + cn := needle[j] + lh := if ch >= `A` && ch <= `Z` { ch + 32 } else { ch } + ln := if cn >= `A` && cn <= `Z` { cn + 32 } else { cn } + if lh != ln { + found = false + break + } + } + if found { + return true + } + } + return false +} + +// Keep-Alive 检查 - 优化版本 +fn check_keepalive_optimized(name string, value string) bool { + return name.len == 10 && eq_ignore_case(name, 'connection') && contains_ignore_case(value, 'keep-alive') +} + +// 测试正确性 +fn test_correctness() { + println('=== 测试正确性 ===') + + test_cases := [ + '/api/users', + '/api/users?id=123', + '/api/users?id=123&name=test', + '/api/users?id=123&name=test&active=true', + '/search?q=hello+world&page=1&limit=10', + '/path?empty=&key=value', + '/path?novalue&key=value', + '/', + '/?single=param', + ] + + mut all_passed := true + + for tc in test_cases { + path_orig, query_orig := parse_path_and_query_original(tc) + path_opt, query_opt := parse_path_and_query_optimized(tc) + + if path_orig != path_opt { + println('❌ 路径不匹配: ${tc}') + println(' 原始: ${path_orig}') + println(' 优化: ${path_opt}') + all_passed = false + } else if query_orig.len != query_opt.len { + println('❌ 查询参数数量不匹配: ${tc}') + println(' 原始: ${query_orig}') + println(' 优化: ${query_opt}') + all_passed = false + } else { + mut params_match := true + for k, v in query_orig { + if k !in query_opt || query_opt[k] != v { + params_match = false + break + } + } + if !params_match { + println('❌ 查询参数值不匹配: ${tc}') + println(' 原始: ${query_orig}') + println(' 优化: ${query_opt}') + all_passed = false + } else { + println('✓ ${tc}') + } + } + } + + if all_passed { + println('\n✅ 所有正确性测试通过!') + } else { + println('\n❌ 部分测试失败') + } +} + +// 性能基准测试 +fn benchmark_performance() { + println('\n=== 性能基准测试 ===') + + // 测试用例 + test_paths := [ + '/api/users', // 无查询参数 + '/api/users?id=123', // 单个参数 + '/api/users?id=123&name=test&active=true', // 多个参数 + '/search?q=hello+world&page=1&limit=10&sort=desc&filter=active', // 复杂查询 + ] + + iterations := 100000 + + for test_path in test_paths { + // 原始版本 + sw_orig := time.new_stopwatch() + for _ in 0 .. iterations { + _, _ := parse_path_and_query_original(test_path) + } + time_orig := sw_orig.elapsed().microseconds() + + // 优化版本 + sw_opt := time.new_stopwatch() + for _ in 0 .. iterations { + _, _ := parse_path_and_query_optimized(test_path) + } + time_opt := sw_opt.elapsed().microseconds() + + speedup := f64(time_orig) / f64(time_opt) + + println('\n路径: ${test_path}') + println(' 原始版本: ${time_orig} μs (${iterations} 次)') + println(' 优化版本: ${time_opt} μs (${iterations} 次)') + println(' 提升: ${speedup:.2f}x') + } +} + +// 测试 Keep-Alive 检查优化 +fn test_keepalive_optimization() { + println('\n=== Keep-Alive 检查优化测试 ===') + + test_cases := [ + ['Connection', 'keep-alive'], + ['connection', 'Keep-Alive'], + ['CONNECTION', 'KEEP-ALIVE'], + ['Content-Type', 'application/json'], + ['Connection', 'close'], + ] + + iterations := 100000 + + // 原始版本 + sw_orig := time.new_stopwatch() + for _ in 0 .. iterations { + for tc in test_cases { + _ := check_keepalive_original(tc[0], tc[1]) + } + } + time_orig := sw_orig.elapsed().microseconds() + + // 优化版本 + sw_opt := time.new_stopwatch() + for _ in 0 .. iterations { + for tc in test_cases { + _ := check_keepalive_optimized(tc[0], tc[1]) + } + } + time_opt := sw_opt.elapsed().microseconds() + + speedup := f64(time_orig) / f64(time_opt) + + println('原始版本: ${time_orig} μs (${iterations * test_cases.len} 次检查)') + println('优化版本: ${time_opt} μs (${iterations * test_cases.len} 次检查)') + println('提升: ${speedup:.2f}x') +} + +fn main() { + println('HTTP 解析优化测试') + println('=' .repeat(50)) + + test_correctness() + benchmark_performance() + test_keepalive_optimization() + + println('\n' + '=' .repeat(50)) + println('测试完成!') +} diff --git a/usockets_server.v b/usockets_server.v index 57194e2..4ecb38e 100644 --- a/usockets_server.v +++ b/usockets_server.v @@ -169,57 +169,119 @@ fn usockets_on_end(s usockets.Socket) usockets.Socket { return s.close() } -// 解析 HTTP 请求 +// 解析 HTTP 请求 - 零分配优化版 +// 使用指针遍历避免创建临时数组 fn parse_http_request_usockets(raw string) (string, string, map[string]string, string) { mut method := '' mut path := '' mut query_map := map[string]string{} mut body := '' - - line_end := raw.index('\r\n') or { return method, path, query_map, body } - request_line := raw[..line_end] - - parts := request_line.split(' ') - if parts.len < 2 { + + len := raw.len + if len == 0 { return method, path, query_map, body } - - method = parts[0] - full_path := parts[1] - - if query_idx := full_path.index('?') { - path = full_path[..query_idx] - query_str := full_path[query_idx + 1..] - for part in query_str.split('&') { - if eq_idx := part.index('=') { - query_map[part[..eq_idx]] = part[eq_idx + 1..] - } + + // 1. 查找第一行结束位置(\r\n) + mut line_end := -1 + for i in 0 .. len - 1 { + if raw[i] == `\r` && raw[i + 1] == `\n` { + line_end = i + break } + } + if line_end == -1 { + return method, path, query_map, body + } + + // 2. 解析 method(到第一个空格) + mut method_end := 0 + for method_end < line_end && raw[method_end] != ` ` { + method_end++ + } + if method_end == 0 || method_end >= line_end { + return method, path, query_map, body + } + method = raw[..method_end] + + // 3. 解析 path 和 query(从空格后到下一个空格) + mut path_start := method_end + 1 + // 跳过多余空格 + for path_start < line_end && raw[path_start] == ` ` { + path_start++ + } + + mut path_end := path_start + mut query_start := -1 + for path_end < line_end && raw[path_end] != ` ` { + if raw[path_end] == `?` && query_start == -1 { + query_start = path_end + 1 + } + path_end++ + } + + if query_start > 0 { + path = raw[path_start..query_start - 1] + // 解析 query string(单次遍历) + query_map = parse_query_string_fast(raw, query_start, path_end) } else { - path = full_path + path = raw[path_start..path_end] } - - if body_start := raw.index('\r\n\r\n') { - body = raw[body_start + 4..] + + // 4. 查找 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 { + body = raw[i + 4..] + } + break + } } - + return method, path, query_map, body } -// 创建 uSockets 上下文 +// 快速解析 query string(单次遍历,避免 split) +@[inline] +fn parse_query_string_fast(raw string, start int, end int) map[string]string { + mut query_map := map[string]string{} + + mut key_start := start + mut key_end := -1 + mut value_start := -1 + + for i := start; i <= end; i++ { + ch := if i < end { raw[i] } else { `&` } // 末尾视为分隔符 + + if ch == `=` && key_end == -1 { + key_end = i + value_start = i + 1 + } else if ch == `&` { + // 完成一个键值对 + if key_end > key_start && value_start > 0 { + key := raw[key_start..key_end] + value := if value_start < i { raw[value_start..i] } else { '' } + query_map[key] = value + } else if key_end == -1 && i > key_start { + // 只有 key 没有 value + key := raw[key_start..i] + query_map[key] = '' + } + // 重置状态 + key_start = i + 1 + key_end = -1 + value_start = -1 + } + } + + return query_map +} + +// 创建 uSockets 上下文 - 优化版 fn create_usockets_context(method string, path string, params map[string]string, query map[string]string, body string) Context { return Context{ req: http.Request{ - method: match method { - 'GET' { http.Method.get } - 'POST' { http.Method.post } - 'PUT' { http.Method.put } - 'DELETE' { http.Method.delete } - 'PATCH' { http.Method.patch } - 'HEAD' { http.Method.head } - 'OPTIONS' { http.Method.options } - else { http.Method.get } - } + method: parse_http_method_usockets(method) url: path data: body } @@ -233,6 +295,38 @@ fn create_usockets_context(method string, path string, params map[string]string, } } +// 快速 HTTP 方法解析(基于首字符和长度) +@[inline] +fn parse_http_method_usockets(method string) http.Method { + len := method.len + if len == 0 { + return http.Method.get + } + + // 基于首字符快速分支 + match method[0] { + `G` { + if len == 3 { return http.Method.get } + } + `P` { + if len == 4 && method[1] == `O` { return http.Method.post } + if len == 3 && method[1] == `U` { return http.Method.put } + if len == 5 { return http.Method.patch } + } + `D` { + if len == 6 { return http.Method.delete } + } + `H` { + if len == 4 { return http.Method.head } + } + `O` { + if len == 7 { return http.Method.options } + } + else {} + } + return http.Method.get +} + // 获取路径对应的所有中间件(优化版:使用预排序的前缀列表) fn get_middlewares_for_path_usockets_optimized(app &Hono, path string) []ContextMiddleware { // 优化2:只有全局中间件时,直接返回引用(避免克隆) @@ -270,7 +364,7 @@ fn exec_middlewares_usockets(idx int, middlewares []ContextMiddleware, mut ctx C return handler.handle(mut ctx) } -// 发送 uSockets 响应 +// 发送 uSockets 响应 - 优化版 fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response) { status_code := if ctx.status_code != 0 { ctx.status_code } else { response.status_code } @@ -286,20 +380,22 @@ fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response // 头部 mut has_content_type := false for key, value in ctx.headers { - if key.to_lower() == 'content-length' { + // 使用快速大小写不敏感比较 + key_len := key.len + if key_len == 14 && eq_ignore_case_usockets(key, 'content-length') { continue } resp.write_string(key) resp.write_string(': ') resp.write_string(value) resp.write_string('\r\n') - if key.to_lower() == 'content-type' { + if key_len == 12 && eq_ignore_case_usockets(key, 'content-type') { has_content_type = true } } - if content_type := response.header.get(.content_type) { - if !has_content_type { + if !has_content_type { + if content_type := response.header.get(.content_type) { resp.write_string('Content-Type: ') resp.write_string(content_type) resp.write_string('\r\n') @@ -326,6 +422,25 @@ fn send_usockets_response(s usockets.Socket, ctx Context, response http.Response s.write_bytes(resp.str()) } +// 大小写不敏感字符串比较(避免分配) +@[inline] +fn eq_ignore_case_usockets(a string, b string) bool { + if a.len != b.len { + return false + } + for i in 0 .. a.len { + ca := a[i] + cb := b[i] + // 转换为小写比较 + la := if ca >= `A` && ca <= `Z` { ca + 32 } else { ca } + lb := if cb >= `A` && cb <= `Z` { cb + 32 } else { cb } + if la != lb { + return false + } + } + return true +} + // 获取状态码文本 fn get_status_text_usockets(code int) string { return match code {