vert.x 相关问题

在 Quarkus 中使用 io.vertx.mutiny 的实现不会改变要返回的值

我们正在通过在 Quarkus 中使用 io.vertx.mutiny 实现它来构建一个反应式系统。 这时测试了一个单值，确认返回。然而，预计变量......

Vert.x 共享数据 - 在 Vert.x 中的线程之间共享数据

我正在使用 vertx 版本 - 3.5.1。 我想在 ELK 中跟踪我的日志，为此我正在使用 elastic.apm。 我在方法的开头初始化我的 co.elastic.apm.api.Transaction 对象。我要

无法使用 vertx 和 JDBC 连接器从小型 kafka 消费者应用程序中执行 Azure SQL Server 查询

我正在尝试使用 java Kafka 消费者应用程序将数据插入 azure sql 服务器。我已确认与数据库的连接。 这是方法。 私人无效轮询（KafkaConsumer 我正在尝试使用 java Kafka 消费者应用程序将数据插入 azure sql 服务器。我已确认与数据库的连接。 这里是方法。 private void poll(KafkaConsumer<String, JsonObject> consumer) { vertx.setPeriodic(TIME_OUT_MS, timerId -> consumer.poll(Duration.ofMillis(POLL_MS)).onSuccess(records -> { for (int i = 0; i < records.size(); i++) { KafkaConsumerRecord<String, JsonObject> record = records.recordAt(i); System.out.println( "key=" + record.key() + ",value=" + record.value() + ",partition=" + record.partition() + ",timestamp=" + record.timestamp() + ",offset=" + record.offset()); Weather weather = toParams(record); JsonObject datasourceConfig = PropertiesHelper.getDatasourceProperties(); JDBCPool pool = JDBCPool.pool(vertx, datasourceConfig); String query = "INSERT INTO fowudatabase.dbo.weather (captureTime, waveHeight, wavePeriod, waveDirection, windSpeed, windDirection) values (?, ?, ?, ?, ?, ?)"; pool .getConnection() .onFailure(e -> { System.out.println("failed to get a connection: " + e.toString()); }) .onSuccess(conn -> { conn .preparedQuery(query) .execute(Tuple.of(weather.getCaptureTime(), weather.getWaveHeight(), weather.getWavePeriod(), weather.getWaveDirection(), weather.getWindSpeed(), weather.getWindDirection())) .onFailure(e -> { System.out.println("failed to execute query: " + e.toString()); conn.close(); }) .onSuccess(rows -> { System.out.println("successfully added row " + weather.getCaptureTime()); conn.close(); }); }); } }).onFailure(cause -> { System.out.println( "Something went wrong when polling " + cause.toString()); cause.printStackTrace(); vertx.cancelTimer(timerId); })); } 我认为问题在于 String query = "INSERT INTO fowudatabase.dbo.weather (captureTime, waveHeight, wavePeriod, waveDirection, windSpeed, windDirection) values (?, ?, ?, ?, ?, ?)"; 查询行，但我不确定接下来要尝试什么。 我的问题是，无论我如何表达我的 sql 查询字符串，我都会遇到两个错误之一。如果我在查询中使用完整的 databasename.dbo.tablename，我会得到“SQL Server 版本不支持对数据库和/或服务器名称的引用”。但是，如果我使用表名和/或 dbo 的任何变体，我就会收到“无效对象”错误。我想我已经尝试了大多数名字的变体，但到目前为止都没有成功。 如有任何帮助，我们将不胜感激。

cosmo 升级到 5.0.0 无法为 vertx-web 创建 bean

我正在尝试将我的 com.visa.commons.cosmo 依赖项升级到 5.0.0。我看到它自动引入了 4.3.7 的 io.vertx 依赖项。 我的应用程序编译正常，但是当我尝试运行它时，它...

Gradle 任务运行另一个带有多个参数的任务

