vertx学习

写在前面

新公司用到了vertx，所以这里学习下。

源码 。

1:vertx是啥？

是个框架吗？不是。只是一个工具类，只不过提供的功能比较全面，如http，websocket，tcp，json处理，定时任务,文件IO等。

2：Vert.x Core

核心对象io.vertx.core.Vertx。

2.1：定时器

// 使用vertx执行定时执行任务
@Test
public void timerWithVertx() throws Exception {Vertx vertx = Vertx.vertx();vertx.setPeriodic(1000, id -> {// 这个处理器将会每隔一秒被调用一次System.out.println("timer fired!");});Thread.sleep(999999);
}

输出：

timer fired!
timer fired!
timer fired!
timer fired!
timer fired!
timer fired!

2.2：简单的http调用

@Test
public void httpCall() throws Exception {Vertx vertx = Vertx.vertx();HttpServer server = vertx.createHttpServer();server.requestHandler(request -> {// 服务器每次收到一个HTTP请求时这个处理器将被调用request.response().end("hello world!!!");});// 监听端口9999server.listen(9999);Thread.sleep(999999);
}

测试：

E:\workspace-idea\dongshidaddy-labs-new>curl http://localhost:9999
hello world!!!

2.3：获取文件大小

// 获取文件大小
@Test
public void fileSizeTest() throws Exception {Vertx vertx = Vertx.vertx();FileSystem fs = vertx.fileSystem();Future<FileProps> future = fs.props("d:\\test\\starter.zip");future.onComplete((AsyncResult<FileProps> ar) -> {if (ar.succeeded()) {FileProps props = ar.result();System.out.println("File size = " + props.size());} else {System.out.println("Failure: " + ar.cause().getMessage());}});
}

运行：

File size = 69281

2.4:组合多个future，任意一个失败则失败

// 组合多个future，任意一个失败则失败
@Test
public void CompositeFutureTest() throws Exception {Vertx vertx = Vertx.vertx();HttpServer httpServer = vertx.createHttpServer();httpServer.requestHandler(request -> {// 服务器每次收到一个HTTP请求时这个处理器将被调用request.response().end("hello world!!!");});HttpServer netServer = vertx.createHttpServer();netServer.requestHandler(request -> {// 服务器每次收到一个HTTP请求时这个处理器将被调用request.response().end("hello world!!!!");});Future<HttpServer> httpServerFuture = httpServer.listen(8889);Future<HttpServer> netServerFuture = netServer.listen(9998);// 所有的成功才算是成功// 1：如果是希望其中一个成功就算是成功，则可以使用any方法// 2：如果是希望获取返回结果，则可以使用resultAt方法接受一个整数，和future的list一一对应// 3：如果是希望不论成功和失败所有的future都执行则可以使用join，虽然所有的future都会执行，但同all必须是所有的future都成功才算是成功，否则算是失败CompositeFuture.all(httpServerFuture, netServerFuture).onComplete(ar -> {if (ar.succeeded()) {// 所有服务器启动完成System.out.println("8889,9998全部监听成功");} else {// 有一个服务器启动失败System.out.println("yyyy");}});Thread.sleep(999999);
}

运行：

8889,9998全部监听成功

2.5:使用verticle实现http服务器

Verticle是vertx提供给我们用来封装一个具体功能的对象，可以更好的进行管理，提供生命周期的能力等！！！使用vertx的话，一般使用这种方式来进行编程。

  • 定义一个http的verticle
public class MyVerticle1 extends AbstractVerticle {private HttpServer server;public void start(Promise<Void> startPromise) {server = vertx.createHttpServer().requestHandler(req -> {req.response().putHeader("content-type", "text/plain").end("Hello from Vert.x!");});// Now bind the server:server.listen(8080, res -> {if (res.succeeded()) {System.out.println("bind 8080 suc!");startPromise.complete();} else {System.out.println("bind 8080 failed!");startPromise.fail(res.cause());}});}@Overridepublic void start() throws Exception {System.out.println("verticle 1 start !!!");}
}
  • 部署
@Test
public void verticleTest1() throws Exception {Vertx vertx = Vertx.vertx();//1: 如果是想利用多核提高并发性能，也可以部署多个verticle实例，如下：/*DeploymentOptions options = new DeploymentOptions().setInstances(16);vertx.deployVerticle("com.mycompany.MyOrderProcessorVerticle", options);*/// 2:传入配置/*JsonObject config = new JsonObject().put("name", "tim").put("directory", "/blah");DeploymentOptions options = new DeploymentOptions().setConfig(config);vertx.deployVerticle("com.mycompany.MyOrderProcessorVerticle", options);获取配置：传入之后，这个配置可以通过 Context 对象或使用 config 方法访问。这个配置会以 JSON 对象（JsonObject）的形式返回， 因此您可以用下边代码读取数据：System.out.println("Configuration: " + config().getString("name"));*/vertx.deployVerticle(new MyVerticle1(), res -> {if (res.succeeded()) {// 部署成功打印部署id，可以通过其来撤销部署，如下：/*vertx.undeploy(deploymentID, res -> {if (res.succeeded()) {System.out.println("Undeployed ok");} else {System.out.println("Undeploy failed!");}});*/System.out.println("verticle 1 deploy suc, deploy id is: " + res.result());}});Thread.sleep(999999);
}
  • 测试
bind 8080 suc!
verticle 1 deploy suc, deploy id is: 6d64fec4-89dc-4ff8-b254-cd43920584f8E:\workspace-idea\dongshidaddy-labs-new>curl http://localhost:8080
Hello from Vert.x!

2.6:一次性计时器

// 一次性计时器
@Test
public void timerTest1() throws Exception {Vertx vertx = Vertx.vertx();long timerID = vertx.setTimer(1000, id -> {System.out.println("And one second later this is printed");});System.out.println("First this is printed, timerID is: " + timerID);Thread.sleep(999999);
}

运行：

First this is printed, timerID is: 0
And one second later this is printed

2.7:周期性计时器.

// 周期性计时器
@Test
public void timerTest2() throws Exception {Vertx vertx = Vertx.vertx();// 1：取消计时器 vertx.cancelTimer(timerID);// 2：如果您在 Verticle 中创建了计时器， 当这个 Verticle 被撤销时这个计时器会被自动关闭。long timerID = vertx.setPeriodic(1000, id -> {System.out.println("And every second this is printed");});System.out.println("First this is printed, timerID is: " + timerID);Thread.sleep(999999);
}

运行：

First this is printed, timerID is: 0
And every second this is printed
And every second this is printed
And every second this is printed
...

2.8:通过eventbus生产和发布消息

可用于同一进程内的模块解耦：

// 通过eventbus生产和发布消息
@Test
public void eventyBusTest() throws Exception {Vertx vertx = Vertx.vertx();// 订阅消息EventBus eb = vertx.eventBus();MessageConsumer<String> consumer = eb.consumer("news.uk.sport");// 1:带有确认的，可以像下边这样发送和接收消息/*接收者：MessageConsumer<String> consumer = eventBus.consumer("news.uk.sport");consumer.handler(message -> {System.out.println("I have received a message: " + message.body());message.reply("how interesting!");});发送者：eventBus.request("news.uk.sport", "Yay! Someone kicked a ball across a patch of grass", ar -> {if (ar.succeeded()) {System.out.println("Received reply: " + ar.result().body());}});*/consumer.handler(message -> {System.out.println("I have received a message: " + message.body());});// 发布消息System.out.println("发布消息：" + "Yay! Someone kicked a ball");eb.publish("news.uk.sport", "Yay! Someone kicked a ball");Thread.sleep(999999);
}

运行：

发布消息：Yay! Someone kicked a ball
I have received a message: Yay! Someone kicked a ball

2.9:json支持测试

// json支持测试
@Test
public void jsonTest() throws Exception {JsonObject object = new JsonObject();object.put("foo", "bar").put("num", 123).put("mybool", true);System.out.println(object.getInteger("num"));
}

运行：

123Process finished with exit code 0

2.10:tcp支持

private static Vertx vertx = Vertx.vertx();
// tcp支持
@Test
public void tcpTest() {NetServer server = vertx.createNetServer();// 1：若想想要监听随机端口可以指定端口号为0，后续可以调用 actualPort 方法来获得服务器实际监听的端口// tcp server端server.listen(1234, "localhost", res -> {if (res.succeeded()) {System.out.println("Server is now listening!");} else {System.out.println("Failed to bind!");}});
}

运行：

写在后面

参考文章列表

Vert.x Core 文档手册 。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/146693.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

2D 3D 工业组态技术 meta2d JavaScript

2D 3D 工业组态技术 meta2d JavaScript

本心、输入输出、结果 文章目录 2D 3D 工业组态技术 meta2d JavaScript前言2D 3D 工业组态技术 meta2d JavaScript 简介2D 3D 工业组态技术 meta2d JavaScript 特性丰富的组态能力0代码数据通信组态的应用多端适配能力强大的扩展能力追求卓越性能丰富的组件库资源广泛的应用场景…
阅读更多...
C语言变量与常量

C语言变量与常量

跟着肯哥&#xff08;不是我&#xff09;学C语言的变量和常量、跨文件访问、栈空间 栈空间还不清楚&#xff0c;期待明天的课程内容 C变量 变量&#xff08;Variable&#xff09;是用于存储和表示数据值的名称。 主要包括四个环节&#xff1a;定义、初始化、声明、使用 在我刚…
阅读更多...
什么是BT种子！磁力链接又是如何工作的？

什么是BT种子！磁力链接又是如何工作的？

目录 一.什么是BT&#xff1f;1.BT简介&#xff1a;1.1.BT是目前最热门的下载方式之一1.2.BT服务器是通过一种传销的方式来实现文件共享的 2.小知识&#xff1a;2.1.你知道吗BT下载和常规下载到底有哪些不同2.2.BT下载的灵魂&#xff1a;种子2.3.当下载结束后&#xff0c;如果未…
阅读更多...
122. 买卖股票的最佳时机 II

122. 买卖股票的最佳时机 II

给你一个整数数组 prices &#xff0c;其中 prices[i] 表示某支股票第 i 天的价格。 在每一天&#xff0c;你可以决定是否购买和/或出售股票。你在任何时候 最多 只能持有 一股 股票。你也可以先购买&#xff0c;然后在 同一天 出售。 返回 你能获得的 最大 利润 。 示例 1&…
阅读更多...
Java实现的插件化策略模式

Java实现的插件化策略模式

Java实现的插件化策略模式 目录结构实现BaseDealAnno.java(注解)BasePluginEnum.java(枚举)BaseDealFactory.javaContextBaseDealListener.java(核心类)BaseDealHandler.java(接口)BaseAudioService.java(可扩展多个)验证目录结构 com.demo.mytest ├── strategy │ ├──…
阅读更多...
mysql客户端navicat的一些错误合集

mysql客户端navicat的一些错误合集

关于mysql的客户端的使用的一些问题 问题描述&#xff1a; 在使用navicat prenium客户端的时候&#xff0c;连接数据库出现 Table ‘performance_schema.session_variables’ doesn’t exist 错误 解决方案&#xff1a; 首先找到mysql的bin目录 然后winR 进入到cmd界面 输入…
阅读更多...
《循环双向链表》（带哨兵位的头节点）

《循环双向链表》（带哨兵位的头节点）

目录 ​编辑 前言&#xff1a; 关于双向循环带头链表: 模拟实现双向循环带头链表&#xff1a; 1.typedef数据类型 2.打印链表 3.初始化链表&#xff1a; 4.创建节点 5.尾插 6.头插 7.尾删 8.头删 9.寻找节点 10.在节点前插入 11.删除指定节点 单链表和双链表的区别…
阅读更多...
解析：什么是生成式AI？与其他类型的AI有何不同？

解析：什么是生成式AI？与其他类型的AI有何不同？

原创 | 文 BFT机器人 快速浏览一下头条新闻&#xff0c;你会发现生成式AI似乎无处不在。事实上&#xff0c;一些新闻标题甚至可能是通过生成式AI编写的&#xff0c;例如OpenAI旗下的ChatGPT&#xff0c;这个聊天机器人已经展现出了生成看起来像人类所写文本的惊人能力。 当人们…
阅读更多...
maptalks三维地图网址

maptalks三维地图网址

三维 地址: http://examples.maptalks.com/examples/cn/gltf/gltf-marker/shader
阅读更多...
Redis实现延时队列-工具类

Redis实现延时队列-工具类

Redis实现延时队列-工具类 RedisDelayQueueUtil第一种方式：优点：缺点：第二种方式：优点：缺点：总结：RedisDelayQueueUtil 依赖： <dependency><groupId>org.springframework.boot
阅读更多...
简朴博客系统测试报告

简朴博客系统测试报告

文章目录 一. 项目简介二. 测试概要三. 测试环境四. 测试执行概况及功能测试1. 手工测试1.1 手动测试用例编写1.2 执行的部分测试用例 2. 自动化测试Selenium2.1 编写测试用例2.2 自动化测试代码 3. 测试结果 五. 发现的问题 一. 项目简介 简朴博客系统是采用前后端分离的方式…
阅读更多...
《Effective C++》条款17

《Effective C++》条款17

以独立语句将newed对象置入智能指针 class A {...}; int g() {...} int f(shared_ptr<A> a,g()) {...} int main() {f(shared_ptr<A> (new A), g()); } 假如你想通过主函数里的语句进行调用f函数。虽然看上去没有什么问题&#xff0c;但是实际上可能会造成内存泄漏…
阅读更多...
【QML】警告Name is declared more than once

【QML】警告Name is declared more than once

1. 问题&#xff1a; qml函数中的不同块中定义同名变量&#xff0c;报警&#xff1a;Name is declared more than once 举例&#xff1a; function test(a){if(a "1"){var re 1;console.log(re);}else{var re 2; //这里会报警&#xff1a;Name is declared mor…
阅读更多...
asp.net core mvc 之 依赖注入

asp.net core mvc 之 依赖注入

一、视图中使用依赖注入 1、core目录下添加 LogHelperService.cs 类 public class LogHelperService{public void Add(){}public string Read(){return "日志读取";}} 2、Startup.cs 文件中 注入依赖注入 3、Views目录中 _ViewImports.cshtml 添加引用 4、视图使用…
阅读更多...
Scala---样例类+隐式转换

Scala---样例类+隐式转换

样例类(case classes) 1、概念理解 使用了case关键字的类定义就是样例类(case classes)&#xff0c;样例类是种特殊的类。实现了类构造参数的getter方法&#xff08;构造参数默认被声明为val&#xff09;&#xff0c;当构造参数是声明为var类型的&#xff0c;它将帮你实现set…
阅读更多...
Python每日一练@前言

Python每日一练@前言

Python每日一练前言 导读 人生苦短&#xff0c;我用Python 大家好&#xff0c;我是鹅不糊涂 欢迎大家来到Python每日一练 好处 加强编程能力: 每日一练可以帮助提升编程技能&#xff0c;通过解决各种编程问题和挑战&#xff0c;你能够不断锻炼自己的逻辑思维和解决问题的能力…
阅读更多...
顺序表（数据结构与算法）

顺序表（数据结构与算法）

✅✅✅✅✅✅✅✅✅✅✅✅✅✅✅✅ ✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨✨ &#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1f33f;&#x1…
阅读更多...
2023.11.17 hadoop之HDFS进阶

2023.11.17 hadoop之HDFS进阶

目录 HDFS的机制 元数据简介 元数据存储流程:namenode 生成了多个edits文件和一个fsimage文件 edits和fsimage文件 SecondaryNameNode辅助NameNode的方式: HDFS的存储原理 写入数据原理: 发送写入请求,获取主节点同意,开始写入,写入完成 读取数据原理:发送读取请求,获取…
阅读更多...
vim——“Linux”

vim——“Linux”

各位CSDN的uu们好呀&#xff0c;今天&#xff0c;小雅兰的内容是Linux的开发工具——vim。下面&#xff0c;我们一起进入Linux的世界吧&#xff01;&#xff01;&#xff01; Linux编辑器-vim使用 vim的基本概念 vim的基本操作 vim正常模式命令集 vim末行模式命令集 vim操…
阅读更多...
【Linux网络】从原理到实操，感受PXE无人值守自动化高效批量网络安装系统

【Linux网络】从原理到实操，感受PXE无人值守自动化高效批量网络安装系统

一、PXE网络批量装机的介绍 1、常见的三种系统安装方式 2、回顾系统安装的过程&#xff0c;了解系统安装的必要条件 3、什么是pxe 4、搭建pxe的原理 5、Linux的光盘镜像中的isolinux中的相关文件学习 二、关于实现PXE无人值守装机的四大文件与五个软件的对应关系详解 5个…
阅读更多...
最新文章

Copyright @ 2022~2023