actix-web整合async-graphql、sqlx、actix-session报Send trait错误如何解决

错误根源 #

你遇到的编译错误核心原因是：

• actix_http::error::Result 对应的错误类型 actix_http::error::Error 内部包装了 dyn actix_web::ResponseError，在你使用的actix-http 2.x版本中，这个 trait 对象没有实现 Send 约束
• async-graphql 要求所有 Resolver 返回的 Future 必须满足 Send 约束，才能被异步调度器跨线程执行
• 去掉sqlx代码后错误消失，是因为此时没有触发跨线程调度的Send校验，一旦引入sqlx的跨线程异步查询逻辑，整个Future的Send约束就不满足，触发编译错误

修复步骤 #

1. 替换Resolver返回值类型：不要使用actix体系的Result，直接使用async-graphql自带的async_graphql::Result<T>，其内部错误类型天然满足Send约束
2. 所有错误统一转换为async-graphql的Error类型：不需要使用anyhow或者actix的错误转换逻辑，直接构造GraphQL的标准错误即可
3. 补全User结构体的GraphQL序列化实现：作为Resolver返回的输出对象，需要派生SimpleObject trait才能被async-graphql正确序列化

修改后核心代码 #

User结构体定义 #

// 派生SimpleObject即可直接作为GraphQL输出对象
#[derive(SimpleObject, Debug)]
struct User {
    id: i32,
    username: String,
    // 其余字段保持不变
}

Resolver方法修改 #

#[Object]
impl UserQuery {
    // 返回值替换为async_graphql::Result，导入async_graphql::*后可直接写Result<User>
    async fn me(&self, ctx: &Context<'_>) -> Result<User> {
        let actix_session = ctx.data_unchecked::<Shared<actix_session::Session>>();
        // session读取错误直接转GraphQL错误
        let user_id = actix_session.get::<i32>("user_id")
            .map_err(|e| Error::new(format!("session读取失败: {}", e)))?;

        if let Some(id) = user_id {
            let pool = ctx.data_unchecked::<DbPool>();
            // sqlx查询错误转GraphQL错误
            let user = sqlx::query_as!(User, "SELECT * FROM users WHERE id = $1", id)
                .fetch_one(pool)
                .await
                .map_err(|e| Error::new(format!("用户查询失败: {}", e)))?;
            return Ok(user);
        } else {
            // 未登录直接返回自定义错误
            return Err(Error::new("当前用户未登录"));
        }
    }
}

其余的Shared包装器、GraphQL请求入口逻辑不需要修改，改完即可正常编译运行。

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