- 综合排序
- 最热优先
- 最新优先
Vertx-client框架-高性能 HTTP 请求框架
<artifactId>vertx-web-client</artifactId> <version>4.5.10</version></dependency>构建全局的 Vertx：通过配置VertxOptions WebClient client ; //全局超时时间 private static final long TimeOut = 3000L; static { //配置vertxOptions 参数 VertxOptions vertxOptions = new VertxOptions(); //The default number of event loop threads public static final int DEFAULT_EVENT_LOOP_POOL_SIZE = 2 * CpuCoreSensor.availableProcessors(); vertxOptions.setEventLoopPoolSize (100); //默认是cpu核心数*2， Vertx vertx = Vertx.vertx(vertxOptions); //配置客户端的配置信息 HttpClientOptions
47710编辑于 2024-11-14- 来自专栏Spark学习技巧
高性能:MYSQL异步客户端
bigdata.spark.DaoUtil; import com.google.common.collect.Lists; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions max_pool_size", 20) .put("user", "root") .put("password", "password"); VertxOptions vo = new VertxOptions(); vo.setEventLoopPoolSize(10); vo.setWorkerPoolSize(20);
4.8K20发布于 2018-12-07 - 来自专栏悠扬前奏的博客
Vert.x-Core-0.写在前面
1.1 Vertx对象配置 创建Vertx时能够进行一些配置，例如： Vertx vertx = Vertx.vertx(new VertxOptions().setWorkerPoolSize(40) ); VertxOptions对象有诸多选项以供配置，例如集群（clustering），高可用（high availability），池大小（pool sizes）等等。
1.1K40发布于 2019-05-28 - 来自专栏Spark学习技巧
Flink通过异步IO实现redis维表join
dependency> 完整的案例： package org.datastream.AsyncIO; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions RedisOptions(); config.setHost("127.0.0.1"); config.setPort(6379); VertxOptions vo = new VertxOptions(); vo.setEventLoopPoolSize(10); vo.setWorkerPoolSize(20
3.8K40发布于 2019-12-27 - 来自专栏技术墨客
Vert.x源码-创建集群 原
VertxFactoryImpl.clusteredVertx(VertxOptions options, final Handler<AsyncResult<Vertx>> resultHandler new VertxImpl(options, resultHandler);//创建Vertx实例 } 图1启动集群 在VertxImpl的构造方法中，若需要创建集群，则执行： VertxImpl(VertxOptions 如下： getClusterManager(VertxOptions options) { if (options.isClustered()) { if (options.getClusterManager
2.1K30发布于 2018-08-15 - 来自专栏Lansonli技术博客
2021年大数据Flink（四十六）：扩展阅读 异步IO
io.vertx.core.AsyncResult; import io.vertx.core.Handler; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions root") .put("password", "root") .put("max_pool_size", 20); VertxOptions options = new VertxOptions(); options.setEventLoopPoolSize(10); options.setWorkerPoolSize package cn.it.extend; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions; import io.vertx.redis.RedisClient vo = new VertxOptions(); vo.setEventLoopPoolSize(10); vo.setWorkerPoolSize(20);
1.6K20发布于 2021-10-11 - 来自专栏乐百川的学习频道
Vert.x学习笔记（一） Vert.x 核心包
VertxOptions options = new VertxOptions(); options.setWorkerPoolSize(20); Vertx vertx2 = Vertx.vertx(
3.7K101发布于 2018-01-09 - 来自专栏技术墨客
Vert.x工具—使用Dropwizard Metrics对指标进行监控（Metrics使用教程）
(String[] args) { // 使用DropwizardMetricsOptions配置创建单机Vertx实例 Vertx vertx = Vertx.vertx( new VertxOptions 想了解点这里：http://my.oschina.net/chkui/blog/708639） 首先，需要像下面这样创建一个Vertx实例： Vertx vertx = Vertx.vertx(new VertxOptions
3.3K20发布于 2018-08-15
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号