Руст Токио |HTTP-запрос внутри обработчика actix-web -> Несколько исполнителей одновременно: EnterError - PullRequest
Новая
       74

Руст Токио |HTTP-запрос внутри обработчика actix-web -> Несколько исполнителей одновременно: EnterError

0 голосов
/ 17 июня 2019

При создании гиперпостового запроса внутри распознавателя actix-web выдается следующая ошибка - как отправить один http-запрос, порождая запрос в существующего исполнителя? 

thread 'actix-rt:worker:1' panicked at 'Multiple executors at once: EnterError { reason: "attempted to run an executor while another executor is already running" }', src/libcore/result.rs:999:5
note: Run with `RUST_BACKTRACE=1` environment variable to display a backtrace.
Panic in Arbiter thread, shutting down system.

main.rs 

extern crate actix_web;
extern crate serde_json;
extern crate actix_rt;
extern crate hyper;

use serde_json::{Value, json};
use hyper::{Client, Uri, Body, Request};
use actix_web::{middleware, web, App, HttpResponse, HttpServer};
use actix_rt::System;
use actix_web::client;
use futures::future::{Future, lazy};

fn main() {
    println!("Start server...");
    listen();
}

pub fn listen() -> std::io::Result<()> {
    HttpServer::new(|| {
        App::new()
            .wrap(middleware::Logger::default())
            .data(web::JsonConfig::default().limit(4096))
            .service(web::resource("/push").route(web::post().to(index)))
            .service(web::resource("/test").route(web::post().to(test)))
    })
    .bind("127.0.0.1:8080")?
    .run()
}


fn index(item: web::Json<Value>) -> HttpResponse {
    println!("model: {:?}", &item);
    send(json!({
        "hello": "world"
    }));

    HttpResponse::Ok().json(item.0) // <- send response
}

fn test(item: web::Json<Value>) -> HttpResponse {
    println!("recevied test call!");
    println!("{:?}", &item);

    HttpResponse::Ok().json(item.0) // <- send response
}



pub fn send(mut data: serde_json::Value) {
    println!("# Start running log post future...");

    // if the following line is removed, the call is not received by the test function above
    System::new("test").block_on(lazy(|| {
        let req = Request::builder()
            .method("POST")
            .uri("http://localhost:8080/test")
            .body(Body::from(data.to_string()))
            .expect("request builder");

        let client = Client::new();
        let future = client.request(req)
        .and_then(|res| {
            println!("status: {}", res.status());
            Ok(())
        })
        .map_err(|err| {
            println!("error: {}", err);
        });
        return future;
    }));

    println!("# Finish running log post future")
}

cargo.toml 

[package]
name = "rust-tokio-event-loop-madness"
version = "0.1.0"
authors = [""]
edition = "2018"

[dependencies]
serde_json = "1.0.39"
actix-web = "1.0.0"
serde_derive = "1.0.92"
actix-rt = "*"
hyper = "0.12.30"
futures = "*"

команда curl для вызова ошибки: 

curl -X POST -H 'Content-Type: application/json' -d '{"test":1}' http://localhost:8080/push

Репо с примером: https://github.com/fabifrank/rust-tokio-event-loop-madness

Ответы [ 2 ]

2 голосов
/ 20 июня 2019

Работаем с помощью функции tokio spawn, чтобы добавить будущее к исполнителю tokio.

Так что вместо: 

System::new("test").block_on(lazy(|| {

использование: 

spawn(lazy(move || {

и, конечно, добавьте tokio в качестве зависимости в cargo.toml и включите ящик.

1 голос
/ 24 июня 2019

Это потому, что actix-web использует Tokio начиная с версии 1.0.0. Как и в случае с Reqwest, вы получите две среды выполнения.

Один из лучших способов справиться с этим - переключиться на асинхронную версию как вашего обработчика, так и запроса reqwest. Процесс может быть немного сложным, но в конечном итоге он того стоит. Эта статья хорошо объясняет переход.

...