问题标签 [vert.x]

这是我的问题的一些背景 - 我正在使用 NodeJS 来处理 HTTP(S) 请求的均匀驱动、非阻塞、反应器模式优势。单节点实例由于其单线程特性而在必须执行计算或耗时任务时无法很好地扩展。我的 NodeJS HTTP(S) 处理程序将数据发布到 Redis 服务器（LPUSH 命令）。

现在我想编写一个 Redis 客户端，它可以使用来自 Redis 服务器的数据（BRPOP 命令），然后处理（某种 CPU 密集型计算）它。我知道 Java，所以我更喜欢用 Java 编写这个数据处理器。刚才我在这里 @ http://www.youtube.com/watch?v=8ClYUo_A3h0阅读了这个关于 Vert.X 的精彩视频，这也比 NodeJS 更好地处理非阻塞 IO 和 CPU 密集型操作。

我现在必须使用 Redis 客户端，因为其他组件正在生产中使用它们。

所以现在如果我必须为 Redis 客户端使用基于 Java 的解决方案，Vert.X 是否适合这里？如果是，那么是否有任何可用的开源库？

提前致谢。

我们正在为我们的 websockets 解决方案使用 vert.x sockJS 实现。当 vert.x 一个接一个地快速发送一些消息时，一些消息将很晚才到达客户端。延迟消息仅在发送心跳时到达。知道这怎么可能吗？

我们通过将 sockjssocket.write() 方法放在同步块中临时解决了这个问题，但这感觉有点像 hack。我们将它放在同步块中的原因是因为我们认为它与并行写入套接字缓冲区有关。

亲切的问候，

大安

I am looking for a method in RxJava that behaves like the zip method, but without returning any new observable.

I have two observables, one emitting RxMessage objects and the other one RxHttpClientResponse objects. I want some kind of method that receives both objects and executes a function. That's all, without returning a new observable that emits new elements.

Any suggestion?

Thanks in advance

我正在尝试使用 Vert.x 和 RxJava 压缩到 observables。我不知道我是否误解了某些东西，或者这只是某种错误。这是代码。

我想使用收到的消息中的信息发出 HTTP 请求，然后压缩两个 observables、事件总线和 HTTP 响应，以便使用来自 HTTP 响应的信息回复消息。

我没有收到我发送的消息的任何回复。

提前致谢！

我正在尝试编写一个简单的网络服务器，该服务器将使用 java 中的 vertx 从本地文件系统提供一个 html 文件。出于某种原因，尽管我在资源文件夹中有我的 web/index.html，但下面的代码找不到该文件。我正在使用 IntelliJ，它会将这个文件夹复制到它为项目生成的类文件夹中。如果我给出绝对路径，它会按预期工作。我在做什么错或如何确定“web”文件夹是否是类路径的一部分？顺便说一句，我已经通过 IntelliJ 以及使用“mvn exec:java -Dexec.mainClass="test.vertx.VertxDriver" 的终端运行它进行了测试，但得到了相同的结果 - 找不到资源。

我已经安装了 vertx 并通过询问版本来验证它将运行给

然后，我从安装页面复制并粘贴了示例 server.js 代码，该代码应该在我转到 URL 时生成一个显示“Hello world”的网页，但我收到 No data received with 并且 Chrome 有 ERR_EMPTY_RESPONSE 以获取更多详细信息。（网址是本地主机：8080）。验证防火墙（暂时）关闭。

Hello i'm newby in Vertx. Today i implemented very simple vertx app with python But it is not working

Here is python code

But i got a error like below

C:\dev\tools\vert.x-1.3.0.final>vertx run app.py Cannot find verticle vertx.web-server-v1.0

i already installed the module in $VERTX_HOME\mods and javascript version of the sample is works well,

Could u please kindly mentoring me?

我在这里找到了一个使用 .jks 文件设置用 Java 编写的 Vert.x SSL 服务器的示例：http: //vertx.io/core_manual_java.html#ssl-servers。

有谁知道如何直接使用 .crt 和 .key 文件设置用 Java 编写的 Vert.x SSL 服务器，而不将它们转换为 .jks 文件？

有没有人幸运地尝试使用 vertx bihind 公司代理？我已经尝试了任何可能的方法来向 vertx 提供代理信息。到目前为止没有任何效果。

设置环境变量 http_proxy= http://mycorporate.proxy.com:8080 - 不走运

设置环境变量 VERTX_OPTS='-Dhttp.proxyHost=mycorporate.proxy.com -Dhttp.proxyPort=8080' - 不走运

设置环境变量 http.proxyHost=mycorporate.proxy.com http.proxyPort=8080 没有运气

在 vertx 命令中注入额外的 echo 我可以看到代理相关的参数正在正确传递给 JVM，但仍然无法下载所需的模块（“vertx run hello.js”显然在尝试下载 io.vertx~lang-rhino~ 2.0.0-最终版）

代理本身没问题 - 我将它用于 maven、sbt 和其他需要代理的不同东西没有问题 在家使用的同一台笔记本电脑可以通过下载 io.vertx~lang-rhino~2.0 成功运行“vertx run hello.js” .0-final（第一次运行）

我刚刚开始为我们公司的需求评估 vertx，这是我第一个阻碍我进一步尝试做出决定的瓶颈。到目前为止，我必须按照以下步骤作为解决方法： 1 从家里运行并在 sys-mods 中获取所需的任何模块。2 回到办公室后，手动将模块上传到测试服务器上的 sys-mods。显然，这不是运行任何东西的正常方式。

我是一名 Scala 程序员，从开发人员的角度理解 Akka。我还没有查看 Akka 库的代码。已经阅读了 Akka 模型中的两种类型的参与者——基于线程的和基于事件的——但没有大规模运行 Akka，我没有配置 Akka 以进行生产的经验。我对 Vert.x 完全陌生。因此，从选择的角度构建我想知道的反应式应用程序堆栈 -

1. Akka 和 Vert.x 的消息传递模型有很大不同吗？如何？
2. Akka 的actors 和Vert.x 的verticles 缓冲消息的数据结构有很大不同吗？