Quarkus Mutiny：异步请求的正确处理姿势
本文旨在帮助开发者理解并掌握 Quarkus Mutiny 中处理异步请求的最佳实践，避免常见的“过早返回”问题。我们将通过示例代码，展示如何利用 Uni.combine() 等操作符，确保所有异步操作完成后再返回结果，从而构建更健壮、更可靠的响应式应用。同时，强调避免使用 await() 方法，充分发挥响应式编程的优势。
在使用 Quarkus Mutiny 构建响应式应用时，经常会遇到需要处理多个并发的异步请求，并将它们的结果合并后返回的情况。一个常见的陷阱是，由于异步操作的延迟，主线程可能会在所有请求完成之前就返回了结果，导致数据不完整或错误。本教程将介绍如何使用 Mutiny 提供的组合操作符来解决这个问题，确保只有在所有异步操作完成后，才返回最终结果。
使用 Uni.combine() 组合多个异步请求
Uni.combine() 是 Mutiny 中一个强大的操作符，它可以将多个 Uni 对象组合成一个新的 Uni 对象，并在所有原始 Uni 对象都发出值后，才发出组合后的值。这非常适合处理需要并发请求多个服务，并将它们的结果合并的场景。
以下是一个示例，展示如何使用 Uni.combine() 来并行调用多个外部服务，并将它们的结果组合成一个 Car 对象：
@GET
@Path("/testingAsync")
public Uni<Car> testingMutiny() {
Uni<List<JsonObjectCar>> carDoorsUni = getDoors(variable1, variable2, variable3);
Uni<List<JsonObjectCar>> carWheelsUni = getWheels(variable1, variable2, variable3);
Uni<List<JsonObjectCar>> carWindowsUni = getWindows(variable1, variable2, variable3);
return Uni.combine()
.all()
.unis(carDoorsUni, carWheelsUni, carWindowsUni)
.combinedWith(list -> {
// Result of carDoorsUni
List<JsonObjectCar> carDoors = (List<JsonObjectCar>) list.get(0);
// Result of carWheelsUni
List<JsonObjectCar> carWheels = (List<JsonObjectCar>) list.get(1);
// Result of carWindowsUni
List<JsonObjectCar> carWindows = (List<JsonObjectCar>) list.get(2);
// Create a car instance with the previous results
Car car = createCar(...);
// You can also return a list of cars, but you need to change the return type of testingMutiny to Uni<List<Car>>
return car;
})
.invoke( () -> System.out.println("Okay it worked"));
}在这个例子中，getDoors(), getWheels() 和 getWindows() 方法分别返回一个 Uni<List<JsonObjectCar>> 对象，代表对不同服务的异步请求。 Uni.combine().all().unis() 将这三个 Uni 对象组合在一起。 combinedWith() 方法接收一个函数，该函数在所有三个 Uni 对象都发出值后被调用。 该函数接收一个包含所有结果的列表，并使用这些结果创建一个 Car 对象。 最后，invoke() 方法在 Uni 发出值后执行一个副作用，这里是打印一条消息。
关键点:
- Uni.combine().all().unis() 确保在所有 Uni 对象都发出值后，才会执行后续的操作。
- combinedWith() 方法允许您访问所有异步请求的结果，并将它们组合成最终结果。
- 避免使用 .subscribe()，Quarkus 会自动处理 Uni 的订阅。
避免使用 await()
在使用响应式编程时，应尽量避免使用 await() 方法。 await() 会阻塞当前线程，导致响应式编程的优势丧失。 在 Quarkus 中，由于它能够识别异步 API 并正确处理结果，通常不需要显式地使用 await()。
总结
通过使用 Uni.combine() 等操作符，您可以轻松地处理多个并发的异步请求，并确保只有在所有请求完成后才返回最终结果。 避免使用 await() 方法，并充分利用 Quarkus 提供的响应式特性，可以构建出更健壮、更高效的响应式应用。
