一、基本概念
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 }
问题是类 "延迟初始化" 问题
计数器的key:作用标识_+机构名称+精确到天的日期
2. multi exec 事务
3. redis + lua