- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在尝试使用 actix-web 1.0 编写 HTTP 端点。我已经缩减了函数,使其只返回传递给它的用户,但编译器仍然给出错误。
extern crate actix_web;
extern crate chrono;
extern crate futures;
extern crate listenfd;
#[macro_use]
extern crate serde_derive;
extern crate dotenv;
use actix_web::{error, web, App, Error, HttpResponse, HttpServer};
use futures::future::Future;
#[derive(Debug, Deserialize, Serialize)]
pub struct LoginUser {
pub username: String,
pub password: String,
}
pub fn login(
login_user: web::Json<LoginUser>,
) -> impl Future<Item = HttpResponse, Error = error::BlockingError<Error>> {
web::block(move || {
let login_user = login_user.into_inner();
let user = LoginUser {
username: login_user.username,
password: login_user.password,
};
Ok(HttpResponse::Ok().json(user))
})
}
pub fn router(cfg: &mut web::ServiceConfig) {
cfg.service(web::scope("/").service(web::resource("").route(web::get().to(login))));
}
fn main() -> std::io::Result<()> {
HttpServer::new(move || App::new().configure(router))
.bind("127.0.0.1:3000")?
.run()
}
这是我的 cargo.toml。
[package]
name = "log"
version = "0.1.0"
authors = ["me@example.com"
edition = "2018"
[dependencies]
actix-files = "~0.1"
actix-web = "~1.0"
chrono = { version = "0.4.6", features = ["serde"] }
listenfd = "0.3"
diesel = {version = "1.4.1", features = ["postgres", "uuid", "r2d2", "chrono"]}
dotenv = "0.13"
failure = "0.1"
futures = "0.1"
scrypt = "0.2.0"
serde_derive="1.0"
serde_json="1.0"
serde="1.0"
我遇到了编译错误
| web::block(move || {
| ^^^^^^^^^^ `(dyn std::any::Any + 'static)` cannot be sent between threads safely
我觉得和web::block
中使用了login_user
有关系,但是从错误中很难判断。在 Rust 或 actix 中安全地异步使用请求参数的首选方法是什么?
最佳答案
嗯,首先,HttpResponse
不执行 Send
.自 web::block()
在线程池上运行闭包,这是一个问题。所以你需要返回一个是 Send
的值来自 web::block
, 然后创建一个 HttpResponse
从那里-使用and_then()
例如。
其次,在您的路由器中您使用的是web::get().to(login)
.如果你想调用一个返回 Future
的函数, 那需要是 web::get().to_async(login)
.
三、闭包在web::block
需要返回Result
.由于您从不返回错误值,因此编译器无法推断错误类型。你需要给编译器一个提示。通常std::io::Error
会做,所以返回Ok::<_, std::io::Error>(...value...)
.
四、web::block
返回 BlockingError<E>
.您可以使用 from_err()
将其映射到您可以返回的内容。
因此,综上所述,您的代码的相关部分将如下所示:
pub fn login(
login_user: web::Json<LoginUser>,
) -> impl Future<Item = HttpResponse, Error = Error> {
web::block(move || {
let login_user = login_user.into_inner();
let user = LoginUser {
username: login_user.username,
password: login_user.password,
};
Ok::<_, std::io::Error>(user)
})
.from_err()
.and_then(|user| HttpResponse::Ok().json(user))
}
pub fn router(cfg: &mut web::ServiceConfig) {
cfg.service(web::scope("/").service(web::resource("").route(web::get().to_async(login))));
}
关于Rust actix-web 线程不安全移动,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56659643/
因此,我正在尝试创建一个基本的actix-web应用程序,该应用程序将允许我创建一个非常基本的博客系统。它正在处理我的GET请求,但没有处理我的POST请求。 main.rs: use actix_w
我对Rust还是很陌生,并且愿意为Actix-web中的Orange Pi Zero提供一些Linux服务,该服务将充当其他网络设备的“网关”(一些愚蠢的中文网络中继,具有4个输入和4个输出,这是受控
您好,我想传递以下 AppState。 pub struct AppState { clients: Vec, } 这就是我的服务器: async fn launch_server(app_c
我正在尝试为我的 Actix 应用程序编写身份验证中间件。在中间件中验证请求时,我调用数据库以检索必要的用户数据以验证传入的请求。一旦请求获得授权,我希望能够将此用户数据传递给处理程序,因为这将允许我
我只是在玩一些Actix网络和Actix Actor ,而我在构建一个简单的应用程序却花了毫秒的时间,所以我观察到Actix正在创建多个 Actor 。我只想限制它一个,但我做不到。 我在这里做错了什
主要功能是: #[actix_rt::main] async fn main() -> std::io::Result { std::env::set_var( "RUST_L
我想为 actix 中的查询值设置默认值。 我知道有一个Default Rust 标准库中结构的特征,但老实说,我不知道如何在这种情况下应用它。 在我的情况下,请求查询可能会也可能不会提供分页值页面和
我正在尝试运行两个应用程序(一个在端口 3006 上进行管理,另一个在端口 8080 上提供数据)。 他们共享数据库池、缓存... 对于actix 1.0,我有这个工作(我不知道这是否是最好的方法):
这是我第一次尝试使用 actix-web 编写带有 Rust 的小型 Web 服务。 下面的代码是一个请求处理程序,旨在做三件事,在数据库中插入一个条目,如果数据库调用成功则发送一封电子邮件,然后返回
我正在尝试使用 SyncArbiter 实现一个包含 10 个 Redis 连接的池,供不同的参与者使用。假设我们有一个名为 Bob 的 actor,它必须使用 Redis actor 来完成它的任务
我正在尝试创建具有 PyO3 Python 解释器和 Py 对象的 Actix Actor。 问题是创建 python 解释器 actor 的正确方法是什么? 我认为错误是由静态定义的 Actor 特
我正在使用 Actix-web 实现中间件,但遇到了一个我无法弄清楚的生命周期问题。 extern crate actix_web; use actix_web::actix::{Actor, Add
我正在尝试使用 actix-web 1.0 编写 HTTP 端点。我已经缩减了函数,使其只返回传递给它的用户,但编译器仍然给出错误。 extern crate actix_web; extern cr
问题 - 如果您只有一个系统但其中有多个仲裁器在运行,它仍然是一个单线程事件循环吗? 通读 Actix 书 - https://actix.rs/book/actix/sec-6-sync-arbit
我现在有以下服务器声明 let server = HttpServer::new(move || { App::new() .app_data(actix_web::web::
我在使用波纹管代码在actix-web上使用Stream时遇到问题: fn format_csv_row(row: tiberius::Row) -> Result { ... } #[get("/s
我试过 example of actix-multipart与 actix-web v3.3.2和 actix-multipart v0.3.0 . 举一个最小的例子, use actix_multi
在actix-web documentation is only an example如何接收唯一命名的查询参数。 但是我如何接收同名的多个查询参数呢?例如: http://localhost:808
我正在使用 sqlx 访问数据库的 actix-web 2.0.0 中实现身份验证提取器。我有这个代码: use actix_web::{dev, web, Error, HttpRequest, F
我有一个正在实现的 API,其中有一个需要调用的昂贵函数。我想记住这个函数或使用键值缓存来查找以前的结果。我也会考虑 Mutex或类似的结构,但我想避免诸如 Redis 或 Memcached 之类的
我是一名优秀的程序员,十分优秀!