简 介

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的生态相比.

太多就不一一列举了.......

基本上都有相对应的生态.....

但是,不得不说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,xml

TcpClient:用原始的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

如果对您有帮助,请关注一下这个二流程序员!谢谢!

也可关注公众号,搜索 -> 高级面试工程师