3

我想要一个 Actix Web 处理程序，它通过将 POST 正文打印到控制台并构造一个包含来自请求对象的当前 URL 的 HTTP 响应来响应 POST 请求。

在读取请求的 POST 正文时，似乎需要涉及期货。到目前为止，我得到的最接近的是：

fn handler(req: HttpRequest) -> FutureResponse<HttpResponse> {
    req.body()
        .from_err()
        .and_then(|bytes: Bytes| {
            println!("Body: {:?}", bytes);
            let url = format!("{scheme}://{host}",
                scheme = req.connection_info().scheme(),
                host = req.connection_info().host());
            Ok(HttpResponse::Ok().body(url).into())
        }).responder()
}

这不会编译，因为未来比处理程序更长寿，所以我的阅读尝试req.connection_info()是非法的。编译器错误建议我move在闭包定义中使用关键字，即.and_then(move |bytes: Bytes| {. 这也不会编译，因为req在req.body()调用中被移动，然后在引用构造移动之后被捕获url。

connection_info构建一个范围的合理方法是什么，在该范围内我可以在访问 POST 正文的同时访问附加到请求对象（例如 ）的数据？

4

1 回答 1

4

最简单的解决方案是在未来根本不访问它：

extern crate actix_web; // 0.6.14
extern crate bytes;     // 0.4.8
extern crate futures;   // 0.1.21

use actix_web::{AsyncResponder, FutureResponse, HttpMessage, HttpRequest, HttpResponse};
use bytes::Bytes;
use futures::future::Future;

fn handler(req: HttpRequest) -> FutureResponse<HttpResponse> {
    let url = format!(
        "{scheme}://{host}",
        scheme = req.connection_info().scheme(),
        host = req.connection_info().host(),
    );

    req.body()
        .from_err()
        .and_then(move |bytes: Bytes| {
            println!("Body: {:?}", bytes);
            Ok(HttpResponse::Ok().body(url).into())
        })
        .responder()
}

如果这不仅仅是出于演示目的的快速破解，通过连接字符串来构造 URL 是一个糟糕的主意，因为它不能正确地转义值。您应该使用为您执行此操作的类型。

于 2018-07-07T17:22:56.773 回答