前言
公司有一個發券的接口有并發安全問題，下面列出這個問題和解決這個問題的方式。
業務描述
這個接口的作用是給會員發多張券碼。涉及到4張主體，分別是：用戶，券，券碼，用戶領取記錄。
下面是改造前的偽代碼。
主要是因為查出券碼那行存在并發安全問題，多個線程拿到同幾個券碼。以下都是基于如何讓取券碼變成原子的去展開。
public boolean sendCoupons(Long userId, Long couponId) {
// 一堆校驗
// ...
// 查出券碼
ListCouponCode> couponCodes = couponCodeService.findByCouponId(couponId, num);
// batchUpdateStatus是一個被@Transactional(propagation = Propagation.REQUIRES_NEW)修飾的方法
// 批量更新為已被領取狀態
couponCodeService.batchUpdateStatus(couponCods);
// 發券
// 發權益
// 新增用戶券碼領取記錄
}
改造過程
因為券碼是多張，想用lua+redis的list結構去做彈出。為什么用這種方案是因為for update直接被否了。
這是寫的lua腳本。。
local result = {}
for i=1,ARGV[1],1 do
result[i] = redis.call("lpop", KEYS[1])
end
return table.contact(result , "|")
這是寫的執行lua腳本的client。。其實主要的解決方法就是在redis的list里rpush（存）,lpop（取）取數據
@Slf4j
@Component
public class CouponCodeRedisQueueClient implements InitializingBean {
/**
* redis lua腳本文件路徑
*/
public static final String POP_COUPON_CODE_LUA_PATH = "lua/pop-coupon-code.lua";
public static final String SEPARATOR = "|";
private static final String COUPON_CODE_KEY_PATTERN = "PROMOTION:COUPON_CODE_{0}";
private String LUA_COUPON_CODE_SCRIPT;
private String LUA_COUPON_CODE_SCRIPT_SHA;
@Autowired
private JedisTemplate jedisTemplate;
@Override
public void afterPropertiesSet() throws Exception {
LUA_COUPON_CODE_SCRIPT = Resources.toString(Resources.getResource(POP_COUPON_CODE_LUA_PATH), Charsets.UTF_8);
if (StringUtils.isNotBlank(LUA_COUPON_CODE_SCRIPT)) {
LUA_COUPON_CODE_SCRIPT_SHA = jedisTemplate.execute(jedis -> {
return jedis.scriptLoad(LUA_COUPON_CODE_SCRIPT);
});
log.info("redis lock script sha:{}", LUA_COUPON_CODE_SCRIPT_SHA);
}
}
/**
* 獲取Code
*
* @param activityId
* @param num
* @return
*/
public ListString> popCouponCode(Long activityId, String num , int retryNum) {
if(retryNum == 0){
log.error("reload lua script error , try limit times ,activityId:{}", activityId);
return Collections.emptyList();
}
ListString> keys = Lists.newArrayList();
String key = buildKey(String.valueOf(activityId));
keys.add(key);
ListString> args = Lists.newArrayList();
args.add(num);
try {
Object result = jedisTemplate.execute(jedis -> {
if (StringUtils.isNotBlank(LUA_COUPON_CODE_SCRIPT_SHA)) {
return jedis.evalsha(LUA_COUPON_CODE_SCRIPT_SHA, keys, args);
} else {
return jedis.eval(LUA_COUPON_CODE_SCRIPT, keys, args);
}
});
log.info("pop coupon code by lua script.result:{}", result);
if (Objects.isNull(result)) {
return Collections.emptyList();
}
return Splitter.on(SEPARATOR).splitToList(result.toString());
} catch (JedisNoScriptException jnse) {
log.error("no lua lock script found.try to reload it", jnse);
reloadLuaScript();
//加載后重新執行
popCouponCode(activityId, num, --retryNum);
} catch (Exception e) {
log.error("failed to get a redis lock.key:{}", key, e);
}
return Collections.emptyList();
}
/**
* 重新加載LUA腳本
*
* @throws Exception
*/
public void reloadLuaScript() {
synchronized (CouponCodeRedisQueueClient.class) {
try {
afterPropertiesSet();
} catch (Exception e) {
log.error("failed to reload redis lock lua script.retry load it.");
reloadLuaScript();
}
}
}
/**
* 構建Key
*
* @param activityId
* @return
*/
public String buildKey(String activityId) {
return MessageFormat.format(COUPON_CODE_KEY_PATTERN, activityId);
}
}
當然這種操作需要去提前把所有券的券碼丟到redis里去，這里我們也碰到了一些問題（券碼量比較大的情況下）。比如開始直接粗暴的用@PostConstruct去放入redis，導致項目啟動需要很久很久。。這里就不展開了，說一下我們嘗試的幾種方法
- @PostConstruct注解
- CommandLineRunner接口
- redis的pipeline技術
- 先保證每個卡券有一定量的券碼在redis，再用定時任務定時（根據業務量）去補
到此這篇關于使用lua+redis解決發多張券的并發問題的文章就介紹到這了,更多相關redis多張券的并發內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- Redis實現分布式Session管理的機制詳解
- kubernetes環境部署單節點redis數據庫的方法
- 銀河麒麟V10sp1服務器系統安裝redis不能使用的快速解決辦法
- 使用docker搭建redis主從的方法步驟
- 基于redis setIfAbsent的使用說明
