189 8069 5689
本系列文章索引《响应式Spring的道法术器》
前情提要 Spring WebFlux快速上手 | Spring WebFlux性能测试 | Spring WebClient性能测试
本文源码藁城ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为成都创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：18980820575（备注：SSL证书合作）期待与您的合作！
许多数据库已陆续推出官方的异步驱动，在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来进行数据的批量操作，先用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命令来观察，如下图所示：
上边运行的
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个阶段。通过这些数据我们可以分析出：
insert的数字增多，加起来是测试预设的30000条数据；类似的run主要是进行基于workload的操作测试，workloada是50/50的read/update，在mongostat的输出中也有体现。conn列可以看到数据库连接个数的变化，对于同步的驱动来说，连接个数会从4个增加到25个，而对于异步的驱动来说，连接个数会从4个增加到7个。通过这种方式，针对不同的线程数，观察两种驱动的性能数据并通过mongostat的数据记录连接数。
一、不限制连接数
为了观察连接数的变化，先不限制maxPoolSize（注释脚本中MAX_POOL_SIZE=8那一行）。最终结果如下：
图中，每种颜色的左列和右列分别是同步和异步的数据。直观起见，我们通过图表来对比一下：
首先对比一下load阶段和run阶段的吞吐量（柱越高越好）
可以发现，当线程数达到8个之后，吞吐量的增长趋势基本消失了，尤其是同步驱动的吞吐量还会随线程数的继续增加而略有下降。不知是否跟测试环境为四核八线程的CPU有关系。
然后对比一下INSERT、READ和UPDATE操作的平均时长（柱越低越好）
相对来说，异步驱动能带来更快的读写操作，尤其是应对越来越多的线程的时候。
最后对比一下连接数
连接数的对比更加明显：对于同步的情况，连接数=线程数+5；而对于异步的情况，连接数几乎一直保持在7个。没有对比就没有伤害呀。
二、限制连接数
下面，将连接数限制为32个，测试一下线程数从30-80的情况下，同步驱动的性能数据：
通过图表对比：
可见，限制连接数之后，略有改善，但是相比异步驱动来说，仍然有一定差距。
3）结论
首先，需要说明的是，以上并非是以数据库调优为目的的测试，这里我们只测试了workloada（如果你感兴趣可以将脚本中的WORKLOAD变量修改一下，然后测试其他场景），而且限制连接数为32并没有特别的依据，对测试的机器来说，32也并非最优的连接数。
通过本节的测试，针对MongoDB驱动我们可以得出以下两个结论：
上边我们分别针对Http服务端、Http客户端以及数据库进行了同步和异步的测试对比，综上来看，基于异步非阻塞的响应式应用或驱动能够以少量且固定的线程应对高并发的请求或调用，对于存在阻塞的场景，能够比多线程的并发方案提供更高的性能。
响应式和非阻塞并不是总能让应用跑的更快，况且将代码构建为非阻塞的执行方式本身还会带来少量的成本。但是在类似于WEB应用这样的高并发、少计算且I/O密集的应用中，响应式和非阻塞往往能够发挥出价值。尤其是微服务应用中，网络I/O比较多的情况下，效果会更加惊人。