问题标签 [smallrye]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
675 浏览

java - Quarkus + Native Image 内存使用

我正在评估 Quarkus,我有一个非常简单的应用程序构建为本机映像。在应用程序中,我有 Smallreye Metrics。一切正常,但我无法推断 Smallrye 和 Docker 报告的内存使用情况。

当我运行 docker stats 时,我得到

所以 4.6MB,很酷。

当我查看 Smallrye 输出/metrics时,我看到了

这大约是 10 倍(如果我正确阅读了科学记数法)。我错过了什么?

0 投票
3 回答
1454 浏览

java - 使用 Apache Camel/Smallrye/reactive 流 - 如何跨 JVM 将“发布者”连接到“订阅者”?

下面是我在 Apache Camel 反应流解决方案中尝试跨 JVM 将发布者连接到订阅者(骆驼路由的代码如下所示)

为了使通信能够跨越 JVM,似乎需要一个“代理”服务器。因此,我已经实现了 Artemis 代理并相应地修改了 application.properties 文件(根据我对如何执行此操作的最佳理解)。

此外,为了缩小焦点,选择使用 smallrye-ampq 连接器。

问题:

订阅者应该接收并记录字符串值(来自正文):

--相反,它正在记录值,如下所示:

问题:

为什么发布者发送的有效负载没有到达订阅者,我可以修改哪些代码/配置来修复它?

提前谢谢您的帮助!

---

“发布者”路线

microprofile-config.properties - 发布者

相关控制台日志摘录(?) - 发布者

“订阅者”路线

microprofile-config.properties - 订阅者

相关控制台日志摘录(?) - 订阅者

注意:上面的输出应该显示数字......而不是例如“Exchange[ID-LAPTOP-4LR4PMVQ-1576639597494-0-289]”等...... :-(

每个基本相同的 maven pom.xml

docker-compose.yml (Artemis)

使用的技术

(使用此链接作为资源: https ://smallrye.io/smallrye-reactive-messaging/ )

0 投票
0 回答
132 浏览

java - Microprofile @Fallback 在本机图像模式下不起作用

在 Quarkus 上运行以下代码:

回退机制在常规 JDK​​ 模式下正常工作。另一方面,在本机图像模式下,@Fallback注释不被尊重,并且在 API 调用不成功后引发异常。@RegisterForReflection如果注释到位,可能是什么原因?

0 投票
2 回答
182 浏览

quarkus - Openapi YAML 错误,无法生成客户端存根

我正在评估 Quarkus 作为后端,由一个角度前端访问。我想使用 Quarkus 通过http://localhost:8080/openapi提供的 openapi 数据,并通过 openapi-generator 工具生成 typescript-angular 客户端存根。

我使用 Quarkus Openapi 指南作为第一步:https ://quarkus.io/guides/openapi-swaggerui 但是在运行未修改的示例并通过http://localhost:8080/openapi 检索 Openapi YAML-Data之后,我注意到生成的数据错误,openapi 生成器由于 stackoverflow 错误而无法生成客户端。

问题:SetFruit-Definition(最后一行)的 Openapi 数据中的自引用:

这是一个已知问题,还是我这边有一些误解。有没有办法解决这个问题?

非常感谢!

0 投票
1 回答
1271 浏览

rest - POST 请求上传文件中 JWT 自动化阶段的 Quarkus Vertx 超时

我正在构建一个基于 quarkus 和 microprofile 的项目,并具有以下扩展名: rest-client,health, resteasy-jsonb, metrics, openapi,fault,jdbc-postgres,hibernate-orm,jwt,mongodb-client,kotlin,resteasy-jsonb.

在一个 REST 资源中,我有一个处理 csv 文件上传的上传方法,由于文件大小和连接带宽,文件上传过程需要两秒钟以上;之后出现以下异常:

是否可以将此 2 秒值修改为更大的值?

0 投票
1 回答
1415 浏览

reactive-programming - Smallrye Mutiny 中的 switchIfEmpty 替代方案是什么

在 RxJava 2 和 Reactor 中,switchIfEmpty如果当前流中没有元素,则有类似的方法可以切换到新流。

但是当我开始使用Minuty时,当我将 Quarkus 样本转换为使用 Reactive 功能时,我找不到替代方案。

目前我的解决方案是:在我的 中PostRepository,我使用异常表示没有找到帖子。

并将其捕获在PostResource.

如何在 中返回Uni0 或 1 个元素PostRepository,并使用switchIfEmpty类似PostResource的方法为流构建替代路径?

0 投票
2 回答
265 浏览

rx-java2 - RxJava2 中 Publisher 和 Flowable 的 Mutiny 等价物是什么

我想创建一个可以将对象推送到其中的缓冲 Multi。Multi 用作 REST 端点的结果。

到目前为止,我所拥有的是:

然而,这段代码混合了 RxJava 和 Mutiny。Publisher 和 Flowable 的 Mutiny 等价物是什么?

0 投票
0 回答
397 浏览

reactive-programming - Quarkus 健康检查

这是我的数据库健康检查:

问题是做 .await().indefinitely() 而我不想要它(io.vertx.core.VertxException:线程被阻塞)

如何以反应/订阅方式 responseBuiler.up() ?

谢谢

0 投票
1 回答
1240 浏览

firebase-authentication - Quarkus 和 Firebase 身份验证

我正在使用 Quarkus (1.3.2.Final) 开发一个新的 REST 服务,并且我正在尝试将 Firebase 身份验证与 Smallrye-Jwt 集成,但它失败了。

我的第一次尝试是将 publickey.location 指向 Google 的 URL,但它失败了,因为有两个密钥,并且检查签名的正确 publicKey 取决于 jwt "kid" 标头值:

我的第二次尝试是创建一个服务(“PublicKeyResolver”的种类)来请求 google 的 url 并根据“kid”声明值提取正确的公钥:

该策略失败,因为“授权”http 标头未包含在对 publicKey 的请求中。

有没有办法集成 Quarkus 和 Firebase 身份验证?

0 投票
1 回答
336 浏览

multithreading - 为什么我不断收到来自 AMQP 的消息被拒绝?

我在 Quarkus 上有一个应用程序正在接收 AmqpMessages,并将它们发送到另一个主题。

我不断收到来自 smallrye 的错误消息,说消息被拒绝。

这里是属性

班级本身

日志输出:

正如你们所看到的,有一条消息被拒绝并且没有更多的输出,说明为什么会发生这种情况。在此之前,我还可以检测到:description='Deliveries cannot be sent to an unavailable address

知道为什么会这样。在此之前,我们有一个具有相同主题的 JMS 实现,并且运行良好