（9）异步Mongo驱动的性能测试——响应式Spring的道

本系列文章索引《响应式Spring的道法术器》
前情提要 Spring WebFlux快速上手 | Spring WebFlux性能测试 | Spring WebClient性能测试
本文源码
藁城ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：18980820575（备注：SSL证书合作）期待与您的合作！

1.4.4 同步与异步数据库驱动的性能对比

许多数据库已陆续推出官方的异步驱动，在Spring Data Reactive中，已经集成了Mongo、Casandra、redis、CouchDB的异步驱动。

在Spring WebFlux中使用 Reactive Mongo的示例见Spring WebFlux快速上手。

这一节我们通过使用YSCB对MongoDB的同步和异步驱动的性能基准测试，来观察异步驱动的优势。

YCSB（Yahoo! Cloud Serving Benchmark）是雅虎开源的一款用于测试各类云服务/NOSQL/键值对存储的性能基准测试工具。YCSB很赞，使用起来很简单，我们就按照wiki介绍来操作即可。

1）准备YCSB

如果使用Windows，请参考这里来预先安装必要的软件和工具。

获取YCSB有两种方式，一种是直接下载压缩包：

curl -O --location https://github.com/brianfrankcooper/YCSB/releases/download/0.12.0/ycsb-0.12.0.tar.gz
tar xfvz ycsb-0.12.0.tar.gz
cd ycsb-0.12.0

另一种是基于源码构建：

git clone git://github.com/brianfrankcooper/YCSB.git
cd YCSB
mvn clean package

此时就可以使用bin/ycsb命令来进行性能测试了，运行一下：

usage: bin/ycsb command databse [options]

Commands:
    load        Execute the load phase
    run         Execute the transaction phase
    shell       Interactive mode

...

从上边的命令帮助可以看到，我们可以运行三种命令：

load，执行数据加载，也就是向数据库保存数据；
run，执行事务，比如更新、查询等；
shell，可以交互式地运行测试。

本节的测试主要用到load和run来进行数据的批量操作，先用load命令加载数据集，然后使用run命令测试数据操作。在YCSB中，测试的工作量由workload文件来定义。我们看到在workloads下有workload[a-f]几个配置文件，比如workloada：

# Yahoo! Cloud System Benchmark
# Workload A: Update heavy workload
#   Application example: Session store recording recent actions
#                        
#   Read/update ratio: 50/50
#   Default data size: 1 KB records (10 fields, 100 bytes each, plus key)
#   Request distribution: zipfian

recordcount=1000
operationcount=1000
workload=com.yahoo.ycsb.workloads.CoreWorkload

readallfields=true

readproportion=0.5
updateproportion=0.5
scanproportion=0
insertproportion=0

requestdistribution=zipfian

可见配置文件定义了记录条数、操作次数、以及不同的操作所占的百分比。比如上边readproportion和updateproportion都是50%，从注释也可以看出来，这模拟的是一种更新操作比较频繁的场景，可以模拟Web应用中保存session的场景。

几个workload的配置通过不同的read/update/scan/insert操作比例来模拟不同的场景。

我们可以通过如下命令对mongo运行基于workloada的load阶段的性能测试：

bin/ycsb load mongodb -P workloads/workloada

默认是连接localhost:27017的mongodb数据库，如果希望指定数据库连接信息，可以用-p参数指定：

bin/ycsb load mongodb -P workloads/workloada \
-p "mongodb.url=mongodb://192.168.0.101:27017/ycsb?w=1&maxPoolSize=32&waitQueueMultiple=20"

同时还指定了连接池最大数量和最多等待数量。

当然我们也可以通过命令参数覆盖workloada文件中的数值，比如：

bin/ycsb load mongodb -P workloads/workloada \
-p "mongodb.url=mongodb://192.168.0.101/ycsb?w=1&maxPoolSize=32&waitQueueMultiple=20"  \
-p recordcount=10000 -p operationcount=10000 -threads 20

此外，还用-threads指定了并发线程数为20。

以上这些是本次测试会用到的内容，其他更多关于YCSB的使用请参考wiki吧。

2）准备测试

本次测试的目标是对比Mongodb同步和异步驱动的性能，简单起见，从吞吐量和平均操作时长两个数据来衡量。纵向上，

比较不同数量的并发线程对两个数据的影响；
观察测试时的连接数变化。

连接数的变化可以通过mongostat命令来观察，如下图所示：

（9）异步Mongo驱动的性能测试——响应式Spring的道

上边运行的mongo-benchmark.sh是基于bin/ycsb命令编写的方便测试的脚本，并输出一些汇总数据（包括吞吐量和平局操作时长）方便查看，同时也会将每次bin/ycsb命令输出的详细内容保存到output目录下的文件中。
脚本可以在代码库中找到，如果mongo运行于localhost:27017，可直接用如下命令执行（在与bin同目录下）：
curl https://raw.githubusercontent.com/get-set/get-reactive/master/ycsb-mongo-shell/mongo-benchmark.sh | bash

图中上方是对同步驱动和异步驱动各自跑了一次基于workloada的load和run的测试，下方是mongostat的输出（每秒输出一行），从insert、query、update的数字可以找出四个橘×××的框标出的4个阶段。通过这些数据我们可以分析出：

load主要是加载数据集，因此会看到insert的数字增多，加起来是测试预设的30000条数据；类似的run主要是进行基于workload的操作测试，workloada是50/50的read/update，在mongostat的输出中也有体现。
load阶段同步和异步驱动的吞吐量分别为19801和25554，run阶段同步和异步的吞吐量分别为25706和27675，同步驱动略逊一筹；再观察insert、read和update操作的平均时长，可以得出同样的结论。
这次测试设置了20个线程对mongo数据库进行操作，在mongostat输出的conn列可以看到数据库连接个数的变化，对于同步的驱动来说，连接个数会从4个增加到25个，而对于异步的驱动来说，连接个数会从4个增加到7个。

通过这种方式，针对不同的线程数，观察两种驱动的性能数据并通过mongostat的数据记录连接数。

一、不限制连接数

为了观察连接数的变化，先不限制maxPoolSize（注释脚本中MAX_POOL_SIZE=8那一行）。最终结果如下：

（9）异步Mongo驱动的性能测试——响应式Spring的道