RocketでTokio CoreとHyper Clientを再利用することはできますか？

Question

私はロケットで処理しているユーザーからの要求を受け取り、可能な限り少数のリソースを使用した後、Hyper 0.11でクライアント要求を行いたいと考えています。 CoreまたはClientを再利用できない場合は、Rocketがリクエストを発するたびに作成する必要があります。高性能な環境では、サーバーが要求に応答するたびにCoreとClientを作成するには、リソースが多すぎます。私はStateを使ってオブジェクトをすべての '点火'に利用できるようにしています。 Hyper 0.10.13では動作しますが、TokioのHyper 0.11では大量のエラーメッセージが表示されています。

Cargo.toml：

rocket = "0.3.3" 
rocket_codegen = "0.3.3" 
hyper = "0.11" 
futures = "0.1" 
tokio-core = "0.1" 

main.rs

#![feature(plugin, decl_macro)] 
#![plugin(rocket_codegen)] 
extern crate futures; 
extern crate hyper; 
extern crate rocket; 
extern crate tokio_core; 
use rocket::State; 
use hyper::*; 
use hyper::header::{ContentLength, ContentType}; 
use futures::{Future, Stream}; 
use tokio_core::reactor::Core; 

fn main() { 
    let mut core = Core::new().unwrap(); 
    let client = Client::new(&core.handle()); 
    rocket::ignite() 
     .mount("/", routes![index]) 
     .manage(client.clone()) 
     .launch(); 
} 

#[post("/", data = "<var>")] 
fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
    let json = r#"{"library":"hyper"}"#; 
    let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
    let mut req = Request::new(Method::Post, uri); 
    req.headers_mut().set(ContentType::json()); 
    req.headers_mut().set(ContentLength(json.len() as u64)); 
    req.set_body(json); 
    let post = client.request(req).and_then(|res| { 
     //println!("POST: {}", res.status()); 
     res.body().concat2() 
    }); 
} 

私はのようなエラーメッセージを取得しています：

error[E0277]: the trait bound `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>: std::marker::Send` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>` cannot be sent between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Send` is not implemented for `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>` 
    = note: required because it appears within the type `tokio_core::reactor::Handle` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

error[E0277]: the trait bound `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>: std::marker::Sync` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>` cannot be shared between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Sync` is not implemented for `std::rc::Weak<std::cell::RefCell<tokio_core::reactor::Inner>>` 
    = note: required because it appears within the type `tokio_core::reactor::Handle` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

error[E0277]: the trait bound `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>: std::marker::Send` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>` cannot be sent between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Send` is not implemented for `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>` 
    = note: required because it appears within the type `hyper::client::pool::Pool<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>` 
    = note: required because it appears within the type `hyper::client::Dispatch<hyper::Body>` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

error[E0277]: the trait bound `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>: std::marker::Send` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>` cannot be sent between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Send` is not implemented for `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>` 
    = note: required because it appears within the type `hyper::client::pool::Pool<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>` 
    = note: required because it appears within the type `hyper::client::Dispatch<hyper::Body>` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

error[E0277]: the trait bound `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>: std::marker::Sync` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>` cannot be shared between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Sync` is not implemented for `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>>>` 
    = note: required because it appears within the type `hyper::client::pool::Pool<tokio_proto::util::client_proxy::ClientProxy<tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RequestLine>, hyper::Body>, tokio_proto::streaming::message::Message<hyper::proto::MessageHead<hyper::proto::RawStatus>, tokio_proto::streaming::body::Body<hyper::Chunk, hyper::Error>>, hyper::Error>>` 
    = note: required because it appears within the type `hyper::client::Dispatch<hyper::Body>` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

error[E0277]: the trait bound `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>: std::marker::Sync` is not satisfied in `hyper::Client<tokio_core::reactor::Handle>` 
    --> src/main.rs:23:1 
    | 
23 |/fn index(var: String, client: State<hyper::Client<tokio_core::reactor::Handle>>) -> &'static str { 
24 | |  let json = r#"{"library":"hyper"}"#; 
25 | |  let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
26 | |  let mut req = Request::new(Method::Post, uri); 
... | 
33 | |  }); 
34 | | } 
    | |_^ `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>` cannot be shared between threads safely 
    | 
    = help: within `hyper::Client<tokio_core::reactor::Handle>`, the trait `std::marker::Sync` is not implemented for `std::rc::Rc<std::cell::RefCell<hyper::client::pool::PoolInner<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>>>` 
    = note: required because it appears within the type `hyper::client::pool::Pool<std::cell::RefCell<futures::sync::mpsc::Sender<(hyper::proto::MessageHead<hyper::proto::RequestLine>, std::option::Option<hyper::Body>, futures::Sender<std::result::Result<hyper::Response, hyper::Error>>)>>>` 
    = note: required because it appears within the type `hyper::client::Dispatch<hyper::Body>` 
    = note: required because it appears within the type `hyper::Client<tokio_core::reactor::Handle>` 
    = note: required by `rocket::State` 

私の状態に何か問題はありますか？答えに多大な努力を払わないでください。あなたが正しい方向で私を指すことができるなら、私は自分で働くことができます。もう1つの解決方法は、別のセットアップでこれを解決する方法も非常に歓迎です。

Answer 1

いいえ、スレッド間でhyper::Clientを共有することはできません。しかし、あなたがtokio_core Remoteを共有することができます。

#![feature(plugin, decl_macro)] 
#![plugin(rocket_codegen)] 
extern crate futures; 
extern crate hyper; 
extern crate rocket; 
extern crate tokio_core; 

use rocket::State; 
use futures::{Future, Stream}; 
use tokio_core::reactor::Core; 

fn main() { 
    let core = Core::new().unwrap(); 
    rocket::ignite() 
     .mount("/", routes![index]) 
     .manage(core.remote()) 
     .launch(); 
} 

#[post("/", data = "<var>")] 
fn index(var: String, remote: State<tokio_core::reactor::Remote>) -> String { 
    remote.spawn(|handle| { 
     use hyper::{Client, Request, Method}; 
     use hyper::header::{ContentLength, ContentType}; 

     let client = Client::new(handle); 

     let json = r#"{"library":"hyper"}"#; 
     let uri = "http://xxx.xxx.xxx.xxx".parse().unwrap(); 
     let mut req = Request::new(Method::Post, uri); 
     req.headers_mut().set(ContentType::json()); 
     req.headers_mut().set(ContentLength(json.len() as u64)); 
     req.set_body(json); 

     client.request(req) 
      .and_then(|res| res.body().concat2()) 
      .map(|_|()) 
      .map_err(|_|()) 
    }); 

    var 
} 

をその後の質問は、あなたの他の主張に変わり：

私は彼らにロケットが要求を点火するたびに作成する必要があります。これは、高性能環境ではあまりにも多くのリソースを必要とするでしょう

私はあなたがそのような決定に基づいているかどうか分かりません。 Constructing a Client doesn't do much。