Vertx：如何在处理正文请求之前验证身份验证？

Question

如何在处理正文请求之前验证身份验证？

我正在使用vertx：

vertxVersion = '3.8.3'
implementation "io.vertx:vertx-core:$rootProject.vertxVersion"
implementation "io.vertx:vertx-web:$rootProject.vertxVersion"
implementation "io.vertx:vertx-lang-kotlin:$rootProject.vertxVersion"
implementation "io.vertx:vertx-lang-kotlin-coroutines:$rootProject.vertxVersion"
implementation "io.vertx:vertx-mongo-client:$rootProject.vertxVersion"
implementation "io.vertx:vertx-auth-mongo:$rootProject.vertxVersion"
implementation "io.vertx:vertx-auth-jwt:$rootProject.vertxVersion"

我想在处理正文请求之前验证身份验证。但我得到了错误的java。lang.IllegalStateException：请求已被读取

使用暂停功能上的延迟复制：

router.handler { context ->
            launch {
                context.request().setExpectMultipart(true)
                delay(100) //This line is sample for a verify auth process
                context.next()
            }
        }
        .handler {context ->
            println("2")
            context.request()
                .handler {
                    b -> println("buff ${b.length()}")
                }
                .endHandler {
                    println("end handle")
                    context.success("ok")
                }
        }.baseHandle(
            fn
        ).failureHandler {
            println("fail: ${it.failure()}")
            it.error()
        }

当运行delay（100）时（这是验证过程的示例），我得到了上面的错误。如果我对延迟（100）进行注释，它可以正常工作。

Answer 1

最后，我确实解决了。

我的路由器正在处理流：

router.post("/api/upload/file")
      .baseHandle { checkAuthorization(it) }
      .handleFileUpload { updateFileOnItem(it) }

和以下步骤：

fun checkAuthorization(context: RoutingContext) {
    val request = context.request()
    val tkCookie = request.getCookie("user")
    ...do something to verify user permission
    request.pause()
    context.next()
    context.request().resume()
}

下一步：

fun updateFileOnItem(context: RoutingContext) {
    val file = context.fileUploads()
    ...do something
}

它和我一起工作。希望能对你有所帮助。谢谢

Answer 2

发生这种情况是因为当您对请求进行身份验证时，内容已经不断到达并已被删除。

您需要在第一个处理程序中调用context.request（）。暂停（），然后在准备好后调用context.request（）。恢复（）。

但在大多数情况下，让BodyHandler为您管理负载更容易。