如何在 Undertow HttpHandler 中发送异步响应

Question

我正在寻找一个示例，该示例说明您如何在 HttpHandler 中异步编写响应？问题是当 HttpServerExchange.endExchange 被调用时，响应被刷新。我的示例 HttpHandler 使用 Scala 的 rx-java 库。

class MyHandler() extends HttpHandler {
  override def handleRequest(exchange: HttpServerExchange) = {
    val observable = Observable.items(List(1, 2, 3)) // simplistic not long running
    observable.map {
      // this is run async
      myList => exchange.getResponseSender.send(myList.toString)
    }
  }
}

Answer 1

如果您调用 dispatch() 方法，则在调用堆栈返回时交换不会结束，但是在这种情况下即使这样也很不礼貌。

你可能想要这样的东西：

exchange.dispatch(SameThreadExecutor.INSTANCE, () -> {
observable.map {
  // this is run async
  myList => exchange.getResponseSender.send(myList.toString)
}}

基本上这将等到调用堆栈返回后再运行异步任务，这意味着没有竞争的可能性。由于交换不是线程安全的，这种方法确保一次只能运行一个线程。