使用Quarkus/Mutiny在反应式REST GETendpoint中调度CompletionStage/CompletableFuture API服务
在使用回调结构和Quarkus/Mutiny实现反应式REST GETendpoint并使用阻塞服务检查变量后，我最终使用CompletionStage/CompletableFuture API版本进行了播放；
如何从我的Reactive REST GETendpoint调用CompletionLevel/CompletableFuture API服务
共有1个答案
同样，事实证明它相当简单（尽管潜在的想法可能更复杂）；
ServiceResources只是将调用转发到服务。
MyRequestService创建MyJsonResultCompletableFuture（CompletableFuture实现CompletionStage），并使用CompletionStage（）方法将其传递给Mutiny Uni。另一种可能是使用；
Uni.subscribe
生成的Uni返回到ServiceResource。
最后，MyJsonResultCompletableFuture阻止来自MyReactiveServiceResources/MyquiestService的调用，等待完成阶段。方法准备（）完成这一阶段，并返回MyJsonResult到Mutiny（类似于某种回调）。
-
最近，我使用回调结构实现了一个带有Quarkus/Multiny的反应式REST GETendpoint； 使用 Quarkus/Mutiny 将 MyRequestService 连接到 Reactive REST GET endpoint 完成后，我想知道如何通过调用阻止服务来解决这个问题; 我如何用quar kus/哗变从我的反应式REST GETendpoint调用阻塞服务
-
我有两个可用的gRPCendpoint和一个ServerInterceptor，它应该在抛出异常时拦截异常。 gRPC服务定义如下： gRPC服务使用SmallRye Mutiny Responsive来处理请求。 其他帖子解释说，应该重写onHalfClose方法，并插入try/catch块来捕获自定义异常，然后映射到StatusRuntimeException gRPC可以使用的状态。我尝试了
-
我正在处理一个反应式quarkus后端服务，它执行以下操作。 使用与postgres交互的Hibernate反应式Panache从后端获取记录列表 使用记录的标识符，从另一个远程服务获取数据 我正在使用Mutiny来执行反应式管道。远程服务和数据库集成都以非阻塞方式单独工作。我只是需要帮助写一个连接这些的管道。例如：下面的例子 我被困在处理统一包装列表，然后试图处理列表中的单个项目。要么是Uni
-
Quarkus有类似于开箱即用？（在文件中找不到任何提及） 要穿上某种服务方式， 这将在一段时间内保留/缓存prev响应，并保留调用堆栈/日志。 类似于那个Spring注释？
-
我将如何创建事务、插入行、提交事务并获取最后插入的id。所以该方法应该返回一个
-
我面临的问题是，有一个服务，我必须调用，这是一个传统的Spring启动应用程序，而不是反应性的！ 下面是一个示例endpoint，它接近上述遗留系统的想法： 我知道我不能用这个来实现真正的反应性善，有没有一个快乐的非阻塞和阻塞的媒介我可以在这里实现？ 谢谢