Я пытаюсь написать простое приложение для чтения файла конфигурации, а затем развернуть гиперреверсивный прокси для каждой записи в этом файле.
Я анализирую конфигурацию в цикле и хочу иметь возможность отслеживать каждый сервер, который я создал, возможно, в Vec. Я не могу понять, какого типа должен быть Vec, так как каждый сервер относится к разному типу. Я пробовал упаковать результат map_error и сохранить его, но ничего не добился. В гипер-примере на GitHub используются только статически созданные серверы.
Это упрощенная версия того, что я пытаюсь сделать:
use futures::future::{self, Future};
use hyper::service::{make_service_fn, service_fn};
use hyper::{Body, Request, Response, Server};
type BoxFut = Box<Future<Item = Response<Body>, Error = hyper::Error> + Send>;
fn debug_request(req: Request<Body>) -> BoxFut {
let body_str = format!("{:?}", req);
let response = Response::new(Body::from(body_str));
Box::new(future::ok(response))
}
fn main() {
// This is our socket address...
let local_address = ([127, 0, 0, 1], 9001).into();
// A `Service` is needed for every connection.
let make_svc = make_service_fn(|socket: &AddrStream| {
let remote_addr = socket.remote_addr();
service_fn(move |req: Request<Body>| {
// returns BoxFut
return hyper_reverse_proxy::call(remote_addr.ip(), "https://192.9.200.162:80", req);
})
});
let server = Box::new(
Server::bind(&local_address)
.serve(make_svc)
.map_err(|e| eprintln!("server error: {}", e)),
);
let server2 = Box::new(
Server::bind(&local_address)
.serve(make_svc)
.map_err(|e| eprintln!("server error: {}", e)),
);
let vec = vec![server, server2];
println!("Running server on {:?}", local_address);
// Run this server for... forever!
let all_servers = future::join_all(vec);
hyper::rt::run(all_servers);
}
vec не может удерживать оба сервера, поскольку они имеют разные типы, и я не уверен, как лучше всего сделать hyper::rt::run.
