1

我正在使用actix 框架来构建一个服务器，该服务器应该支持向给定的用户显示年龄/平衡的机会user_id：

fn show_balance(req: &HttpRequest) -> HttpResponse {
    let client = create_client();
    let user_id = req.match_info().get("user_id").unwrap();
    let balance = client.load_grade(user_id); // Returns a balance as a String
    HttpResponse::Ok()
        .content_type("text/plain")
        .body(format!("Hello! Your balance is {}", balance))
}

fn show_age(req: &HttpRequest) -> HttpResponse {
    let client = create_client();
    let user_id = req.match_info().get("user_id").unwrap();
    let age = client.load_grade(user_id); // Returns an age as a String
    HttpResponse::Ok()
        .content_type("text/plain")
        .body(format!("Hello! Your balance is {}", age))
}

fn main() {
    env::set_var("RUST_LOG", "actix_web=debug");
    env::set_var("RUST_BACKTRACE", "1");
    env_logger::init();
    let sys = actix::System::new("basic-example");

    let addr = server::new(
        || App::new()
            // enable logger
            .middleware(middleware::Logger::default())
            .resource("/balance/{user_id}", |r| r.method(Method::GET).f(show_balance))
            .resource("/age/{user_id}", |r| r.method(Method::GET).f(show_age))
        .bind("127.0.0.1:8080").expect("Can not bind to 127.0.0.1:8080")
        .start();

    println!("Starting http server: 127.0.0.1:8080");
    let _ = sys.run();
}

fn create_client() -> UserDataClient {
    let enviroment = grpcio::EnvBuilder::new().build();
    let channel = grpcio::ChannelBuilder::new(enviroment)
        .connect(API_URL);
    UserDataClient::new(channel)
}

这段代码有效，但我担心我必须为每个低效且可读的传入请求创建一个客户端（并打开一个通道），我认为制作一个单例是个好主意（因为我可以重用它）。我查看了示例文件夹，发现todo 示例与我正在做的有点相似。所以我找到了以下两个选项来注入我的client对象（在我创建它的单个实例之后main()：

  1. 将其置于应用状态
  2. 将其作为中间件 ( 1 , 2 ) 注入？

什么是最好的/正确的实施？

我想过只是将一个客户端对象作为参数传递给每个处理程序，但我没有设法让它工作（而且看起来并不好）。

4

0 回答 0