问题标签 [vertx3]

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 投票
2 回答
1358 浏览

event-bus - Vertx 事件总线无法向不同的 Verticle 发送消息

我对 Vertx 很陌生,但我对测试它与 Spring 的集成非常感兴趣。我使用 Spring boot 来提升项目,并部署了两个 Verticle。我希望他们使用事件总线相互通信,但失败了。这就是我所做的:

  1. 在主要应用程序中:

    @SpringBootApplication 公共类 MySpringVertxApplication { @Autowired MyRestAPIServer myRestAPIServer; @Autowired MyRestAPIVerticle MyRestAPIVerticle;

    }

  2. 在 APIVerticle 中:

    @Component 公共类 MyRestAPIVerticle 扩展 AbstractVerticle {

    }

  3. 最后是ServerVerticle:

    @Service 公共类 MyRestAPIServer 扩展 AbstractVerticle {

    }

但是在我启动它并访问/page1之后,消息根本无法从ServerVerticle发送到APIVerticle。如果我将事件总线消费者移动到与 Sender 相同的 Verticle 中,则可以接收到事件。

在两个verticles之间发送消息有什么问题吗?我怎样才能让它工作?

提前致谢。

0 投票
1 回答
785 浏览

vertx3 - Vertx Java 使用 Future Callback 部署一个 JavaScript verticle

我想在我的 Java VertX 中部署一个 javascript Verticle。当然,这不是问题。问题是,我怎样才能给他们回电?

我的 Java 代码:

我的 server.js:

当然,我的 server.js 更大,这需要一些时间来启动。在我的集群 Vertx 中,我在开始时收到一些消息,这些消息阻止了我的总线。

我怎样才能解决这个问题 ?

谢谢马塞尔

0 投票
1 回答
1928 浏览

java - 用Java将流写入mongoDB

我有一个文件要存储在 mongoDB 中。我想要的是避免加载整个文件(可能是几 MB 大小),而是我想打开流并将其定向到 mongoDB 以保持写入操作的性能。我不介意将内容存储在 base64 编码的字节 [] 中。

之后我想在读取文件时做同样的事情,即不要将整个文件加载到内存中,而是在流中读取它。

我目前正在将 hibernate-ogm 与 Vertx 服务器一起使用,但如果它有效地解决了问题,我愿意切换到不同的 api。

我想实际存储一个包含多个字段和多个附件的文档。

0 投票
0 回答
490 浏览

java - 由于缺少 EmbeddedServletContainerFactory bean,SpringApplication 无法启动嵌入式容器无法启动 EmbeddedWebApplicationContext

Vertx 3.2.1 中的 Spring Boot 部署

我正在尝试部署在 vertx 框架中使用 Spring Boot 开发的服务。

这些服务在 Spring Boot 中开发并使用 Gradle 进行部署。以下是我的开发环境 a) Java 版本 - 1.8 b) Spring boot 版本 - 1.2.8.RELEASE c) Gradle 版本 - 2.0 d) Vertx 版本 - 3.2.1。

使用命令vertx run samplevertx.java -cp sampleFAT.jar启动 vertx 应用程序。当我启动 vertx 应用程序时,抛出以下异常

我尝试了其他成员发布的以下解决方案,但我没有运气。

解决方案 1解决方案 2解决方案 3解决方案 4

我已经在 build.gradle 文件中添加了必要的注释和依赖项,但是问题仍然存在。

论坛里有人可以帮我解决这个问题吗?

0 投票
2 回答
2630 浏览

java - 如何在不发送回复的情况下测试异步 vertx 事件总线处理程序

我有两个用 java vertx 编写的微服务。他们通过事件总线进行通信。第一个发送消息,第二个接收消息。

第一个想法:仅在单元测试中回复 Vertx 事件总线消息。

我想测试消息正在被正确处理,因此我在第二个微服务上编写单元测试来检查回复

现在我必须在我的消费者中发送回复,但我只想在测试中这样做,我不需要在生产中发送回复。我不想消耗 cpu 和网络在生产中发送回复。所以我正在寻找的是这样的:

第二个想法是在cdelmas 评论之后出现的,在我自己的回答中

0 投票
1 回答
101 浏览

java - 链接 Observable & Emitting / 将原始 Emit 传递给订阅调用

我有一个用例,我正在消费消息,保存它们然后回复成功或失败。mongo insert 返回一个 Observable,因此我可以使用 flatmap 进行链接。问题是 insert Observable 发出插入的结果,但我需要从第一个 observable 发出的原始 Message 发出来回复。因此,为了完成这项工作,我在第一个 Observable 的订阅中运行插入,并在第二个订阅中回复。

我希望使用像 flatmap 这样的操作符以一种更具反应性的方式来实现这一点。我搜索了运算符列表,但没有找到我要查找的内容。

上面的代码是应该完成的方式还是有更好的方法?两个订阅者感觉不对劲。

0 投票
1 回答
6034 浏览

java - 如何从 main 方法启动 Vertx 3 Verticle?

如何从 main 方法启动 Verx 3 Verticle?我已经弄清楚如何从单元测试开始它,入门指南解释了如何构建一个胖罐子。但是,为了调试、分析等目的,我如何简单地从主要方法开始呢?

0 投票
2 回答
10543 浏览

java - 在 Eclipse 中停止 vertx verticle

我正在关注Jenkov 关于vertx 的教程。这里我有两个文件:

MyVerticle.java:

和 VertxVerticleMain.java:

运行后在 Eclipse 的控制台中VertxVerticleMain.java看到"MyVerticle started!"了但不知道怎么调用stopMyVerticle

Jenkov 说,当 Vert.x 关闭并且您的 Verticle 需要停止时,将调用 stop() 方法。我究竟如何关闭我的 Vert.x 并停止这个 Verticle?我想MyVerticle stopped!在控制台中看到。

0 投票
3 回答
5314 浏览

java - Handling multipart form in Vertx

I have got a multipart form with some text fields and some upload files. I need to handle this multipart post request in vertx handler so that all the uploaded files (variable number) should be read in chunks (for memory effeciency purpose). The moment I read the chunks (in foreach loop), I want to stream that out directly to the file. For multipart with text fields, I want to simply store the values to my model object.

I am quite new to vertx and therefore looking for a code snippet to achieve this but couldnt find it anywhere on the vertx documentation.

0 投票
1 回答
540 浏览

vertx3 - 如何从 vert.x 3.2 中的多个 Verticle 实例安全地写入一个文件?

我不想使用记录器或数据库服务器,而是将信息从可能的许多 Verticle 实例中附加到一个文件中。

有不同版本的异步写入文件的方法。我可以假设 vertx 处理写入之间的同步,以便在使用那些标记为“异步”的方法版本时这些不会干扰吗?似乎有一条规则,可以依靠 vertx 在开箱即用的并发处理之间提供所有隔离。但是在写入文件访问的情况下是这样吗?

您能否在答案中包含一个代码片段,该代码片段显示如何从许多 Verticle 实例中以尽可能精细的粒度打开和写入一个文件,例如用于记录请求。