一、前言

上一篇结尾的时候我提了两个问题,这一次主要针对这两个问题进行思考和讨论。 ticket更新

二、代码测试

增加日志 我尝试在sleep之前增加一条日志,用于观察程序睡眠的时间。 简单编写一个测试类用于测试ticket不足的场景。

public static void main(String[] args) {
    RateLimiter rateLimiter=RateLimiter.create(5);
    for(int i=0;i<5;i++) {
      boolean acquire = rateLimiter.tryAcquire(10);
      System.out.println("result:"+acquire);
    }
  }

最终运行的结果:

sleep0ms...
result:true
result:false
result:false
result:false
result:false

Process finished with exit code 0

我们可以知道

我们再来总结下,只要你手头上至少有一个ticket(当前时间>=nextFreeTicketMicros),不管请求者是需要多少个ticket,我们都一并满足给他,返回true,并且把ticket更新为负数(往后更新nextFreeTicketMicros)。但是这种模式后面来的人就遭殃了,假如前面一个用户申请了很多ticket,那么后来者需要等待很长的时间才能申请到一个ticket。

四、总结

RateLimiter的SmoothBursty实现我们已经大致讨论完了,可以看得出来其实SmoothBursty的实现会存在一些弊端,比如说可能会出现比较严重的突刺流量,另外一个实现类SmoothWarmingUp是否能比较好地解决这部分问题?这个有待讨论