Ржавчина от actix-web-нити небезопасного движения - PullRequest
Новая
       33

Ржавчина от actix-web-нити небезопасного движения

3 голосов
/ 19 июня 2019

Я пытаюсь написать конечную точку HTTP, используя actix-web 1.0.Я сократил функцию так, чтобы она просто возвращала пользователя, который ей передан, но компилятор все еще выдает ошибку. 

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

Я думаю, что это как-то связано с использованием login_user в web::block, но по этой ошибке трудно сказать.Каков предпочтительный способ безопасного использования параметров запроса в Rust или actix?

1 Ответ

5 голосов
/ 25 июня 2019

Ну, во-первых, 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))));
}
...