我想知道是否可以创建一个 gradle 任务来并行运行具有多个参数的另一个任务。这个特定的任务是部署和运行 Vertx Verticle，部署它们

从 vert.web.ext context.request() 获取 HttpServletRequest

我可能会问类似的问题 是否可以相互翻译 ServerHttpRequest 和 HttpServletRequest 我有一个旧的第 3 方 jar 库（无源代码），它接收/期望

在应用层的VertX Spring框架应用中进行延迟故障注入。

我查过ChaosMonkey，它只针对springboot框架。另外，还有Pumba工具，但是，那看起来像是基础设施级别的故障注入，需要根系统访问。我在寻求帮助，诱导...

如何对TCP客户端进行反压

我有一个Vert.x NetServer，接受一个来自客户端的连接，假设我暂停了套接字ReadStream，那么我将不会收到任何来自连接的缓冲区，同时，假设客户端继续......

连接solace服务器时Vertx SSLTLS握手失败。

我使用vert.x java客户端连接solace服务器，在使用SSL证书连接时，收到以下SSL握手错误。当使用SSL证书进行连接时，收到以下SSL握手错误。谁能...

使用ertx-jooq-classic-reactive：5.0.1合成期货时，出现连接未打开的错误。

我有一个问题，当多个期货被组成，以执行更新书表和插入删除某些行在中间表_Category_Book_和_Author_Book_，因为书是......

Vertx HttpServerRequest中的语法

我对Java比较陌生，最近在学习Vertx，不明白下面的代码是怎么工作的。@Override public void start() { vertx.createHttpServer() .requestHandler(req -& ...

使用Vertx微服务在Java中构建的AWS X-Ray仪器。

如何用java实现Vertx微服务构建的x射线仪器？有沒有vertx aws-xray的sdk？我使用了java sdk，但没有得到服务地图。

缓冲区与TCP Vert.x服务器中的另一个缓冲区合并。

我想通过TCP向服务器发送命令。我创建了一个服务器，它可以检索Buffers消息。在客户端，我发送了10条命令，我不知道为什么服务器读取Buffer的方式不可预测。我不知道为什么服务器读取Buffer的方式不可预测。@...

使用Gradle和VS Code调试Vert.x应用。

我正在使用一个用Java编写的Verticle的Vert.x应用程序。该应用程序使用MainVerticle启动，并使用Gradle进行构建。我正在使用VS Code作为IDECode编辑器，因为它真的很简单。

在请求体中接受数字作为字符串？

我有一个API规范，在请求体中定义了一个参数account_id作为字符串。比如说一个请求中包含了一个数字或者甚至是布尔值的字段。就像这样 "account_id": 1234567890 ...

如何用Quarkus托管自定义Netty编解码器？

我对Quarkus完全是个新手，但我对Netty和vert.x很了解。我必须深入研究并使用Quarkus打开一个服务器套接字，托管一个用Netty编写的自定义网络编解码器--而不是 ...

Vert.x: 如何在整个工作线程池中处理事件序列？

我的问题是：如果我在事件循环线程中接收多个事件序列，我怎么能处理每个序列阻塞和有序的，但不同的序列是由整个工人线程处理......

每天在凌晨12:00和晚上23:00用Java和vertx对一个API执行两次调用。

我一直在玩vertx.setTimer和vertx.setPeriodic，但我没有在java中找到一个简单的方法来执行一个计划任务(在具体的周期内调用一个API，例如在12.00 AM......)。

Vertx在Quarkus vertx munity web客户端中不可用。

我试图测试vertx munity web客户端提供的reactive web客户端。我按照官方指南Quarkus - Reactive入门。并在依赖关系中添加了以下内容。...

Vertx - Java - 在循环中使用Handlerslambda。

我们有一个srings的列表，我们要循环执行。在循环中，我们将每个字符串传递给一个async调用。问题是，在所有的 asysnc 调用完成之前，循环就结束并退出了。 public void ...