冷门的Java高性能开发工具/框架-Vert.x 与 Java中的全能霸主Spring
简 介
Vert.x 是一个用于在 JVM 上构建反应式/响应式应用程序的工具包.
依托于全异步Java服务器Netty，并扩展了很多其他特性，以其轻量、高性能、支持多语言开发而备受开发者青睐.
可以参考我的上一篇文章,来自官网的翻译:Eclipse Vert.x
接下来,我们尝试对比下Spring,让大家有个大致的感受:
Vert.x 如同逍遥派,武功奇幻,风格飘逸,变化多端.
Spring犹如武当派,风格一板一眼,功力浑厚.
Vert.x vs Spring 性能
Spring5加入了webflux,与Vert.x web 的两种都有基于 netty 的响应式 webmvc 框架.本质,思想上是一样的.但依然有一些区别!
Spring 5后,虽然也有Webflux,但受限于第三方包,大多是同步的,如常用的MyBatis,JPA以及大量的工具Jar包,所以.无法发挥出异步的全部威力.
而Vert.x的生态里,都是异步构建的,非常契合!
看看相对权威的评测.
https://www.techempower.com/号称各种web框架性能大乱斗,在这里的框架都追求极致的性能,虽然,并不能代表实际场景的一切,但是依然有一定的可比性,就当图个乐!
数据来源于techempower.com最后一期
单个查询
混合查询
Vert.x还是比较靠前,综合排名第11位,而Spring综合在67位
Vert.x vs Spring 生态
Vert.x生态可以查看
https://github.com/vert-x3/vertx-awesome）
和Spring的生态相比.
项目 | Spring | Vert.x |
核心 | Spring-Core | vertx-core |
Web | spring-webmvc | vertx-web |
JDBC | spring-jdbc | vertx-jdbc-client |
Redis | spring-data-redis | vertx-redis-client |
Kafka | spring-kafka | vertx-kafka-client |
微服务 | spring-cloud | vertx-hazelcast |
单元测试 | spring-junit 5 | vert.x-junit 5 |
注册中心 | Eureka / Nacos | Service Discovery |
配置中心 | Spring Cloud Config | Config |
熔断器 | Hystrix / Sentinel | Circuit Breaker |
太多就不一一列举了.......
基本上都有相对应的生态.....
但是,不得不说Vert.x还是比较小众,Spring在Java领域依然是绝对的霸主,Spring在资料,文档的丰富度,流行度上来说是更有优势.
除非追求极致的性能,Spring一般是更好的选择!
毕竟准时下班陪老婆孩子,比极致性能重要得多!
来个Demo感受一下
地址
:https://gitee.com/ParkJun/vertx4-reactive-template
项目结构与启动方法如上图
首先,定义了三个verticle,在vert.x项目中:
- verticle相当于1个执行模块，是vertx的部署单元。
- vertx可以部署多个verticle，且verticle之间可以互相通信。
- 因为vertx主要是个网络框架，所以在verticle中通常会启动server，如http或tcp。
ApiVerticle:HTTP服务,拥有对单表的CURD操作的Rest Api.
MigrationVerticle:用Flyway初始化数据库.
TcpVerticle:TCP服务的verticle.
@Override
public void start() {
final long start = System.currentTimeMillis();
deployMigrationVerticle(vertx)
.flatMap(x ->
deployApiVerticle(vertx)
).flatMap( x ->
deployTcpVerticle(vertx))
.onSuccess(success ->
LOGGER.info(LogUtils.RUN_APP_SUCCESSFULLY_MESSAGE.buildMessage(System.currentTimeMillis() - start)))
.onFailure(throwable ->
LOGGER.error(throwable.getMessage()));
}用异步的方式完成启动!
几个Rest Api
我们用PostMan测试接口
TCP服务是单独设计的协议,用两种方式实现了客户端,效果是一致的!
// 魔数，用来在第一时间判定是否是无效数据包，如java的coffee baby 1
// 版本号，可以支持协议的升级 1
// 序列化算法，消息正文到底采用哪种序列化反序列化方式，可以由此扩展，例如：json、protobuf、hessian、jdk 1
// 指令类型， 跟业务相关 1
// 请求序号，为了双工通信，提供异步能力 4
// 保留字段 4
// 正文长度 4
// 消息正文:如json,xmlTcpClient:用原始的Socket实现.
VertxTcpClient:用Vertx的NetClient实现.
public class VertxTcpClient extends AbstractVerticle {
private static NetSocket netSocket;
@Override
public void start() throws Exception {
NetClient netClient = vertx.createNetClient();
netClient.connect(9999, "127.0.0.1", connect -> {
if (connect.succeeded()) {
System.out.println("连接建立成功，开始发送数据！");
netSocket = connect.result();
byte magic =0x1A ;
byte version =0x01;
byte serializerType =0x01 ;
byte messageType =1 ;
int sequenceId =54321 ;
int extend =12345 ;
byte[] sequenceIdBytLen = BytesUtils.int2BytesBig(sequenceId);
byte[] extendBytLen = BytesUtils.int2BytesBig(extend);
Req v=new Req();
v.setToken("aaaaaaaaaaaaaaaaaaaaaaaaaaa");
String data = JSONUtil.toJsonPrettyStr(v);
int len = data.getBytes().length;
byte[] bytLen = BytesUtils.int2BytesBig(len);
byte[] b=new byte[1024];
b[0]=magic;
b[0]=magic;
b[0]=magic;
b[0]=magic;
Buffer.buffer();
Buffer buffer = Buffer.buffer()
.appendByte(magic)
.appendByte(version)
.appendByte(serializerType)
.appendByte(messageType)
.appendBytes(sequenceIdBytLen)
.appendBytes(extendBytLen)
.appendBytes(bytLen)
.appendBytes(data.getBytes());
netSocket.write(buffer);
netSocket.handler(resp -> {
System.out.println("接收到的数据为：" + resp.toString());
});
} else {
System.out.println("服务器连接异常");
}
});
}
public static void main(String[] args) {
Vertx.vertx().deployVerticle(new VertxTcpClient());
}
}
END
如果对您有帮助,请关注一下这个二流程序员!谢谢!
也可关注公众号,搜索 -> 高级面试工程师