如何在Rust Actix-Web 4中间件中返回未授权HTTP响应

错误原因分析 #

• 你当前为AuthMiddleware的Service实现定义了泛型参数B，要求返回的响应体必须和下游服务S的响应体类型完全一致，但你手动构造的HttpResponse::Unauthorized().finish()默认使用AnyBody类型，和泛型B没有关联，自然编译不通过。
• Actix 4对响应体的类型系统做了重构，不再像3.x版本那样兼容任意响应体转换，中间件如果需要提前返回自定义响应，不能绑定下游服务的响应体泛型，需要做兼容处理。

正确实现方式 #

第一步：调整Service实现的泛型约束和关联类型 #

把泛型约束改成允许下游服务返回任意实现了MessageBody的响应体，同时中间件自身返回的响应体统一用BoxBody（Actix 4官方推荐的通用擦除类型）：

use actix_web::body::{BoxBody, MessageBody};
use actix_web::dev::{Service, ServiceRequest, ServiceResponse};
use actix_web::{HttpResponse, Error};
use std::future::Future;
use std::pin::Pin;
use std::task::{Context, Poll};

impl<S, B> Service<ServiceRequest> for AuthMiddleware<S>
where
    S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error> + 'static,
    S::Future: 'static,
    B: MessageBody + 'static, // 仅约束下游响应体实现MessageBody即可
{
    // 统一返回BoxBody类型的响应，同时兼容自定义响应和下游服务响应
    type Response = ServiceResponse<BoxBody>;
    type Error = Error;
    type Future = Pin<Box<dyn Future<Output = Result<Self::Response, Self::Error>>>>;

    fn poll_ready(&self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
        self.service.poll_ready(cx)
    }

    fn call(&self, req: ServiceRequest) -> Self::Future {
        let svc = self.service.clone();
        let authenticate_fail = true; // 替换为你自己的身份校验逻辑

        if authenticate_fail {
            return Box::pin(async move {
                // 构造未授权响应，转换为BoxBody类型
                let res = req.into_response(
                    HttpResponse::Unauthorized()
                        .finish()
                        .map_into_boxed_body() // 核心方法，把AnyBody转换成通用BoxBody
                );
                Ok(res)
            });
        }

        // 正常转发请求到下游服务，同步把下游的B类型响应体转换为BoxBody
        Box::pin(async move {
            let res = svc.call(req).await?;
            Ok(res.map_into_boxed_body())
        })
    }
}

核心修改点说明 #

• 把Service的Response关联类型从ServiceResponse<B>改为ServiceResponse<BoxBody>，统一所有返回路径的响应体类型
• 自定义返回响应时调用map_into_boxed_body()方法，消除自定义响应和泛型B的类型冲突
• 正常转发请求的返回路径也调用map_into_boxed_body()，把下游服务返回的业务响应体转换为通用BoxBody，保持类型统一

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