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

Question

Я пытаюсь написать конечную точку 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()
}

Вот мой груз.томл.

[package]
name = "log"
version = "0.1.0"
authors = ["[e-mail]"
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?

Answer 1

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