java - 如何将 io.micronaut.http.HttpRequest 转换为 CompletableFuture
问题描述
我正在关注4 个低级客户端,我想调整示例以返回 CompletableFuture。我的最终目标是并行使用两个不同的端点。我是 Micronaut 的新手。我相信一种好的方法是创建两个 Micronaut 低级客户端,它们返回一个可完成的未来,然后使用 CompletableFuture.allOf().join() 加入两者
所以我将服务编码为
import com.mycomp.application.clients.EmployeClient
import com.mycomp.application.clients.EmployeeLowLevelClient
import java.awt.desktop.PrintFilesEvent
import java.util.*
import java.util.concurrent.CompletableFuture
import javax.inject.Inject
import javax.inject.Singleton
@Singleton
class EmployeeService {
@Inject
lateinit var employeClient: EmployeClient //Declarative Cliente
@Inject
lateinit var employeeLowLevelClient: EmployeeLowLevelClient //Low Level Client
fun thenCombineAsyncExample() {
val allFutures: MutableList<CompletableFuture<String>> = ArrayList<CompletableFuture<String>>()
allFutures.add(employeClient.getEmployeesA()) //### THIS WORKS
allFutures.add(employeClient.getEmployeesB()) //### THIS WORKS
employeeLowLevelClient.getEmployeeSurname()?.let { allFutures.add(it) } //### THIS FAILS
CompletableFuture.allOf(*allFutures.toTypedArray<CompletableFuture<*>>()).join()
for (i in 0..1) {
print("response: " + allFutures[i].get().toString())
}
}
}
低级客户端为
import io.micronaut.http.HttpRequest
import io.micronaut.http.client.RxHttpClient
import java.util.concurrent.CompletableFuture
import javax.inject.Singleton
@Singleton
class EmployeeLowLevelClient(private val httpClient: RxHttpClient) {
internal fun getEmployeeSurname(): CompletableFuture<String>? {
val req = HttpRequest.GET<String>("http://localhost:3000/employees_a?first_name=Jimis")
//val flowable = httpClient.retrieve(req)
return req as CompletableFuture<String> //### HERE IS THE ISSUE
}
}
例外是
java.lang.ClassCastException: class io.micronaut.http.client.netty.NettyClientHttpRequest cannot be cast to class java.util.concurrent.CompletableFuture (io.micronaut.http.client.netty.NettyClientHttpRequest is in unnamed module of loader 'app'; java.util.concurrent.CompletableFuture is in module java.base of loader 'bootstrap')
有趣的是,声明式客户端并没有例外。
import io.micronaut.http.annotation.Get
import io.micronaut.http.client.annotation.Client
import io.reactivex.Single
import java.util.concurrent.CompletableFuture
@Client()
interface EmployeClient {
@Get("http://localhost:3000/employees_a?first_name=Jimis")
fun getEmployeesA(): CompletableFuture<String>
@Get("http://localhost:3001/employees_b?first_name=Jimis")
fun getEmployeesB(): CompletableFuture<String>
}
解决方案
如果我理解正确,您想异步发出一些 Http 请求......
以下几行相对简单,但我认为可能存在一些混乱......
val allFutures: MutableList<CompletableFuture<String>> = ArrayList<CompletableFuture<String>>()
allFutures.add(employeClient.getEmployeesA()) //### THIS WORKS
allFutures.add(employeClient.getEmployeesB()) //### THIS WORKS
employeeLowLevelClient.getEmployeeSurname()?.let { allFutures.add(it) }
您创建一个CompletableFuture
s 列表。然后你添加两个CompletableFuture
s 到它。然后您使用“客户端”getEmployeeSurname()
与CompletableFuture
s 通话。
所以在我看来你想getEmployeeSurname()
返回 aCompletableFuture
所以你可以将它添加到列表中allFutures
所以你想要一个getEmployeeSurname()
更像的函数:
internal fun getEmployeeSurname(): CompletableFuture<String>? {
val req = HttpRequest.GET<String>("http://localhost:3000/employees_a?first_name=Jimis")
//val flowable = httpClient.retrieve(req)
return CompletableFuture.runAsync(req)
}
然后,此函数返回包装在可完成未来中的 Http 请求。您不能只从 HttpClient 转换为 CompletableFuture,因为两者之间没有共性。
所以现在当你这样做时:
employeeLowLevelClient.getEmployeeSurname()?.let { allFutures.add(it) }
它应该添加CompletableFuture
调用应该在单独的线程上运行,而不会阻塞主线程上的执行。
推荐阅读
- c# - 获取 ComboBox 选定项
- php - 列中的 Wordpress 搜索结果
- components - Flutter AppBar 多次使用组件
- odoo - 在odoo视图中显示动态值?
- amazon-web-services - 是否每个 aws 批处理作业都会启动一个新的 docker 容器
- nginx - 使用 Nginx 上下文路由通过 https 运行 Zeppelin
- javascript - 以角度创建一个库以用于任何项目
- c++ - 如何初始化由 unique_ptr 管理的数组元素?
- android - 如何在 RecyclerView PagedListAdapter 的特定位置添加 Admob?
- twitter-bootstrap - 为什么我的按钮有不同的颜色而它们有相同的类