RabbitMQPublisher 有时无法恢复
我将 Vertx 4.2.1 与 RabbitMQ 客户端一起使用,我刚刚注意到有时当rabbitMQ 客户端断开连接并重新连接时,RabbitMQPublisher 无法再发布消息。这意味…
StacklessClosedChannelException 捕获 JavaFlightRecorder
为什么会出现这样的异常呢?其原因何在? 我使用 JavaFlightRecorder 捕获了它。 我使用 AWS EC2 实例和 AWS 负载均衡器,所有流量都来自均衡器,看起…
Quarkus Rest 客户端并行连接数是否限制为 256
我有一个客户端请求远程服务器 Multi.createFrom() .items( userInfoList.stream()) .onItem() .transformToUniAndMerge( userInfo -> { System.out.p…
网络不可达时 NetSocket 写入异常
我正在使用 NetSocket 类将数据写入 TCP 服务器。当 TCP 服务器正常关闭时,套接字的关闭处理程序将被调用,并且一切正常。但是,当我在执行期间切断…
如何订阅“HttpClientResponse::toFlowable()”在 vert.x“rxResponse().subscribe”之外打回来
我试图在事件循环之外使用 HttpClientResponse.toFlowable() 的内容,使用 AtomicReference 来保存 Flowable。 因此,我设置了一个返回正文的测试,然…
Vertx JDBC 客户端行更新计数
使用 Vertx SQL 客户端 API (https://vertx.io/docs/ vertx-jdbc-client/java/#_using_the_sql_client_api) 如何执行更新并获取更新的数字或行来告诉…
VertX 多个 Future 返回一个 Future
我正在尝试调用 3 个 future,等待它们完成,处理结果,然后将所有这些也作为 Future 返回。我似乎无法弄清楚如何将 3 个期货“包装”在未来中以使其…
我可以将敏感数据存储在 Quarkus 应用程序的 Vert.x 上下文中吗?
我正在寻找一个地方来存储一些请求范围的属性,例如使用 Quarkus 请求过滤器的用户 id。我稍后想在日志处理程序中检索这些属性并将它们放入 MDC 日志…
如何将 HSCAN 响应映射到 Map使用 Vert.x Redis
我正在使用 io.quarkus.redis.client.RedisClient ,其中使用 Vert.x 用于 Java 中的 Redis 客户端。当我使用 HSCAN 方法时,它会返回不同行中的键和…
vertx 环境下,如何使用log4j2+slf4j日志框架读取外部的日志配置文件?
我想在基于vertx的java的maven项目下使用log4j2+slf4j日志框架。log4j2日志配置文件在项目文件下的config文件夹里,并不在resources文件夹中。加载日…
vertx4 jdbc 基于JsonObject配置jdbc,如何配置执行sql的超时时间?
使用vertX4 的异步jdbc框架连接pg数据库,发现pg数据库的配置写错了,再执行sql语句,不会马上提示数据库连接异常。如何设置?配置jdbc,我猜测connect…
在Vertx Web的体系下,如何做一个Action级别的拦截器?
我希望能进行参数校验,权限校验,登录校验等校验检查和认证操作,但是我希望的是当一个请求成功匹配一个路由后(Route),在真正调用路由处理的方法…
在vert.x环境下使用基于阻塞jdbc的orm框架来访问数据库有什么大问题?
我使用vert.x 创建一个自定义的tcp服务端实例程序来处理tcp服务,其中编写的代码包括使用基于阻塞jdbc的orm框架来进行数据库访问。在vert.x环境下使…