Swift/Vapor HTTP服务器中间件偶发请求体为空解码失败问题求助

• Vapor的Request.body默认是流式传输的，中间件执行时框架默认不会预先等待整个请求体加载完成。本地环境/压测时网络延迟极低，请求体几乎瞬间完成传输，因此不会触发问题；而低配置Ubuntu服务器加上反向代理的网络链路延迟更高，就会偶发中间件执行时body还未传输完毕的情况，此时读取request.body.string自然为空。
• 你当前的中间件实现直接用同步的request.content.decode逻辑，没有等待请求体全量收集完成的异步操作，在网络IO较慢的场景下必然会出现概率性解码失败。
• 路由接口的实现不会出现该问题，是因为Vapor默认会在调用路由处理函数前，自动完成全量请求体的收集工作，此时读取body一定是完整的。

方案1：在中间件中主动等待请求体收集完成（推荐） #

你只需要修改中间件的逻辑，先调用Request.collectBody()方法等待全量body加载完成后再执行解码操作即可，示例代码如下：

func respond(to request: Request, chainingTo next: Responder) -> EventLoopFuture<Response> {
    // 先主动收集完整请求体
    return request.collectBody().flatMapThrowing { _ in
        let myStuff = try request.content.decode(SomeCommonPattern?.self)
        // 在这里执行你的身份校验等逻辑
        // ...
    }.flatMap { _ in
        // 校验通过后继续调用后续链路
        return next.respond(to: request)
    }.flatMapError { error in
        // 处理解码失败、校验失败的错误响应
        // 比如返回400/401状态码的Response
        // ...
    }
}

这个方案可以保留你原本的中间件统一校验的架构，不需要修改各个接口的实现。

方案2：全局配置Vapor自动收集全量请求体 #

如果你需要所有路由的中间件都能直接读取完整body，可以在App启动时添加全局配置：

app.middleware.use(ContentConfiguration.default.middleware)
// 或者直接设置最大 body 大小，自动收集所有小于该大小的请求体
app.routes.defaultMaxBodySize = "10mb"

该配置会让框架在调用所有中间件前自动收集完整的请求体，适合大部分请求体大小可控的业务场景。

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