我有一个需要很长时间才能完成的异步操作管道，如果管道在截止日期之前没有生成项目，我想让 Uni 继续使用占位符项目，如下所示：

但是当使用这种方法时，处理流水线被取消并且操作链被中断。是否可以在截止日期到期而不取消处理管道的情况下使用占位符项目完成 Uni？即使错过了最后期限，我也希望管道能够持续到最后。如果有帮助，可以使用 Vert.x。

谢谢

编辑：

这是我迄今为止尝试过的：

当处理在截止日期之前完成时，这可以正常工作，但是如果截止日期到期并且计时器被触发，它会javax.enterprise.context.ContextNotActiveException在发出占位符项目时崩溃，并且应用程序似乎陷入某种死锁。

编辑 2

原来我的大部分问题实际上是由于不正确使用 Hibernate 引起的。在对 Hibernate 事务的管理方式进行了一些重构之后，所有随机死锁和其他问题都消失了。

这似乎是原始问题最优雅的解决方案，即如何在不中断处理的情况下使用虚拟项目进行响应，除非它在截止日期之前完成：

我是 Quarkus 的新手，真的很高兴在我的下一个项目中使用它。我的第一步是配置 mysql 连接并以反应方式对其执行查询，如此处所示。我不想使用 JPA/Hibernate，所以我没有采用 Panache 方式。

但我发现在映射行集时我不能使用表别名。

这真的很令人沮丧，因为当列名不明确时（例如，id 是一个非常常见的列名），将无法进行包含复杂连接的查询。

有没有办法改变这种行为，或者它只是一个错误？ Im using Quarkus 1.13.0.Final with the quarkus-reactive-mysql-client dependency

最近我使用回调结构实现了一个带有 Quarkus/Mutiny 的 Reactive REST GET 端点；

使用 Quarkus/Mutiny 将 MyRequestService 连接到反应式 REST GET 端点

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

如何使用 Quarkus/Mutiny 从我的 Reactive REST GET 端点调用阻塞服务

找不到项目时尝试发送自定义错误消息。ifNotNull大小写正确生成所需的响应。但ifNull不生成所需的响应（始终响应为空，状态码为 200）

AuthorService.java

资源.java

我有一个简单的资源，它返回一个 Uni<Response>

我有一个示例拦截器，用于将请求/响应记录为 json

当我发送 json 请求时：

打印出来的日志是：

我想问的问题是： 拦截器拦截到一个Uni<Response>的响应时，如何打印出响应的json内容

这是我目前的解决方案：

但我认为它很丑。

在使用回调结构使用 Quarkus / Mutiny 实现 Reactive REST GET 端点并使用阻塞服务检查变体后，我最终使用了 CompletionStage / CompletableFuture API 版本；

如何使用 Quarkus/Mutiny 从我的 Reactive REST GET 端点调用 CompletionStage / CompletableFuture API 服务

我正在使用 Mutiny 扩展（用于 Quarkus），但我不知道如何解决这个问题。

我想以异步方式发送许多请求，所以我读过 Mutiny 扩展。但是服务器关闭了连接，因为它收到了数千个。

所以我需要：

• 分块发送请求
• 发送所有请求后，执行操作。

我一直在使用 Uni 对象来组合所有响应，如下所示：

接着：

此代码并行发送所有请求，以便服务器关闭连接。

我正在使用一组 Multi 对象，但我不知道如何使用它（在 Mutiny 文档中我找不到任何示例）。

这就是我现在正在做的方式：

我认为订阅不会执行，直到有“100”组项目，但我想这不是方式，因为它不起作用。

有谁知道如何以 100 个块启动数千个异步请求？

提前致谢。

2012 年 4 月 19 日更新

我试过这种方法：

当我把这条线：

响应一个接一个地打印，当前 100 组项目结束时，它会打印下一组。问题？有顺序请求，需要很多时间

我想我已经接近解决方案了，但我需要知道，如何仅以 100 组为一组发送并行请求，因为如果我输入：

所有请求都是并行发送的（而不是 100 组）

我想问一下实现 Mutiny 的最低 Java SDK 是多少？是否可以使用 Java 6 实现这一点？