一个优雅的异步解决方案，可以将文件从S3从Vertx worker verticle发送到客户端
。
异步解决方案是一种非阻塞的处理方式，它可以在处理长时间运行的任务时保持应用程序的响应性能。在云计算领域中，异步解决方案经常被用于处理大文件的上传和下载等场景，其中涉及到从云存储服务（如S3）中获取文件，并将其发送到客户端。
在这个异步解决方案中，Vertx worker verticle被用作后台任务处理的容器。Vertx是一个开源的高性能异步应用框架，它提供了轻量级的、基于事件驱动的编程模型，非常适合构建异步应用。通过使用Vertx worker verticle，我们可以将文件处理任务分发给后台的工作线程，以避免阻塞主线程。
文件从S3获取到Vertx worker verticle后，可以在后台进行各种处理，例如数据解析、格式转换等。一旦文件处理完成，Vertx worker verticle可以将文件发送给客户端，通常通过HTTP协议进行传输。
这个异步解决方案的优势包括：
- 高性能和高并发：通过使用异步处理，可以更好地利用计算资源，提高应用程序的处理能力和响应速度，从而实现高性能和高并发。
- 提升用户体验：由于异步解决方案可以避免阻塞主线程，因此可以保持应用程序的响应性能，提升用户体验。
- 可扩展性：通过将任务分发给后台的工作线程，可以轻松地扩展应用程序的处理能力，以适应不断增长的用户需求。
应用场景包括但不限于：
- 文件上传和下载：异步解决方案可以在处理大文件的上传和下载过程中提供更好的性能和用户体验。
- 数据处理和分析：在云计算中，异步解决方案可以用于处理大规模的数据处理和分析任务，例如数据清洗、数据转换、数据挖掘等。
- 图片和视频处理：异步解决方案可以应用于对图片和视频进行处理和转码等任务。
腾讯云相关产品推荐：
- 对象存储（COS）：腾讯云对象存储是一种高可靠、低成本、高扩展性的云存储服务，适用于存储和处理各种类型的文件。
- 云函数（SCF）：腾讯云云函数是一种事件驱动的无服务器计算服务，可以在无需管理服务器的情况下运行代码，非常适合处理异步任务。
- 云监控（CM）：腾讯云云监控是一种全方位的监控服务，可以帮助用户实时监控云上资源的性能和运行状态，提供性能指标和报警功能。
请访问以下链接获取更多关于腾讯云相关产品的详细介绍：
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云云函数（SCF）：https://cloud.tencent.com/product/scf
- 腾讯云云监控（CM）：https://cloud.tencent.com/product/cm
相关·内容
2回答
我正在尝试扩展一个应用程序，该应用程序对外部应用程序执行阻塞调用以获取一些数据(请求和响应顺序并不重要)
由于它是vertx文档中描述的阻塞调用，因此我使用worker verticle并将worker pool设置为5，并且我已经部署了worker verticle的5个实例。
当我提交多个查询时(当我测试时，我只触发了3个查询)，尽管我的verticle被定义为具有多个实例的worker，具有足够的worker线程来并行处理我的请求，但它们看起来并不是按顺序处理的(参见下面的日志)。
我还尝试创建了一个master verticle和4个worker verticle (处理阻塞调用)，其
浏览 14提问于2016-09-25得票数 3
回答已采纳
我有几个主要用java(使用spring和hibernate)编写的微服务。我将vertx用于rest apis和非阻塞事件。在每个API调用中都有一个jwt令牌，其中包含非常基本的用户信息，如用户名。我可以从vertx RoutingContext的jwt令牌中提取用户名。 现在，每当hibernate实体发生更改或保存新实体时，我都要审计数据库中的用户名。但是在将事件传递给处理DB操作的worker verticle之后，我没有用户名，除非我在每次请求时都在eventbus中传递它。我想知道在请求的生命周期中，我们是否可以有任何上下文，在其中我可以在worker verticle中持久化
浏览 11提问于2020-01-08得票数 1
回答已采纳
在将HTTP服务器部署为worker verticle时，是否有其他方法可以获取等待由worker线程处理的大量请求？我需要一个https://vertx.io/docs/vertx-dropwizard-metrics/java/#_pool_metrics的替代品。
浏览 48提问于2020-06-18得票数 0
事情是这样的，假设在Hazelcast上有两个垂直星团。Verticle 1通过事件总线向Verticle 2发送大量消息。V2使用这些消息，将它们的内容分成块，并将这些块插入到数据库中。问题是，当块被插入时，一些消息不会被Vertile2使用。Vertile1报告它在30秒内没有收到回复。
问题是，什么是处理大量消息的最佳方法，以便可以使用消息？我从vertx.executeBlocking开始，然后尝试创建单独的共享worker executor并使用它执行。我的最后一次尝试是部署新的verticle，它在"start“方法中进行处理。
推荐的是什么？
浏览 4提问于2021-04-14得票数 0
当我运行以下代码时：
import io.vertx.core.*;
import io.vertx.core.eventbus.MessageConsumer;
import io.vertx.core.json.JsonObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
class TestVerticle extends AbstractVerticle {
final Logger logger = LoggerFactory.getLogger(TestVerticle.class.getName
浏览 0提问于2016-11-01得票数 1
回答已采纳
新手警报。
我正在尝试用Vertx编写一个简单的模块，它每10秒轮询一次数据库(PostGres)，并将结果推送到客户端。我正在考虑将阻塞代码(通过JDBC查询数据库)限制在一个worker verticle中，而上面的其他层是完全非阻塞和异步的。
该模块将被打包为jar并分发到不同的应用程序(通常是webapps)，这些应用程序可以通过javascript桥订阅事件总线。
我这里的问题是，在一个集群环境中，我有5个webapp进程在运行vertx模块，我如何确保只有一个vertx verticle查询数据库。我不希望所有的verticle都查询数据库并增加更多的负载。或者有不同的思考方式来解
浏览 1提问于2017-04-14得票数 0
我在理解Vertx异步模型和Future的行为方式方面有一些问题…… 在我的应用程序的启动代码中，我检查一些条件，如数据库访问和其他凭证，然后在启动应用程序的核心之前启动几个管理verticle (config verticle、http admin verticle等)。代码的结构如下： Vertx vertx = null;
Vertx.clusteredVertx(opts, ar -> {
if(ar.failed()) {
System.exit(-1);
}
else {
vertx = ar.result();
Future<V
浏览 12提问于2019-03-25得票数 0
回答已采纳
我是Vert.x的新手，我想实现一个工作者verticle池来使用BoneCP进行数据库查询。然而，我对如何“调用”它们工作以及如何在它们之间共享BoneCP连接池感到有点困惑。
我在Vertx DeploymentManager 中看到，start(Future)方法是同步调用的，然后verticle会一直保存在内存中，直到取消部署。在start方法完成之后，调用worker verticle上的方法的正确方式是什么？如果我部署了许多verticle实例(使用DeploymentOptions.setInstances())，Vertx会在它们之间进行负载均衡吗？
我看到Vert.x附带了一
浏览 0提问于2016-12-30得票数 0
我已经写了一个简单的Websocket应用程序，它有一个服务器端和一个客户端端。它在我本地的Windows系统(Eclipse)上运行得很好。当它被部署在亚马逊网络服务EC2(Ubuntu)上时，问题就开始了。虽然服务器verticle似乎没有问题，并侦听分配的端口，但当在同一系统上运行的Websocket客户端verticle尝试连接到服务器时，它会收到来自服务器的连接被拒绝消息。我甚至检查了从外部系统通过浏览器连接到Websocket -即使连接失败。但是，当我在同一台机器上运行Http server verticle时，我可以毫无问题地连接到它并从服务器接收消息。我已在AWS实例的所有端
浏览 0提问于2017-10-23得票数 1
1回答
vertx中的MDC日志记录
、、、、
我计划在我的rest应用程序中使用vertx，它使用的是slf4j框架。我在某处读到，你不应该在vertx中使用MDC，因为MDC是线程特定的，而vertx是线程不可知的。但我在服务开始时设置了MDC变量，该服务从一个verticle调用，并在结束时调用MDC.clear()。你觉得这有什么问题吗。我认为它将会在一个线程内--端到端的事件处理。
浏览 26提问于2019-02-22得票数 1
我正在写。使用命令行启动hello-vorld.js时，如下所示：
D:\Progs\vertx\vert.x-2.1M5\bin\vertx.bat run D:\Workspaces\runtime-EclipseApplication\Vertx2\hello-vorld.js
我犯了两次同样的错误：
Failed in deploying verticle
java.lang.IllegalStateException: No language implementation known for prefix D
at org.vertx.java.platform.impl.
浏览 3提问于2014-02-11得票数 1
回答已采纳
1回答
Vertx自动部署
、、、、
我最近一直在研究Vertx文档，并想知道通用自动部署策略 for Vertx应用程序是什么？
假设我用服务器语言编写了我的应用程序。
Verticle1: vertictles/1 verchine.js
Verticle2:眩晕/2种垂直型.
Verticle3:眩晕/3 verdicch.java
从文档中，我只发现了以下内容：
//通过递阶路径部署java垂直线：
vertx.deployVerticle("com.mycompany.MyOrderProcessorVerticle")；
//部署一个JavaScript垂直线
vertx.deployVerticle(
浏览 3提问于2016-11-21得票数 1
回答已采纳
我有两个操作step_1()和step_2()，希望在step_1()之后执行step_2()。
对于普通的java，这将是：
step_1();
step_2();
对于vertx，我必须使用vertx-作文()。我说的对吗？
根据，我不需要期货的顺序代码。
“如果你想按顺序处理每一个请求，你就不需要未来。”
那么，我怎么才能不使用期货呢？
我不知道这是否重要:执行这段代码的Vertx是一个"Worker"-Verticle。
@Override
public void start(Future<Void> fut) throws IOException
浏览 13提问于2017-06-12得票数 4
回答已采纳
我们在Hazelcast客户端中使用ReplicatedMap。客户端和服务器都是4.2.1版。 映射非常小(<10个条目，每个值小于100个字节)。客户端仅读取地图，该地图在服务器上不经常更新。 我们期望ReplicatedMap.get是非阻塞的，但是在长时间运行的性能测试中，我们开始从vertx (监控阻塞线程)收到类似下面这样的警告。第一个错误出现在6小时后，所以它不容易重现。 有什么方法可以实现非阻塞get吗？或者我们是否需要添加一个维护ConcurrentHashmap的EntryListener？ 澄清:这里真正的问题不是阻塞vertx (这可以通过将调用移动到Vertx
浏览 28提问于2021-11-19得票数 1
回答已采纳
我有一台Vertx服务器，它有一个垂直工作线程，可以异步处理S3操作的请求。我们需要一个解决方案来通过我们的服务器将文件从S3传输到客户端。tsegismont回答了之前的一个问题Streaming S3 object to VertX Http Server Response，但该建议似乎会阻止vertx线程。文件传输属于单独的垂直方向。这个推荐的解决方案在worker垂直系统中不起作用，因为How can I send RoutingContext object from routing vertical to some other vertical using vertx.eventB
浏览 18提问于2021-01-17得票数 3
我有一个程序，我在其中部署了一个worker verticle (vertx版本3.6.3)。在worker verticle中，我使用Vertx WebClient库发出了一个HTTP请求。我的vertx工作线程池大小是20，事件循环池大小是10。在发出http请求之后(在send()调用之后)，我阻塞了使用completable发出HTTP请求(工作线程)的工作线程。当我阻塞工作线程时，HTTP请求永远不会响应，而且总是超时。它在工作线程未被阻塞时进行响应。我想，如果我阻塞工作线程，池中还有其他工作线程来支持HTTP请求。我在这里做错了什么？此外，我已经启用了网络日志活动，但在日志中看不
浏览 73提问于2020-03-22得票数 1
1回答
在Vertx官方文档中，我读到了以下段落
If a result can be provided immediately, it will be returned immediately, otherwise you will usually provide a handler to receive events some time later.
Because none of the Vert.x APIs block threads that means you can use Vert.x to handle a lot of concurrency using just a sm
浏览 0提问于2018-04-11得票数 6
我正在尝试开发一个数据库服务代理，并使用扩展io.vertx.reactivex.core.AbstractVerticle的verticle，这样我就可以在数据库调用中使用rxJava语义。问题是，当我编写代码生成服务代理时，我会得到这样的结果：
ServiceVertxEBProxy.java:[37,1] a type with the same simple name is already defined by the single-type-import of io.vertx.core.Vertx
数据库服务负责处理共享的dbclient，我是通过以下方式完成的：
publ
浏览 21提问于2018-09-09得票数 0
我正在使用vertx executeBlocking进行实验，以模拟我所做的实时场景
vertx.setPeriodic(1000, id ->{
counter += 1;
LOGGER.info("invoked method {} ",counter);
vertx.executeBlocking(future -> {
int counterFinal = counter;
String result = service.blockingMethod("cycle "+counterFi
浏览 1提问于2018-05-24得票数 0
回答已采纳
当运行由start.vertx.io生成的示例测试时，得到以下信息。
Vertx 4.0Java 11和Java 15 10
java.util.concurrent.TimeoutException:
The test execution timed out. Make sure your asynchronous code includes calls to
either VertxTestContext#completeNow(), VertxTestContext#failNow() or Checkpoint#flag()
我为它添加了一个GitHub操作。
@BeforeEa
浏览 1提问于2020-12-11得票数 0
回答已采纳
我解释了我的问题，我有一个定义了所有路由的竖线。我有一些简单的java类，其中包含我在verticle中根据路由调用的方法。例如，我的downloadFile()方法位于MyFile类中，如下所示：
public class MyFile {
public final void downloadFile(RoutingContext rc, Vertx vertx) {
final HttpServerResponse response = rc.response();
response.putHeader("C
浏览 0提问于2018-08-15得票数 1
我编写了一个verticle，使用routingContext.fileUploads()从vertx文件系统中读取多部分表单数据。现在我想写一个测试用例。我正在尝试上传一个文件到vertx文件系统，这样我就可以调用我的verticle从文件系统读取文件并测试我的代码。
浏览 4提问于2020-05-23得票数 0
下面的类是我的worker verticle，在这个类中，我想要在一个名为events-config的通道上，在接收到来自事件总线的消息时执行阻塞代码。
目标是无限期地生成和发布json消息，直到我在events-config通道上收到停止操作消息。
我使用executeBlocking来实现所需的功能。然而，由于我无限期地运行阻塞操作，vertx阻塞了线程检查器转储警告。
问题：
是否有办法禁用阻塞线程检查器？？以下代码是否符合在vertx中按需执行无限循环的最佳实践？如果没有，你能建议最好的方法吗?
public class WorkerVerticle extends AbstractV
浏览 2提问于2019-03-03得票数 0
我们在verticle中使用rabbitmq来接收消息。我们将Vert.x Common SQL接口包装为一个单独的jar文件作为DBHelper。
在rabbitmq verticle start()中初始化DBHelper。
每次有消息到达时，它都会调用DBHelper来更新数据库中的一列。但是当两个消息到达非常接近的点时，我们观察到的是，两个db操作在不同的事件循环中执行，这导致db中的列没有最新的值。例如，来自rabbitmq的两条消息(一条带有一个值，另一条带有b值)(b值消息在value消息之后)。DB中的列的值是a而不是b。
以下是一些代码片段：
rabbitmq verticl
浏览 1提问于2016-06-07得票数 0
我在试着决定在部署我的弗蒂克勒斯时该走哪条路。我得出的结论是，我应该将Vert.x作为我的运行时环境，而不是自己创建自己的Vertx实例，并开始从主方法部署我的应用程序。然而，我更喜欢在每个应用程序中都有一个主要的方法，这使我能够很好地控制我的服务、服务发现和其他东西。
我在Vertx中找不到一篇关于这一点的文档。或者Pros和Cons。有人能帮帮我吗？
Shell启动：
cd /verticles # the location of the verticle jar
vertx run io.vertx.sample.RandomGeneratorVerticle
-cp /verticle
浏览 4提问于2021-03-17得票数 2
2回答
单元测试垂直部署
、、、
我有一个简单的垂直线，它从属性文件中读取配置并加载到vertx配置中。我编写了一个单元测试来测试这个垂直线的部署，测试失败的可能原因是这个位置的属性文件不可用。
当我运行测试时，不管我是否更改了属性、文件名或路径，单元测试都会通过，处理程序表示垂直线已经成功部署。
我在这里做错什么了吗？下面是我的代码
import io.vertx.config.ConfigRetrieverOptions;
import io.vertx.config.ConfigStoreOptions;
import io.vertx.core.DeploymentOptions;
import io.vertx.co
浏览 6提问于2017-06-13得票数 2
回答已采纳
有没有人能让这个例子起作用？
我尝试连接到正在运行的Kafka和Vertx-kafka-client 3.5.0，但没有成功。更奇怪的是，运行这个小代码片段，但根本没有任何kafka集群，消费者说它订阅成功。
public class KafkaConsumerExampleVerticle extends AbstractVerticle {
public static void main(String[] args) throws Exception {
KafkaConsumerExampleVerticle verticle = new KafkaConsum
浏览 17提问于2018-01-09得票数 1
我有一个vertx服务器应用程序，其中我收到了单个客户端请求，并且从服务器上，我需要进行两个阻塞调用。例如，一个调用后端系统A，另一个调用后端系统B。我希望对这两个系统进行两个并发调用。我需要等待两个调用的响应，然后合并两个调用的两个数据，然后将响应发送回客户端。我不知道如何在worker verticle中做到这一点。
谁能推荐一下vertx最好的方法是什么？
浏览 3提问于2015-05-07得票数 1
我刚刚开始学习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
1回答
当收到来自客户端的调用和响应时，我尝试通过事件总线发送数据。 一切都很正常，直到我在事件总线上添加了拦截器。 以下是代码： public class TestVerticle extends AbstractVerticle {
@Override
public void start(Promise<Void> promise) {
Router router = Router.router(vertx);
vertx.exceptionHandler(globalExceptionHandler -> {
浏览 14提问于2020-07-13得票数 1
使用vertx.io 3.0.0和Java 1.8.0_60
我正在尝试从JAVA启动一个javascript垂直线。我找到了下面的文档，它展示了如何实现它。但实际上在我目前的情况下，这是行不通的。
//main class
vertx.deployVerticle("com.mycompany.services.DiscountServices");
vertx.deployVerticle("com.mycompanyservices.SupplierServices");
vertx.deployVerticle("com.mycompany.se
浏览 3提问于2015-10-05得票数 2
回答已采纳
1回答
我有一段代码要进行单元测试。
this.vertx.eventBus().consumer(VERTICLE_ID).toObservable()
.subscribe(msg -> doSomethingCool());
和我的消费者方法：
private void doSomethingCool(){
// Some cool stuff.
}
现在，我想在不使用powermockito的情况下对doSomethingCool()进行单元测试(我想要有代码复盖率)，并且我不想让我的方法可见(公共)。我该怎么做呢？在vertx中有什么钩子可以做到这一点吗？
浏览 1提问于2018-02-28得票数 0
下面是垂直线
package com.api.redis.gateway.verticle;
import java.util.UUID;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.web.RoutingContext;
import io.vertx.redis.RedisClient;
import io.vertx.redis.RedisOptions;
public class SimpleRestChild extends SimpleRestServer{
RedisClient clien
浏览 0提问于2018-09-13得票数 1
我在k8集群上运行了一个基于vertx的java微服务。当安装了一个新的吊舱时，在init期间，我会间歇性地得到这个异常。将vertx核心和vertx web版本从3.5.3升级到3.9.3，但没有帮助。在经历了这些异常之后，这个应用程序仍然很活跃，而且还很好。我想知道这件事的根源。
这是在init过程中发生的。以下是我在init期间所做的事情
this::deploymentHandler); 部署垂直线A: vertx.deployVerticle(新Verticle_A()、serverOpts、vertx.deployVerticle)
this::deploymentHandler)
浏览 10提问于2020-10-13得票数 1
我正在尝试一个非常简单的试探性方法，第一次使用vertx对MySql进行插入和选择。对我来说很有趣的是，我可以构建和调试应用程序，但我从未得到过ar.succeeded或失败。
如何执行下面的插入和选择？我必须以某种方式附上client.query并订阅它吗？我完全被卡住了。我在互联网上看到的所有例子都遵循这种方法。
package com.mybank
import io.vertx.kotlin.mysqlclient.mySQLConnectOptionsOf
import io.vertx.kotlin.sqlclient.poolOptionsOf
import io.vertx.
浏览 0提问于2020-11-18得票数 1
在Windows上使用Eclipse时，带有错误配置的cluster.xml的vertx Verticle在Eclipse控制台中显示以下错误：
11:46:18.536 [hz._hzInstance_1_dev.generic-operation.thread-0] ERROR com.hazelcast.cluster - [192.168.25.8]:5701 [dev] [3.5.2] Node could not join cluster. A Configuration mismatch was detected: Incompatible joiners! expected:
浏览 2提问于2015-11-05得票数 0
1回答
我正在开发一个使用Vertx的应用程序。在它中，我有一个NetClient，并使用Vertx断路器来保持与服务器的持续连接。我现在正在做一些事情，需要在某个时候取消部署这些Verticle，但当我这样做时，似乎出于某种原因，断路器仍然活着，即使在verticle.undeploy成功之后。 我试着在取消部署之前调用断路器的close方法，但即使这样，我也得到了非常不一致的结果。第一次它工作，但第二次，断路器仍然活着。 你知道启动后能不能完全关掉断路器？ 使用: Java 8和Vertx 3.8.1
浏览 31提问于2020-08-19得票数 0
回答已采纳
嗨，我已经部署了像这样的vertx垂直线，现在我想要asynchResult访问这个内部类。我已经经历了很多的帖子，但没有找到任何解决办法。
container.deployVerticle("com.demo.vertx.FirstVert", snmp_trap_listener_count, new AsyncResultHandler<String>() {
public void handle(AsyncResult<String> asyncResult) {
if (a
浏览 2提问于2015-01-29得票数 0
回答已采纳
我已经使用Kotlin协程扩展成功地创建了一个带有少量verticle的影子jar，并且能够通过vertx run命令行运行它们，同时指定到我的jar的路径，除了一个verticle在启动时创建了一个telnet shell，但出现了异常：
java.lang.NoClassDefFoundError: io.vertx.ext.shell.term.TelnetTermOptions
at io.vertx.kotlin.ext.shell.term.TelnetTermOptionsKt.telnetTermOptionsOf(TelnetTermOptions.kt:119)
浏览 8提问于2019-12-01得票数 0
1回答
我是vert.x的新手，我正在尝试通过调用我的new服务来进行单元测试。我需要一个使用testng测试with服务的示例。
当我用junit5做这件事时，它用下面的代码工作得很好
@BeforeMethod
private static void deploy_verticle(Vertx vertx , VertxTestContext testContext) {
vertx.deployVerticle(new MainVerticle(), testContext.completing());
}
@Test
public void getTestFalse(Vertx v
浏览 13提问于2020-02-18得票数 1
我对Vert.x3还不熟悉，我正试图为一个简单的事件处理程序编写一个单元测试。现在，我所要做的就是检查测试中的垂直线是否委托给正确的组件，该组件是使用Mockito作为模拟创建的。
我的测试代码看起来类似于：
@Rule
public final RunTestOnContext vertxRule = new RunTestOnContext();
@Before
public void setUp(TestContext context) {
vertx = vertxRule.vertx();
//verticle is set up with mock delegat
浏览 0提问于2016-09-21得票数 2
1回答
Vertx无法编译外部库
、、、、
我正在构建一个vertx服务器，使用IntelliJ作为我的集成开发环境，我的项目在那里构建得很好。但是，当我尝试从终端运行我的服务器时，由于以下编译错误而失败，但我不确定原因。它的编译和运行非常好，没有来自终端的aws依赖，我已经在IntelliJ内部测试了库是否被检测到。我希望在这个问题上能得到一些帮助！
/ExampleProject/src/main/java/Server/Server.java:4: error: package com.amazonaws.auth.profile does not exist
import com.amazonaws.auth.profile.P
浏览 0提问于2016-11-20得票数 0
有一个简单的方法来设置在创建所有眩晕？时将使用的选项吗？
在交互式调试器中调试Vertx时，需要设置一些选项以防止Vertx监视狗代码(例如BlockedThreadChecker)抛出异常。
问题是，我不确定如何设置Vertx选项，因此从Vertx.vertx()工厂方法返回的所有Vertx实例都将使用它们。
例如,
public static void main(String[] args){
VertxOptions vertxOptions = new VertxOptions();
vertxOptions.setBlockedThreadCheckInterval(
浏览 4提问于2017-04-03得票数 0
在Vert.x中是否有配置deployment options、instances、worker等的“合理”方法？
我希望能够在部署时“摆脱”DeploymentOptions，并将其放在Vert.x所理解的JSON/YAML配置文件中--最好被“环境”分割，就像Spring所做的那样。
这是我目前正在使用的：
class MainVerticle : AbstractVerticle() {
private val logger: Logger = LoggerFactory.getLogger(this.javaClass.name)
override fun start(fut
浏览 6提问于2017-07-19得票数 3
回答已采纳
所以这有点偷偷摸摸的，它不是100%发生的，但情况是这样的：
我创建了一个JUnit集成类，声明了一个在上下文上运行的Rule，然后从规则中提取了vertx对象。然后我将新的verticle部署到vertx，如果尝试部署超过3-4个verticle，我会为每个verticle得到以下结果：
Jan 09, 2017 2:43:33 PM io.vertx.core.impl.ContextImpl
SEVERE: Unhandled exception
java.lang.IllegalStateException: Result is already complete: succeeded
浏览 0提问于2017-01-09得票数 1
回答已采纳
1回答
我有一个vertx应用程序，其中部署了多个verticle (HttpVerticle.java)实例和多个垂直B实例(AerospikeVerticle.java)。飞机上的眩晕需要共用一个AerospikeClient。HttpVerticle侦听端口8888并使用事件总线调用AerospikeVerticle。我的问题是：
正在使用sharedData来共享单例客户端实例吗？是否还有其他建议/更清洁的方法？我计划创建和共享更多这样的单例对象(cosmos db客户端、meterRegistry等)。在申请中。我计划使用sharedData.localMap以类似的方式共享它们。是否可以使
浏览 7提问于2021-11-09得票数 1
我想对Restful进行基准测试，所以我向它发送了大量的请求，以度量吞吐量和延迟。我使用Vert.x WebClient创建一个客户机。
首先，我从AbstractVerticle创建AbstractVerticle扩展并在start方法中创建WebClient。
public class BenchmarkVerticle extends AbstractVerticle {
@Override
public void start(Future<Void> future) {
WebClient client = WebClient.create(
浏览 0提问于2018-04-18得票数 1
回答已采纳
最近我开始用Kotlin在Vert.x中编程，这个问题对于我们使用Vertx工具包的任何技术都是通用的。我创建了我的verticles，但在这些verticles中我有业务逻辑，我想知道最佳实践是什么：
1.将逻辑分离到一个独立的类，在verticle中实例化它并执行它的操作，只留下verticle接收消息并将消息传递给eventBus。
2.尽可能在同一个verticle中实现逻辑。
下面我给出了一个代码示例，但正如您所看到的，这是verticle本身的逻辑。从设计的角度来看，这是很好的，或者您应该将它放到一个独立的类中，并将该垂直部分仅用于在总线上接收和发送消息的操作
class MyAP
浏览 0提问于2019-10-31得票数 0
我正在摆弄我的两个顶点，我想在集群模式下启动它们。
下面是我的两个verticle的start-Methods：
第一个垂直：
public static void main(String[] args) {
VertxOptions options = new VertxOptions();
options.setClustered(true);
options.setClusterManager(new HazelcastClusterManager());
Vertx.clusteredVertx(options, res -> {
浏览 0提问于2016-08-23得票数 0
回答已采纳
1回答
我们有一个非集群的vertx应用程序，我们使用事件总线在眩晕之间进行内部通信。
垂直线A从总线中消耗，执行HTTP请求，并通过总线将响应发送回.
垂直线B只是请求执行该HTTP请求.
当由竖线B执行“高”请求卷时，问题就出现了。然后，使用者开始越来越慢地接收事件(大概是因为他们在事件总线中排队)。对于8个请求/秒，总线占用最多3-4秒的时间来消耗事件。当请求/秒被提升时，消耗它的时间可能超过30秒，因此会触发总线超时。
问题是，Verticle执行HTTP操作的速度非常快(~200 is )，所以我不太明白为什么请求会卡在总线中。
我们尝试过许多解决方案，但都没有奏效：
部署多个垂直A实例，工
浏览 6提问于2022-04-12得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
