在vertx事件总线上流式传输文件是否明智
在vertx事件总线上流式传输文件是一种明智的做法。Vert.x是一个开源的、响应式的、多语言的应用程序平台，它提供了一个事件总线来实现不同组件之间的通信。流式传输文件可以通过事件总线来实现高效的数据传输。
优势：
- 高效性：通过事件总线进行流式传输文件可以实现高效的数据传输，特别是对于大文件或者大量文件的传输。
- 异步处理：Vert.x的事件总线支持异步处理，可以在文件传输过程中进行其他操作，提高系统的并发性能。
- 可扩展性：事件总线可以方便地扩展到多个节点，实现分布式的文件传输，满足高并发和大规模的需求。
应用场景：
- 大文件传输：对于需要传输大文件的场景，使用事件总线进行流式传输可以提高传输效率和性能。
- 分布式系统：在分布式系统中，使用事件总线进行文件传输可以方便地实现节点之间的数据交换和共享。
推荐的腾讯云相关产品：
腾讯云提供了一系列与云计算相关的产品，以下是一些推荐的产品：
- 对象存储（COS）：腾讯云对象存储（COS）是一种高可用、高可靠、低成本的云存储服务，适用于存储和处理大规模非结构化数据。 链接地址：https://cloud.tencent.com/product/cos
- 云服务器（CVM）：腾讯云服务器（CVM）是一种弹性计算服务，提供安全、可靠、高性能的云端计算能力，适用于各种应用场景。 链接地址：https://cloud.tencent.com/product/cvm
- 云数据库MySQL版（CMYSQL）：腾讯云数据库MySQL版（CMYSQL）是一种高性能、可扩展、高可用的云数据库服务，适用于各种规模的应用。 链接地址：https://cloud.tencent.com/product/cdb_mysql
请注意，以上推荐的产品仅为示例，实际选择产品时应根据具体需求进行评估和选择。
相关·内容
2回答
我计划跨集群和跨web客户端使用vert.x事件总线。请您澄清事件总线是否安全以交换机密数据？如果我没有弄错事件总线使用JSON或简单的vertx兼容的数据类型，文档没有明确提到在传递事件总线时是否可以加密。如果有什么值得赞赏的例子。
浏览 7提问于2015-03-22得票数 3
回答已采纳
我正在使用VertX度量内置与普罗米修斯。在这里，我的代码设置：
try {
MicrometerMetricsOptions options = new MicrometerMetricsOptions()
.setPrometheusOptions(new VertxPrometheusOptions().setEnabled(true))
.setEnabled(true);
Vertx vert = Vertx.vertx(new VertxOptions().setMetricsOptions(opti
浏览 2提问于2020-09-18得票数 0
回答已采纳
在我的一个项目中，考虑到Vertx经过验证的性能记录，我决定将Vertx用于HTTP API。然后，因为应用程序在内部使用事件队列，所以我开始考虑是否应该使用Vertx event bus和verticles，而不是我通常使用的ArrayBlockingQueue。我对Vertx还很陌生，所以我不知道它有多合适。我有使用Akka和Actors的经验，它们非常符合要求，但我不确定Vertx event bus是否可以扩展到每秒100k事件？
浏览 60提问于2020-07-21得票数 1
Vertx 说，为了将sock JS连接到eventbus，人们将在客户端javascript中使用vertx-eventbus.js。获得此文件所述的gradle依赖项是：
compile 'io.vertx:vertx-web:3.4.1:client'
但是，在其他vertx依赖项所在的jCenter和/或mavenCentral repos中，gradle没有找到这种依赖关系。
我的问题：
1)如何在java服务器端gradle项目中正确地获得vertx-eventbus.js？
2)一旦解决了依赖关系，如何通过http服务器从类路径为vertx-eventbus.js
浏览 5提问于2017-05-27得票数 2
回答已采纳
1回答
我正在使用vertx4开发微服务，每个服务都由多个眩晕组成，所有服务都是使用下面的代码作为集群(Hazelcast)垂直部署的。
Vertx.clusteredVertx(options.setHAEnabled(isHa), (vertx) -> {
((Vertx)vertx.result()).deployVerticle(verticleName, (new DeploymentOptions()));
});
我正在为服务中的每个顶点调用上面的代码，并创建多个vertx对象或实例。
在cluster?Should中部署是正确的吗?我从clusteredV
浏览 4提问于2021-04-20得票数 1
回答已采纳
通过javascript使用vertx.clusteredVertx的用例是什么？
我可以在集群模式下从命令行启动vertx，使用：
vertx run server.js --cluster
我可以(在我的server.js文件中)使用以下命令创建另一个vertx实例：
var Vertx = require("vertx-js/vertx");
var options = {};
Vertx.clusteredVertx(options, function (res, res_err) {
if (res_err == null) {
var ver
浏览 0提问于2015-11-12得票数 3
我正试图在Ignite集群管理器中使用集群事件总线，集群vertx本身运行良好，集群vertx web也很好，现在我正在2 apache的集群中与集群事件总线进行斗争，在两台不同的机器上点燃JVMs。
我知道以下几点：
1-我们在文档中看到Ignite集群为集群Vertx执行以下操作:集群管理器不处理节点间事件总线传输，这是由Vert.x与TCP连接直接完成的。
2-现在的问题是如何正确处理两台不同机器之间的集群vertx事件总线，集群事件总线需要知道公共集群主机和公共集群端口，所以从附加的配置中，您能告诉我们如何知道公共集群主机，以及每台机器每个节点的端口，这样我们就可以在Ignite集群上
浏览 8提问于2016-12-02得票数 3
回答已采纳
1回答
我有两个眩晕，如下所示
首先，垂直线只是监听地址、测试和回复消息。
public class FirstVerticle extends AbstractVerticle {
@Override
public void start() {
Logger logger = LogManager.getLogger(FirstVerticle.class);
vertx.eventBus().consumer("test",message->{
logger.info("message received " + message.h
浏览 2提问于2020-12-10得票数 0
1回答
我正在检查，这是一个可以在几种不同JVM语言中运行应用程序的框架。
在中有大量的例子可用。
但问题是，(我还没有找到任何东西)，我们如何才能以真正的polyglot方式(同时使用所有受支持的JVM语言)编写Vert.x应用程序？
例如，如何编写使用以下文件的代码：Java.java、Kotlin.kt、Javascript.js、Ruby.rb。其中，每个语言的内部都有一个简单的函数来打印语言名称(例如，Ruby.rb打印ruby)。
例如，在使用此输入时：
$vertx run Polyglot.java
如何实现以下输出？
java, kotlin, javascript, ruby
编辑
浏览 3提问于2017-10-14得票数 1
1回答
这是一门让人眩晕的课程：
public class RequestResponseExample {
public static void main(String[] args) throws InterruptedException {
Logger LOG = LoggerFactory.getLogger(RequestResponseExample.class);
final Vertx vertx = Vertx.vertx();
final Handler<AsyncResult<String>> R
浏览 6提问于2022-02-07得票数 1
我正在尝试为Vertx web-client编写一个包装器，以便使用reactivestreams中的Publisher从服务器加载响应体： import org.reactivestreams.Publisher;
import io.vertx.reactivex.ext.web.client.WebClient;
interface Storage {
Publisher<ByteBuffer> load(String key);
}
class WebStorage implements Storage {
private final WebClient cl
浏览 74提问于2020-03-26得票数 0
当我需要在Vertx中创建新的垂直点时，有人能给我提供最佳实践吗？我知道每个垂直点都可以远程部署并放到集群中。然而，我仍然有一个问题，如何设计我的应用程序。我的问题是：
有很多垂直的东西可以吗？
例如，我创建了一个HttpServer，其中有许多用于服务的端点。我想做不同的子路线，并根据启用的功能(服务)设置它们。其中一些将启动长期进程，并将使用事件总线在系统中生成新的事件。这里最好的方法是什么？
例如，我可以将vertx作为参数传递到每个端点，并使用它创建路由器：
getVertx().createHttpServer() .requestHa
浏览 7提问于2016-12-29得票数 1
我正在尝试将twitter4j与vertx事件循环集成在一起，我不知道我这样做是否正确。虽然我是一个Node.js开发人员，但我对vertx还是新手，所以我熟悉事件循环/单线程概念。
在我的测试中，我想订阅twitter流并在vertx事件总线上发布该流。
我已经创建了一个不可知论的TwitterAPI类，它将把twitter流转换为一个可观察的流(稍后将链接到vertx )：
public class TwitterAPI {
public Observable<Status> getTwitterObservable() {
return Observa
浏览 2提问于2017-03-31得票数 1
2回答
上周，我阅读了有关vertx的文档。我不明白的是vertx处理程序是如何工作的？例如
public class Client extends AbstractVerticle{
@Override
public void start() throws Exception {
final HttpClient httpClient = this.vertx.createHttpClient();
this.vertx.setPeriodic(1000, handler->{
httpClient.getNow(8080,
浏览 2提问于2018-04-10得票数 3
回答已采纳
我正在开发一个应用程序，它将在浏览器上显示使用Ver.x从服务器接收的数据。因此，我有以下模块：
server.java:
NetServer server = vertxx.createNetServer();
server.connectHandler(new Handler<NetSocket>() {
@Override
public void handle(final NetSocket sock) {
System.out.println("A client has connected"
浏览 2提问于2015-03-04得票数 2
1回答
我在一个具有多种功能的VertX应用程序上编写，该应用程序可以访问数据库。每个数据库包代表一个java类。这些类中的每一个都可以实现为单例类。
我做了一个小的代表:两个眩晕，正在使用的database.doLoginUser。
package testInject;
import io.vertx.core.DeploymentOptions;
import io.vertx.core.Vertx;
public class App {
public static void main(String[] args) {
Vertx vertx = Vertx.ve
浏览 1提问于2020-11-20得票数 0
回答已采纳
我想用Hawkular从vert.x获得度量标准，但我有问题。以下是本教程的内容。
然后，我修改了vert.x 教程的代码
就像这样。
从这里开始
@Before
public void setUp(TestContext context) {
vertx = Vertx.vertx();
vertx.deployVerticle(MyFirstVerticle.class.getName(),
context.asyncAssertSuccess());
}
到这个
VertxOptions vertxOptions = new VertxOption
浏览 1提问于2017-05-09得票数 0
回答已采纳
我有一个vert.x程序。我正在创建一个消息使用者，并将其附加到vertx事件总线上的一个地址上。在稍后的程序中，我将取消该用户的注册。我如何知道消费者是否未成功注册？
下面的代码片段显示了如何在顶点事件总线上的地址上注册使用者
MessageConsumer<JsonObject> consumer = vertx.eventBus().consumer("my_channel", eventHandler)
稍后，我将取消对消费者的注册。
consumer.unregister( res -> {
if(res.succeeded()) { Syste
浏览 34提问于2022-03-28得票数 1
回答已采纳
1回答
我试着运行下一段代码，但是对于2.1.6顶点库发生io.vertx包没有发现问题。
或者，如果有人有一个带有Java和JS代码的小项目，请提供一个链接。
此外，我尝试了3.x.x版本，但它没有io.vertx方法。
import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.core.eventbus.EventBus;
import io.vertx.core.http.HttpServer;
import org.vertx.java.core.sockjs.SockJSServer;
浏览 2提问于2015-09-11得票数 0
回答已采纳
我刚刚开始学习Vert.x和如何编写Verticle。我想知道从应用程序服务器或Web服务器(如Tomcat )中部署Verticle是否有意义。例如：
public class HelloVerticle extends AbstractVerticle {
private final Logger logger = LoggerFactory.getLogger(HelloVerticle.class);
private long counter = 1;
@Override
public void start() {
vertx.setPeriodic(5000
浏览 4提问于2019-09-28得票数 0
我正在用vertx，vertx创建一个微服务。我想提供一个用于登录的MDC。
我想以类似于：的方式来做这件事
我不确定使用这种方法是否正确：
ContextInternal context = (ContextInternal) Vertx.currentContext();
context.localContextData().getOrDefault("userId", "defValue");
Vertx文档没有向我说明上下文是为每个处理程序执行创建的，还是上下文是唯一的，并在所有处理程序执行之间共享(使这种方法无效)。
浏览 0提问于2019-07-26得票数 0
我的请求处理程序
router.route("/clientController/*").handler(sockJSHandler);
我的活动总线是
eb.consumer("chat.to.server",message->{
System.out.println("Getting Request in Client Controller Event Bus");
JsonObject data = (JsonObject) message.body();
String classif
浏览 0提问于2016-05-26得票数 0
回答已采纳
一切都很好，是一个一体化的Vertx应用程序。但是当使用集群时，当使用Hazelcast集群时，在事件总线中得到上面的异常(没有通过错误流到处理程序)。由于JSON传递的一些数据很大，我假设数据被截断并导致这种情况。因此，如果您没有设置足够大接收/发送缓冲区大小，HTTP中也会发生同样的错误，我认为在Hazelcast中设置它们如下：
System.setProperty("hazelcast.socket.receive.buffer.size", "128000");
System.setProperty("hazelcast.socket.send
浏览 0提问于2014-07-09得票数 2
1回答
我正在开发数据报服务器，它监听特定端口上的消息，我们正在使用Vertx Java Framework来实现它。如果我在启动垂直应用时只在部署选项中指定一个实例，那么一切都会正常工作。一旦我指定了多个实例，我就会收到套接字绑定错误。据我所知，在一台机器上，一旦打开了一个套接字，如果我们再次尝试监听同一套接字，就会导致这个错误。但是为了利用多核处理器，我需要在同一垂直的多个实例之间共享数据报套接字。我不确定如何使用vertx框架来实现这一点。下面我已经提到了代码片段，我正在尝试实现同样的目标。请告诉我哪里出错了。
public class TestServer extends AbstractV
浏览 1提问于2017-01-31得票数 0
与Vert.x和JUnit5的简单集成测试可能类似于下面的代码块。
@Test
@Timeout(value = 10, timeUnit = TimeUnit.SECONDS)
void some_test(Vertx vertx, VertxTestContext testContext) {
// do nothing in this example.
}
这个简单的测试将等待10秒，然后由于超时而失败。我想知道是否有一个选项可以在不等待超时的情况下尽早失败这个测试。由于没有活动，Vert.x可以推断，如果测试还没有完成，测试就永远不会完成。没有活动，我的意思是没有运行的任务，也没有
浏览 5提问于2020-01-16得票数 3
回答已采纳
1回答
除了黑兹尔卡斯特之外，有谁对Vertx集群管理人员有过实际经验，对我们的要求有什么建议吗？
对于我们的实时传感器数据(，实时传感器数据)系统，我们有数百个JVM，但我们不需要或不希望事件总线跨越多个物理服务器。
我们在多个服务器上运行Vertx，但是如果我们不在所有服务器之间汇集一个事件总线(我们更喜欢在服务器之间传递消息)，那么我们的平台就不那么复杂了。
黑兹尔卡斯特不是我们的集群管理器。我们不需要在服务器之间发现它的对等点，但关键的是，Hazelcast的任何发布更改都意味着新客户端不能与运行前一个版本的现有运行客户端一起加入集群，因此，不可能将使用vertx 3.6.3编译的一个新的垂直
浏览 1提问于2019-03-08得票数 7
3回答
我正在尝试从前端到vertx后端建立一个sock.js连接。
我最初的尝试是这样的：
let token = '<the token>';
let data = {'Authorization' : 'Bearer ' + token};
let eb = new EventBus("http://localhost:8080/eventbus");
eb.onopen = function () {
eb.registerHandler('notifications', data, (err,
浏览 0提问于2017-06-06得票数 2
回答已采纳
1回答
据我所知，有两种类型的集群:水平集群和垂直集群。
我正在尝试使用vertx.io进行垂直集群。
我有两个vertx应用程序在两台不同的机器上运行。一个应用程序创建TCP服务器，而另一个应用程序创建HTTP服务器。现在我想在事件总线上发布一些消息，这些消息应该被垂直运行的TCP服务器监听。
我遵循vertx中的这些。我无法在even bus上监听HTTP服务器发布的消息。
Vertx支持垂直伸缩吗？
浏览 0提问于2016-01-18得票数 0
在将HTTP服务器部署为worker verticle时，是否有其他方法可以获取等待由worker线程处理的大量请求？我需要一个https://vertx.io/docs/vertx-dropwizard-metrics/java/#_pool_metrics的替代品。
浏览 48提问于2020-06-18得票数 0
我在3个不同的ec2实例上运行了一个Java服务。它们使用Hazelcast形成一个集群。下面是我的cluster.xml配置的一部分：
<join>
<multicast enabled="false"></multicast>
<tcp-ip enabled="false"></tcp-ip>
<aws enabled="${AWS_ENABLED}">
<iam-role>DEFAUL
浏览 7提问于2022-07-28得票数 0
回答已采纳
1回答
X版本是在JVM上构建反应性应用程序的工具包。
我想为基于JVM的自动可伸缩的RESTful后端API使用vertx。
到目前为止，我从文档中发现，默认情况下，它需要机器中的核数，假设您有N个内核，并为每个内核创建了N个线程，每个线程都是一个事件总线，每个线程都包含vertx实例。问题是，Vertx如何控制实例的数量？基于负载压力？
这个关于控制运行在给定线程上的Verticles数量的事情，我仍然不明白。请帮我清理一下这东西。让我们假设机器有4个核心，我编写了两个类作为AbstractVerticle扩展：
1)让一个数据库数据检索器(让我们称它为检索器或"R")
2)另一个
浏览 7提问于2016-11-20得票数 5
回答已采纳
5回答
我有一个提供视频剪辑的网站，我每天都有几千个移动用户，所以我想以一种可以在iphone和黑莓设备上观看的格式提供视频库。
ffmpeg或其他工具能否将视频转换成类似youtube为上述设备所做的流媒体格式？除了链接到文件本身之外，它还需要什么吗?或者它是否需要某种特殊的实现？
浏览 1提问于2009-12-28得票数 2
我在openfaas函数中使用Vert.x，我想使用vert.x事件总线在它们之间进行通信，但是我不知道如何在函数的外部使用事件总线。它在相同的功能中工作。我没有找到任何关于这方面的文档或资源。目前，我使用vertx java11模板作为openfaas函数，但我也希望使用python作为ml模型，并希望使用事件总线在它们之间进行通信。在开法斯有可能吗？
浏览 9提问于2021-12-13得票数 0
1回答
我被vertx的例子弄糊涂了。第一次看到文档时，我认为实例意味着事件循环线程的数量。
当我深入研究源代码(vertx2.1.2)时，我发现verticle实例意味着事件循环线程组中的一个任务。事件循环线程总是等待选择器并运行任务。
然后第一个问题来了：
是否有必要在vertx?中有垂直实例，因为vert流经一个事件循环只运行一次。更准确地说，事件循环线程运行垂直开始方法并丢弃它，它就像一个条目一样工作，仅此而已。
我的第二个问题是：
如何收集多个事件的结果？
场景
使用同一个处理程序实例在事件总线上发送多个查询
处理程序等待每个回调并修改标志。
如果标志到达线程，请执行一些工作。
浏览 1提问于2014-08-25得票数 0
背景：使用Vertx3.3.3Core和Java端的Web作为服务器，使用vertx-web-3.3.3-client.js作为带有sockjsclient1.1.2.js的客户机。
问题:在本地机器或局域网上，正在成功地从客户端连接到事件总线。当我通过代理时，wss事件总线连接被阻塞(在Firefox中，我看到"Firefox无法建立到“wss://.”的连接；在Chromium中，我看到"WebSocket连接到wss://.失败:在WebSocket握手过程中出错:意外响应代码: 400"，然后我看到"https ://./eventbus/./xhr_s
浏览 2提问于2017-03-06得票数 1
回答已采纳
我在vertx文档中看到了下面的语句，我想要理解的是，当进程完成或我们需要显式调用undeploy方法时，verticle将自动取消部署。
在垂直中自动清理如果你从垂直内部创建消费者和生产者，当垂直被取消部署时，这些消费者和生产者将被自动关闭。
谢谢。
浏览 12提问于2017-07-31得票数 0
我是Vert.x的新手，我准备做一个小例子，每次我从某个外部服务器读取当前时间时，我都会得到一个指向根路径的GET-request。我以为使用launch和awaitResult就可以为我处理异步部分，但是日志只告诉我线程阻塞了。对外部url的请求大约需要5到7秒。使用较快的url是可能的，但我有意使用较慢的url来感受Vert.x的异步方面。
有人能帮帮我吗？我在协程中做错了什么？
class MainVerticle : CoroutineVerticle() {
override suspend fun start() {
val server = vertx.c
浏览 132提问于2018-02-22得票数 1
回答已采纳
我不使用记录器或数据库服务器，而是从可能的多个垂直实例中将信息附加到一个文件中。
有用于异步写入文件的方法的版本。我是否可以假设vertx处理写操作之间的同步，以便在使用那些被标记为购进异步的方法的版本时不会发生干扰？似乎有一条规则可以依靠vertx提供并发处理之间的所有隔离。但是在写入文件访问的情况下是这样的吗？
请您在答案中包含一个代码片段，说明如何从多个具有最佳粒度的垂直实例(例如日志请求)中打开和写入一个文件。
浏览 1提问于2016-04-09得票数 0
回答已采纳
有办法为多个类注册编解码器吗？基本上，我的所有类都应该使用Jackson对象映射器来序列化。但是，似乎我必须为每个类创建一个自定义编解码器(尽管我可以使用泛型对其进行一些抽象)。
一个小代码示例：
编解码器：
class JacksonCodec<T>(private val mapper: ObjectMapper, private val clazz: Class<T>) : MessageCodec<T, T> {
override fun encodeToWire(buffer: Buffer, s: T) {
buffer.
浏览 4提问于2022-02-03得票数 1
回答已采纳
1回答
我是Vertx的新手，我怀疑不幸的是，堆栈溢出问题还没有解决。我有2核的ubuntu服务器，我想使用这段代码。
@Override
public void start() throws Exception {
vertx.deployVerticle(StringName, new DeploymentOptions().setInstances(2));
}
上面的垂直线是我个人网站的http服务器。说
这对于跨多个核很容易地扩展是有用的。例如，您可能有一个要部署的web服务器垂直线和您的计算机上的多个核心，因此您希望部署多个实例来使用所有的核心。
好吧，我有两个
浏览 1提问于2019-09-19得票数 1
回答已采纳
1回答
我有一个Quarkus应用程序，在那里我使用事件总线。
所讨论的代码如下：
@ConsumeEvent(value = "execution-request", blocking = true)
@Transactional
@TransactionConfiguration(timeout = 3600)
public void consume(final Message<ExecutionRequest> msg) {
try {
execute(...);
} catch
浏览 2提问于2021-07-09得票数 0
回答已采纳
我使用Vert.x 3实现websockets。
场景很简单:从客户端打开套接字，在顶点顶点工作者处执行一些“阻塞”的工作，以及当完成对客户端的响应时(通过打开的套接字)。
如果我做得对，请告诉我：
创建了VertxWebsocketServerVerticle。一旦websocket打开并从客户端发出请求，我将使用eventBus并将消息传递给
EventBusReceiverVerticle。在那我在做阻塞手术。
我实际上是如何将响应发送回VertxWebsocketServerVerticle并将其发送回客户端的？
代码：
主修班：
public static void main(St
浏览 1提问于2015-08-17得票数 1
我第一次接触到Vertx的EventBus，我意识到有两种方式可以提交消息。使用发送或发布方法。我问:使用这两种方法的实际区别是什么?在哪种情况下，它们使用每种方法？
浏览 0提问于2019-06-22得票数 6
回答已采纳
1回答
我有两个眩晕词叫"A“和"B”。两者都运行在不同的JVM实例中。现在，A向B发送一条信息：“操作成功。您可以自行解除部署”。当B收到这条消息时，它应该自行解除部署。
我尝试了两种选择: 1. vertx.close()；(a)如果在不同的命令提示符下打开竖线B。(b)如果没有在不同的命令提示符中打开垂直线B。2. vertx.undeploy(deploymentID()，)；B作为不同的cmd提示符打开，以及在同一个cmd提示符中打开(后台为垂直cmd prompt...runs )。
在1->(a)中，标线B是关闭的，但cmd提示仍然是打开的。在1->(b)中，
浏览 0提问于2016-09-30得票数 1
回答已采纳
2回答
我对vert.x完全陌生，我用JavaScript编写了一个hello world程序：
console.log("Hello, World");
当我从linux命令行(如果重要的话，在一个旧的ubuntu开发系统上)运行程序时，程序会运行，但永远不会退出：
hostname$ ./node_modules/.bin/vertx run server.js
Hello, World
Succeeded in deploying verticle
^Chostname$
我不得不按CTRL键来终止这个过程，这似乎是错误的。在我们的生产环境中，流程在完成时退出是可取的。
我发现了
浏览 1提问于2016-06-22得票数 1
背景：I使用JavaVert.xCore3.3.3和Web3.3.3作为EventBus服务器，并在Javascript中的Web客户机上使用Vert.x2.0.0和SockJS 1.1.1连接到EventBus EventBus。我是连接的，能够发送和接收消息，所有入站和出站流量都是开放的。一切正常运转。
在Java方面，我添加了一个SockJSHandler来处理任何路由到"/eventbus/*“的事件，这样我就可以处理来自JavaScript客户端的SockJS连接的事件。我能够正确地捕获BridgeEventType_s，如_BridgeEventType.REGISTER和
浏览 0提问于2017-01-24得票数 1
回答已采纳
我使用vertx.io发出了几个HTTP请求，程序的输入是一个包含几个完整URL的文件。检查vertx.io HttpClient，似乎只能查询主机，而不能查询完整的URL。例如:它将成功地查询，但会在类似于：之类的东西上失败
所以我的问题是：
是否可以使用Vertx.io本机HttpClient查询完整的HttpClient？
是否可以在vertx中使用其他HttpClients？例如，将Apache异步HTTP客户端与回调和vertx一起使用？
在谷歌上找不到任何好的答案。
提前感谢！
浏览 2提问于2016-02-18得票数 2
回答已采纳
我在Vert.x中有一个套接字处理程序，我知道如何在客户机到服务器(从Web浏览器到Web )和服务器组件到服务器组件的形式中通过EventBus发送数据。
现在，我有了一个JavaFX客户机，通过websockets连接到Vert.x套接字处理程序：
public void start() {
vertx.createHttpClient()
.setHost(Main.SOCKET_SERVER)
.setPort(8080)
.connectWebsocket("/chat/service", new Handler<WebSock
浏览 2提问于2015-08-17得票数 0
回答已采纳
1回答
我试图找出从Apache路由向外部Vert.x事件总线发送消息的最佳方法。
我看过骆驼-vertx库和vertx-骆驼桥，但这些库似乎用于运行在同一个JVM中的Camel和Vert.x之间的通信，而且我没有看到Camel和Vert.x分别运行的例子。
我的假设正确吗？ActiveMQ会成为Vertx和Camel之间的好桥梁吗？
浏览 3提问于2017-09-26得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
