使用Quarkus/Martiny在反应式REST GETendpoint中调度阻塞服务

Question

最近，我使用回调结构实现了一个带有Quarkus/Multiny的反应式REST GETendpoint；

使用 Quarkus/Mutiny 将 MyRequestService 连接到 Reactive REST GET endpoint

完成后，我想知道如何通过调用阻止服务来解决这个问题;

我如何用quar kus/哗变从我的反应式REST GETendpoint调用阻塞服务

Answer 1

我在文档中没有看到快速答案，但结果非常简单;

ServiceResource只是将调用转发给Service。

MyRequestService 创建了一个 MyJsonResultSupplier，并使用方法 item（） 将其交付给 Mutiny Uni。生成的 Uni 将返回到 ServiceResource。

穆特尼在供应商上使用方法get（）用于MyJsonResault。该调用阻塞了信号量mMyJsonResult供应商信号量上的获取。接下来，另一个工作线程调用准备好方法（），该方法设置mMyJsonResault并向穆特尼释放信号量mMyJsonResult供应商信号量解除阻塞方法get（）。

哗变完全隐藏了故事的反应部分，因此您可以在注册的供应商中阻止方法调用。