[开发测试]Disruptor简单理解 QPS TPS 压力测试JMH使用

QPS

• Query per Second
• 每秒查询率，也就是一个接口每秒可以执行多少次

TPS

• Transactions per Second
• 每秒传输事务的个数，也就是服务器每秒处理的事务数

JMH

• 测试一个方法的性能
• 官方建议打好jar包放去服务器中测试，开发环境会对测试结果有影响
• 需要写在test包下
• JMH注解

  @Benchmark
  	? 在方法上添加，就可以进行测试
  @Warmup
  	? 预热，对于测试结果很重要，由于JVM中对于特定代码会存在优化（本地化）
  	? 参数： Iterations-预热多少次 	time-预热多长时间
  @Fork
  	? 用多少个线程去执行我们的程序
  @Mesurement
  	? 调用多少次
  @BenchmarkMode
  	? 设定基准测试的模式。
  	? 一般用Mode.Throughput 吞吐量模式
  

• IDEA中要让注解生效，需要把这个勾选上
• 运行的时候，需要把系统的环境变量包含进来
  
  

Disruptor

• 直译为分裂瓦解，是一个在内存中用于存放元素的高效率的队列，底层由CAS实现
• 目前为止，在单机情况下，最快的MQ，支持高并发，可以做到一个线程每秒处理600万订单
• 默认是多线程生产者，假如是单线程生产者，可以改模式提高性能，会把锁和检测去除，将性能会发挥到极致
• 用于生产消费者模型，源码中使用了观察者模式，消费者为观察者，队列为被观察对象
• 核心是ringBuffer，Disruptor内部使用的是环型Buffer队列，用数组实现，首尾相连
• 队列中存储的是Event，需要定义Event工厂
• 生产满了没有被覆盖，也就是队列满了消费者还没来消费的时候，会执行等待策略

BlockingWaitStrategy

• 常用策略
• 线程阻塞等待生产者唤醒
• 被唤醒后，再循环检查依赖的sequence是否已经消费。

YieldingWaitStrategy

• 常用策略
• 尝试100次，然后调用Thread.yield()让出cpu，效率最高，但是得分情况，消费者慢生产者多时应该用BlockingWaitStrategy

SleepingWaitStrategy

• 常用策略
• sleep()，满了的时候去睡一下再来

BusySpinWaitStrategy

• 线程一直自旋等待，可能比较耗cpu

LiteBlockingWaitStrategy

• 线程阻塞等待生产者唤醒
• 与BlockingWaitStrategy相比，可以减少lock加锁次数

LiteTimeoutBlockingWaitStrategy

• 线程阻塞等待生产者唤醒
• 与LiteBlockingWaitStrategy相比，设置了阻塞时间，超过时间后会抛异常。

TimeoutBlockingWaitStrategy

• 线程阻塞等待生产者唤醒
• 与BlockingWaitStrategy相比，设置了阻塞时间，超过后抛异常

PhasedBackoffWaitStrategy

• 根据时间参数和传入的等待策略来决定使用哪种等待策略