多线程中redis实现计数器总结

63 阅读 0 评论 42 点赞

我是靠谱客的博主跳跃悟空，最近开发中收集的这篇文章主要介绍多线程中redis实现计数器总结，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

一、基本概念

1、竞态条件：设备或者系统出现不适当的执行时序导致不正确结果的严重后果，叫做竞态条件。

2、原子性：一个操作不可中断，要么全执行，要么全不执行，个人理解可以把原子操作当做一个最小的行为单元。

二、容易出问题的点：

1、多线程共享资源定要在拿到资源的同时就考虑释放

2、有限数量的资源

（1）保证incr要设置有效期

（2）原子性

（3）延迟赋值等情况

三、计数器实现

背景：控制1分钟内的请求拉取照片次数

1、原代码实现：

 1 String key = "gateway_ext_fetchdata_" + model.getExtCode();
 2         try {
 3             String accessCount = flowControl.get(key);  取计数器的值
 4             if (accessCount == null) {                  判断
 5                 accessCount = "0";                                   
 6                 flowControl.set(key, accessCount, 1, TimeUnit.MINUTES); 设置计数器的值
 7             }
 8 
 9             int count = Integer.parseInt(accessCount);
10             logger.info("拉取照片请求流量控制, extCode={}, key={}, currCount={}", model.getExtCode(), key, count);
11             if (count >= 100) {
12                 model.setRet(RetCodeEnum.INTERFACE_LIMIT, "调用过于频繁");
13                 logger.warn("拉取照片请求流量控制, 机构调用过于频繁, extCode={}, key={}, currCount={}", model.getExtCode(), key, count);
14                 return;
15             } else {
16                 flowControl.increment(key, 1);                      修改计数器的值
17             }
18         } catch (Exception e) {
19             logger.error("拉取照片请求流量控制异常, extCode={}, key={}, exception={}", model.getExtCode(), key, e);
20             model.setRetCode(RetCodeEnum.FAILED);
21             return;
22         }