Rust使用lazy_static初始化SQLx MySQL连接无法跨线程安全传递

云原生阿岚

2026-8-29

问题根本原因

报错本质是两个问题叠加导致的：

旧版本sqlx（0.5.x及更早）的MySQL驱动在连接初始化阶段，认证逻辑、字符集缓存部分使用了非线程安全的Rc指针包裹内部状态，导致创建连接池的Future本身不满足Sync约束；而同期Postgres驱动内部全程使用Arc做线程安全封装，初始化Future天然满足Sync，所以换Postgres后能直接编译通过。
你选用的lazy_static+旧版async_once的全局异步初始化组合存在缺陷：lazy_static本身是为同步静态值设计的，旧版async_once对包装的Future的Send/Sync trait自动推导有漏洞，会把内部持有的连接池裸指针*const Pool<MySql>直接暴露在类型签名里，触发编译器对静态变量必须实现Sync的强制检查。

你看到的*const Pool<MySql>无法跨线程传递的提示，不是连接池本身不支持多线程访问——sqlx的连接池从第一个正式版开始就做了线程安全设计，完全可以跨线程共享，报错是初始化包装层的类型推导问题+旧版MySQL驱动的内部状态问题共同触发的。

正确实现方案

优先选Actix-web官方推荐的应用状态注入方案，完全避开全局静态变量的trait约束坑，也是生产环境最稳妥的写法：

先调整Cargo.toml依赖，用新版sqlx即可，不需要额外的异步静态库依赖：

[dependencies]
actix-web = "4"
sqlx = { version = "0.7", features = ["mysql", "runtime-tokio", "tls-rustls"] }
dotenv = "0.15"

在服务启动阶段先初始化连接池，再通过actix-web的app_data注入全局状态：

use actix_web::{web, App, HttpServer, Responder};
use sqlx::MySqlPool;

async fn test_handler(pool: web::Data<MySqlPool>) -> impl Responder {
    // 业务里直接拿pool用即可，和全局静态访问一样方便
    let count: (i64,) = sqlx::query_as("SELECT 1")
        .fetch_one(pool.get_ref())
        .await
        .unwrap();
    format!("query result: {}", count.0)
}

#[actix_web::main]
async fn main() -> std::io::Result<()> {
    // 加载环境变量
    dotenv::dotenv().ok();
    let db_url = std::env::var("DATABASE_URL").expect("DATABASE_URL not found in env");
    // 异步初始化连接池，此时已在tokio运行时上下文，不需要额外block_on
    let pool = MySqlPool::connect(&db_url)
        .await
        .expect("MySQL pool init failed");

    HttpServer::new(move || {
        App::new()
            .app_data(web::Data::new(pool.clone()))
            .route("/test", web::get().to(test_handler))
    })
    .bind(("0.0.0.0", 8080))?
    .run()
    .await
}

如果你一定要用全局静态连接池的写法，替换掉老旧的lazy_static+async_once组合，用生态标准的once_cell实现即可，注意把sqlx升级到0.6以上版本：

新增依赖：

once_cell = "1.19"

全局连接池定义：

use once_cell::sync::Lazy;
use sqlx::MySqlPool;

pub static DB_POOL: Lazy<MySqlPool> = Lazy::new(|| {
    dotenv::dotenv().ok();
    let db_url = std::env::var("DATABASE_URL").expect("DATABASE_URL not found");
    // 绑定当前运行时阻塞执行初始化逻辑
    tokio::runtime::Handle::current()
        .block_on(MySqlPool::connect(&db_url))
        .expect("MySQL pool init failed")
});

避坑提示

不要继续使用旧版async_once库，该库已经停止维护，trait推导的bug不会被修复，目前Rust生态全局静态初始化的事实标准是once_cell，后续Rust标准库的静态初始化功能也是基于once_cell的实现合并的。
如果使用静态连接池方案，注意要在actix运行时启动之后再第一次访问DB_POOL，否则会因为拿不到tokio句柄报运行时错误。
sqlx 0.6之后的版本已经修复了MySQL驱动初始化阶段的非Sync问题，只要依赖版本正确，不会再出现同类编译报错。

内容的提问来源于stack exchange，提问作者Abdelaziz Said