Actix-web 2.0 JsonConfig error_handler 不工作

Question

我有下面的代码，一切正常，期待 error_handler。我不确定怎么了。如果我以正确的格式发出 post 请求，我会得到 200 的响应数据。但是在糟糕的请求下，我期待 400 没有接收到 JSON 数据。它只显示 400，但 return 没有任何错误 json 数据。

预期行为

错误请求 -> curl -X POST -H "Content-Type: application/json" -d '{"bad": "Someone was here"}' localhost:8080/send

status 400
{
    error: String,
    server_id: usize,
    request_count: usize,
}

当前行为

错误请求 -> curl -X POST -H "Content-Type: application/json" -d '{"bad": "Someone was here"}' localhost:8080/send

status 400

可能的解决方案

我用 .app_data 替换了 .data 它可以工作，但是找不到 AppState

代码

pub struct MessageApp {
    pub port: u16,
}

impl MessageApp {
    pub fn new(port: u16) -> Self {
        Self{port}
    }

    pub async fn run(&self) -> std::io::Result<()> {
        let messages = Arc::new(Mutex::new(vec![]));
        println!("Starting http server: 127.0.0.1:{}", self.port);

        HttpServer::new(move || {
            App::new()
                .data(AppState {
                    server_id: SERVER_COUNTER.fetch_add(1, Ordering::SeqCst),
                    request_count: Cell::new(0),
                    messages: messages.clone(),
                })
                .wrap(middleware::Logger::new(LOG_FORMAT))
                .service(index)
                .service(
                    web::resource("/send")
                    .data(
                        web::JsonConfig::default()
                            .limit(4096)
                            .error_handler(post_error)
                    )
                    .route(web::post().to(post))
                )
                .service(clear)
        })
        .bind(("127.0.0.1", self.port))?
        .workers(8)
        .run()
        .await
    }
}

错误处理程序

fn post_error(err: JsonPayloadError, req: &HttpRequest) -> Error {
    let extns = req.extensions();
    let state = extns.get::<web::Data<AppState>>().unwrap();
    let request_count = state.request_count.get() + 1;
    state.request_count.set(request_count);

  let post_error = PostError {
      server_id: state.server_id,
      request_count,
      error: format!("{}", err),
  };

  InternalError::from_response(err, HttpResponse::BadRequest().json(post_error)).into()
}

环境

流行OS 20.04 LTS
Rust 版本：rustc 1.45.2 (d3fb005a3 2020-07-31)
Actix 网络版：2.0.0

Answer 1

正如我之前在可能的解决方案中提到的那样。

在 github 上得到作者的帮助后。他提到我需要搬出 .app_data 来解决这个问题，或者转到解决这个问题的新版本 3.0。

但使用下面的 2.0.0 版本是解决方案：

HttpServer::new(move || {
            App::new()
                .data(AppState {
                    server_id: SERVER_COUNTER.fetch_add(1, Ordering::SeqCst),
                    request_count: Cell::new(0),
                    messages: messages.clone(),
                })
                .wrap(middleware::Logger::new(LOG_FORMAT))
                .service(index)
                .service(
                    web::resource("/send")
                    .app_data(
                        web::JsonConfig::default().limit(4096).error_handler(post_error)
                    )
                    .route(web::post().to(post))
                )
                .service(clear)
        })
        .bind(("127.0.0.1", self.port))?
        .workers(8)
        .run()
        .await

还有提取AppState的方法我做错了。下面固定在 post_error 函数中。

fn post_error(err: JsonPayloadError, req: &HttpRequest) -> Error {
    // let extns = req.extensions();
    // let state = extns.get::<web::Data<AppState>>().unwrap();
    let state = req.app_data::<web::Data<AppState>>().unwrap();
    let request_count = state.request_count.get() + 1;
    state.request_count.set(request_count);

    let post_error = PostError {
        server_id: state.server_id,
        request_count,
        error: format!("{}", err),
    };

    InternalError::from_response(err, HttpResponse::BadRequest().json(post_error)).into()
}

Actix-web 2.0 JsonConfig error_handler 不工作

Actix-web 2.0 JsonConfig error_handler not working

rust

rust-actix

actix-web

预期行为

当前行为

可能的解决方案

代码

环境