Rust Actix集成scylla-rust-driver时Session无Clone trait报错如何解决

错误原因 #

Actix Web 的 HttpServer 默认会启动等于CPU核心数的worker线程，传入HttpServer::new的闭包会在每个worker初始化时执行一次，因此该闭包需要支持重复调用，其捕获的所有外部变量必须实现Clone trait。而scylla-rust-driver的Session类型默认没有实现Clone，直接将其move进闭包就会触发编译错误。

解决方案 #

用线程安全的引用计数指针Arc包装Session，Arc实现了Clone trait，克隆时仅增加引用计数，无额外性能开销，可安全在多个worker线程间共享Session实例。

完整修改代码 #

1. 调整AppState定义

use std::sync::Arc;
use scylla::Session;
use actix_web::web;

struct AppState {
    scy_session: Arc<Session>,
    app_name: String,
}

2. 调整接口处理函数（含CRUD调用示例）

#[get("/")] 
async fn index(data: web::Data<AppState>) -> String {
    let app_name = &data.app_name;
    // 直接通过Arc调用Session的查询方法即可
    let query_res = data.scy_session
        .query("SELECT * FROM your_keyspace.your_table LIMIT 10", &[])
        .await;
    
    match query_res {
        Ok(rows) => format!("Hello {}! 查询到{}条数据", app_name, rows.rows.unwrap_or_default().len()),
        Err(e) => format!("查询失败: {}", e)
    }
}

3. 调整main函数逻辑

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    let session: Session = SessionBuilder::new()
        .known_node("localhost:9042")
        .user("username", "password")
        .build()
        .await
        .expect("ScyllaDB连接初始化失败");
    
    // 用Arc包装Session供多线程共享
    let shared_session = Arc::new(session);

    HttpServer::new(move || {
        // 每个worker初始化时克隆Arc，仅增加引用计数
        let session_clone = shared_session.clone();
        App::new()
            .data(AppState {
                scy_session: session_clone,
                app_name: String::from("Actix-web"),
            })
            .service(index)
    })
    .bind("127.0.0.1:8080")?
    .run()
    .await
}

如果你使用的是0.3.0及以上版本的scylla-rust-driver，Session本身已经实现了Clone trait，你也可以省略Arc包装，直接在闭包内clone Session实例即可，效果一致。

内容的提问来源于stack exchange，提问作者Pamungkas Jayuda