如何从回调函数返回ZIO HTTP响应并对接Java异步服务

解决方案 #

核心思路 #

你现有代码的核心问题有两个：

1. 误用了ZIO HTTP的流式响应API：HttpData.fromStream仅用于需要分片传输的大负载/流式响应场景，要求输入字节类型的ZStream，你只是返回单个字符串结果完全不需要用这个API
2. 没有用collectZIO承接异步返回的ZIO效果：ZIO HTTP的collect仅支持直接返回Response类型，如果你要返回异步计算的ZIO效果，需要用collectZIO方法

完整实现代码 #

首先把Java回调式API包装成ZIO效果：

import zio._
import zio.http._
import java.nio.charset.StandardCharsets

// 包装Java回调服务为ZIO效果
def invokeJavaService(service: JavaService): Task[String] = 
  ZIO.effectAsync { callback =>
    service.doSomeStuffWithCallback { resultString =>
      // 回调触发时返回结果，可根据Java服务逻辑补充异常处理
      callback(IO.succeed(resultString))
    }
  }

然后编写ZIO HTTP服务：

object HelloWorld extends zio.App {
  def app(service: JavaService) = Http.collectZIO[Request] {
    case Method.GET -> Root / "text" => 
      invokeJavaService(service).map(Response.text(_))
  }

  override def run(args: List[String]): URIO[zio.ZEnv, ExitCode] =
    Server.start(8090, app(new JavaService)).exitCode
}

可选：如果你确实需要流式响应 #

如果后续你有流式返回的需求，只需要把字符串转为字节流即可解决类型不匹配问题：

val content: HttpData[Blocking, Throwable] = HttpData.fromStream {
  ZStream.fromEffect(doSomeStuffWrapped)
    .map(_.getBytes(StandardCharsets.UTF_8))
    .map(Chunk.fromArray)
    .flattenChunks
}

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