2

所以我想在 actix API 中使用 tokio_postgres，我刚开始，在我的获取请求中共享客户端时遇到了困难。这是我的代码：

use actix_web::{web, App, HttpServer, HttpResponse};
use tokio_postgres::{NoTls};
use std::cell::RefCell;

mod api;

use api::routes::hello_actix;

fn main() {
    actix_rt::System::run(|| {
        println!("connecting to postgres");
        let pro = tokio::spawn(
            async
            {
                let (client , conn) = match tokio_postgres::connect(
                    "foo",
                    NoTls)
                    .await {
                    Ok(t) => t,
                    Err(e) => panic!("{}", e)
                };

                tokio::spawn(async move {
                    if let Err(e) = conn.await {
                        eprintln!("connection error: {}", e);
                    }
                });

                println!("connected to postgres");
                HttpServer::new(|| {
                    App::new()
                        .data(RefCell::new(conn))
                        .route("/hello", web::get().to(hello_actix))
                        .default_service(web::route().to(|| HttpResponse::NotFound().body("404 Not Found")))
                })
                    .bind("127.0.0.1:8080")
                    .unwrap()
                    .run();
                Ok(())
            });

    });
}

我将此代码基于此，但它似乎不起作用。

我也想保持“纯粹”，所以如果可能的话，我不想拥有一个全球客户。甚至可以做我想做的事吗？

4

0 回答 0