{"topic":{"id":14521,"title":"Rust async 疑问","slug":"topic","categoryId":14,"createdAt":"2025-04-28 14:53:34.536214","bumpedAt":"2025-04-29 02:43:36.501588","views":196,"postsCount":7,"highestPostNumber":7,"likeCount":3,"closed":false,"pinned":false,"pinnedGlobally":false,"pinnedAt":null,"pinnedUntil":null,"isBanner":false,"excerpt":"use actix_web::{ dev::ServiceRequest, error::ErrorUnauthorized, App, Error as ActixError, HttpServer, }; use actix_web_httpauth::extractors::basic::BasicAuth; use std::io; use std::time::Duration; use tokio::sync::onesho…","deletedAt":null,"isAnonymous":false,"category":{"id":14,"name":"问答","slug":"qa","color":"f5c211"},"author":{"id":4668,"username":"IO","name":null,"avatarUrl":"/uploads/image/86/f2/86f267c0aaa73835a999b7cc3a7e7a701605574eda9a2c2a56f5ddbbba64d1a9.avif"},"tags":[]},"posts":[{"id":50026,"postNumber":1,"raw":"```rs\nuse actix_web::{\n dev::ServiceRequest, error::ErrorUnauthorized, App, Error as ActixError,\n HttpServer,\n};\nuse actix_web_httpauth::extractors::basic::BasicAuth;\nuse std::io;\nuse std::time::Duration;\nuse tokio::sync::oneshot;\n\nasync fn do_auth(\n req: ServiceRequest,\n creds: BasicAuth,\n) -> Result {\n if creds.user_id() == \"user\" && creds.password() == Some(\"22222222222222222222\") {\n Ok(req)\n } else {\n Err((ErrorUnauthorized(\"not authorized\"), req))\n }\n}\n\nasync fn process(socket: tokio::net::TcpStream) {\n // Process the socket connection\n tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;\n println!(\"Processing socket connection\");\n}\n\n#[tokio::main(flavor = \"current_thread\")]\nasync fn main() -> io::Result<()> {\n {\n let (tx, rx) = oneshot::channel();\n\n tokio::spawn(async move {\n tokio::time::sleep(Duration::from_secs(2)).await;\n tx.send(()).unwrap();\n });\n\n let server = HttpServer::new(|| {\n App::new()\n // .wrap(HttpAuthentication::basic(do_auth))\n .service(\n actix_files::Files::new(\"/\", \"/storage/emulated/0/\")\n .show_files_listing()\n .use_hidden_files(),\n )\n })\n .shutdown_timeout(1)\n .bind((\"0.0.0.0\", 4804))\n .unwrap()\n .run();\n let server_handle = server.handle();\n\n tokio::select! {\n _ = async {\n server.await.unwrap();\n // Help the rust type inferencer out\n Ok::<_,std::io::Error>(())\n } => {}\n _ = rx => {\n println!(\"terminating accept loop\");\n server_handle.stop(false).await;\n }\n }\n }\n\n println!(\"sleeping\");\n tokio::time::sleep(tokio::time::Duration::from_secs(3)).await;\n println!(\"exiting\");\n Ok(())\n}\n\n```\n\n```\n[package]\nname = \"tmptokio\"\nversion = \"0.1.0\"\nedition = \"2024\"\n\n[dependencies]\ntokio = { version = \"1\", features = [\"full\"] }\nactix-files = \"0.6.6\"\nactix-web = { version = \"4\", features = [\"macros\", \"compress-brotli\", \"compress-gzip\", \"compress-zstd\"], default-features = false }\nactix-web-httpauth = \"0.8\"\n```\n\n为啥 `server_handle.stop(false).await;` 不起作用呢？\n\n在 print sleep 之后，http server 还在运行\n有没有 Rust 高手帮看下，谢谢🙏","cooked":"

use actix_web::{\n    dev::ServiceRequest, error::ErrorUnauthorized, App, Error as ActixError,\n    HttpServer,\n};\nuse actix_web_httpauth::extractors::basic::BasicAuth;\nuse std::io;\nuse std::time::Duration;\nuse tokio::sync::oneshot;\n\nasync fn do_auth(\n    req: ServiceRequest,\n    creds: BasicAuth,\n) -> Result<ServiceRequest, (ActixError, ServiceRequest)> {\n    if creds.user_id() == \"user\" && creds.password() == Some(\"22222222222222222222\") {\n        Ok(req)\n    } else {\n        Err((ErrorUnauthorized(\"not authorized\"), req))\n    }\n}\n\nasync fn process(socket: tokio::net::TcpStream) {\n    // Process the socket connection\n    tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;\n    println!(\"Processing socket connection\");\n}\n\n#[tokio::main(flavor = \"current_thread\")]\nasync fn main() -> io::Result<()> {\n    {\n        let (tx, rx) = oneshot::channel();\n\n        tokio::spawn(async move {\n            tokio::time::sleep(Duration::from_secs(2)).await;\n            tx.send(()).unwrap();\n        });\n\n        let server = HttpServer::new(|| {\n            App::new()\n                // .wrap(HttpAuthentication::basic(do_auth))\n                .service(\n                    actix_files::Files::new(\"/\", \"/storage/emulated/0/\")\n                        .show_files_listing()\n                        .use_hidden_files(),\n                )\n        })\n        .shutdown_timeout(1)\n        .bind((\"0.0.0.0\", 4804))\n        .unwrap()\n        .run();\n        let server_handle = server.handle();\n\n        tokio::select! {\n                _ = async {\n                    server.await.unwrap();\n                    // Help the rust type inferencer out\n                    Ok::<_,std::io::Error>(())\n                } => {}\n            _ = rx => {\n                println!(\"terminating accept loop\");\n                server_handle.stop(false).await;\n            }\n        }\n    }\n\n    println!(\"sleeping\");\n    tokio::time::sleep(tokio::time::Duration::from_secs(3)).await;\n    println!(\"exiting\");\n    Ok(())\n}\n\n

[package]\nname = \"tmptokio\"\nversion = \"0.1.0\"\nedition = \"2024\"\n\n[dependencies]\ntokio = { version = \"1\", features = [\"full\"] }\nactix-files = \"0.6.6\"\nactix-web = { version = \"4\", features = [\"macros\", \"compress-brotli\", \"compress-gzip\", \"compress-zstd\"], default-features = false }\nactix-web-httpauth = \"0.8\"\n

为啥 server_handle.stop(false).await; 不起作用呢？

在 print sleep 之后，http server 还在运行
\n有没有 Rust 高手帮看下，谢谢🙏

\n","createdAt":"2025-04-28 14:53:34.6213","updatedAt":"2025-04-29 13:05:21.73539","replyToPostNumber":null,"replyCount":0,"likeCount":1,"wordCount":224,"liked":false,"bookmarked":false,"polls":[],"reactions":[{"reaction":"❤️","count":1,"users":[{"id":7137,"username":"emu_otori","name":"鳳笑夢"}],"hasReacted":false}],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":4668,"username":"IO","name":null,"avatarUrl":"/uploads/image/86/f2/86f267c0aaa73835a999b7cc3a7e7a701605574eda9a2c2a56f5ddbbba64d1a9.avif","admin":true,"moderator":false,"signatureRaw":"","signatureCooked":null}},{"id":50030,"postNumber":2,"raw":"![image|690x281](/uploads/image/03/41/03414e35fa95e6dc67ebdd1d000126c367189fbaf4cf7bf43d6cdaab4c3bca21.avif)\n\n这是期望结果吗","cooked":"

$\"image\"$

这是期望结果吗

\n","createdAt":"2025-04-28 15:23:46.757946","updatedAt":"2025-04-28 15:23:46.757946","replyToPostNumber":null,"replyCount":1,"likeCount":0,"wordCount":8,"liked":false,"bookmarked":false,"polls":[],"reactions":[],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":7137,"username":"emu_otori","name":"鳳笑夢","avatarUrl":"/uploads/image/0b/13/0b133abcd3dfadb90fdbf7583cfdc31ec56db3dbd063fce95dbe0f09296b527a.avif","admin":false,"moderator":true,"signatureRaw":null,"signatureCooked":null}},{"id":50031,"postNumber":3,"raw":"这段代码编译无问题，只看输出不够，netstat 看端口是否还在监听或 curl 看看，sleep 后 exit 前 server 依然还在","cooked":"

这段代码编译无问题，只看输出不够，netstat 看端口是否还在监听或 curl 看看，sleep 后 exit 前 server 依然还在

\n","createdAt":"2025-04-28 15:26:46.24495","updatedAt":"2025-04-28 15:27:47.514209","replyToPostNumber":2,"replyCount":1,"likeCount":0,"wordCount":39,"liked":false,"bookmarked":false,"polls":[],"reactions":[],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":4668,"username":"IO","name":null,"avatarUrl":"/uploads/image/86/f2/86f267c0aaa73835a999b7cc3a7e7a701605574eda9a2c2a56f5ddbbba64d1a9.avif","admin":true,"moderator":false,"signatureRaw":"","signatureCooked":null}},{"id":50032,"postNumber":4,"raw":"这，运行几秒后已经自动退出了，怎么可能还在监听\n\ntokio select 阻塞住两秒，然后收到 oneshot signal 打印 `terminating accept loop` 并停止服务器。然后打印 `sleeping` 并睡眠三秒，再打印 `exiting`。\n\n出现 `sleeping` 前服务器一定已经停止了，因为顺序执行的","cooked":"

这，运行几秒后已经自动退出了，怎么可能还在监听

tokio select 阻塞住两秒，然后收到 oneshot signal 打印 terminating accept loop 并停止服务器。然后打印 sleeping 并睡眠三秒，再打印 exiting。

出现 sleeping 前服务器一定已经停止了，因为顺序执行的

\n","createdAt":"2025-04-28 15:27:22.070746","updatedAt":"2025-04-28 15:40:06.395219","replyToPostNumber":3,"replyCount":1,"likeCount":0,"wordCount":86,"liked":false,"bookmarked":false,"polls":[],"reactions":[],"wiki":false,"version":2,"publicVersion":2,"deletedAt":null,"isAnonymous":false,"user":{"id":7137,"username":"emu_otori","name":"鳳笑夢","avatarUrl":"/uploads/image/0b/13/0b133abcd3dfadb90fdbf7583cfdc31ec56db3dbd063fce95dbe0f09296b527a.avif","admin":false,"moderator":true,"signatureRaw":null,"signatureCooked":null}},{"id":50034,"postNumber":5,"raw":"curl 看看哦，和预想的不一样","cooked":"

curl 看看哦，和预想的不一样

\n","createdAt":"2025-04-28 15:41:02.778946","updatedAt":"2025-04-28 15:41:02.778946","replyToPostNumber":4,"replyCount":1,"likeCount":0,"wordCount":12,"liked":false,"bookmarked":false,"polls":[],"reactions":[],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":4668,"username":"IO","name":null,"avatarUrl":"/uploads/image/86/f2/86f267c0aaa73835a999b7cc3a7e7a701605574eda9a2c2a56f5ddbbba64d1a9.avif","admin":true,"moderator":false,"signatureRaw":"","signatureCooked":null}},{"id":50035,"postNumber":6,"raw":"sleeping 前面的大括号结束的时候 server 应该已经被 drop 掉了，但还能继续响应请求，说明应该不是 await 的问题。","cooked":"

sleeping 前面的大括号结束的时候 server 应该已经被 drop 掉了，但还能继续响应请求，说明应该不是 await 的问题。

\n","createdAt":"2025-04-28 16:45:22.466959","updatedAt":"2025-04-28 16:45:22.466959","replyToPostNumber":5,"replyCount":0,"likeCount":0,"wordCount":43,"liked":false,"bookmarked":false,"polls":[],"reactions":[],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":7137,"username":"emu_otori","name":"鳳笑夢","avatarUrl":"/uploads/image/0b/13/0b133abcd3dfadb90fdbf7583cfdc31ec56db3dbd063fce95dbe0f09296b527a.avif","admin":false,"moderator":true,"signatureRaw":null,"signatureCooked":null}},{"id":50045,"postNumber":7,"raw":"单纯 actix 的 bug 参见 [issue](https://github.com/actix/actix-web/issues/2759)","cooked":"

单纯 actix 的 bug 参见 issue

\n","createdAt":"2025-04-29 02:43:36.501588","updatedAt":"2025-04-29 02:43:36.501588","replyToPostNumber":null,"replyCount":0,"likeCount":2,"wordCount":8,"liked":false,"bookmarked":false,"polls":[],"reactions":[{"reaction":"❤️","count":2,"users":[{"id":4668,"username":"IO","name":null},{"id":7137,"username":"emu_otori","name":"鳳笑夢"}],"hasReacted":false}],"wiki":false,"version":1,"publicVersion":1,"deletedAt":null,"isAnonymous":false,"user":{"id":6529,"username":"mo","name":"dude","avatarUrl":"/uploads/image/e1/fc/e1fca535ca0b5ffb99fd206d4b415e550c383ab98fffcc263e3a6c32bf75cb93.avif","admin":false,"moderator":false,"signatureRaw":null,"signatureCooked":null}}],"hasMore":false,"lastReadPostNumber":1,"hasUrlPostNumber":false}