什么事分布式事務(wù)：
多個(gè)服務(wù)同時(shí)修改記錄時(shí)，保證數(shù)據(jù)的一致性.
分布式思路:
- 通過(guò)在redis設(shè)置一個(gè)唯一鎖，如果存在key守呜，則認(rèn)為有其他客戶端在使用，等待鎖釋放山憨。
- 如果不存在key查乒，說(shuō)明沒(méi)有客戶端使用，可以執(zhí)行任務(wù)郁竟，執(zhí)行完畢玛迄，解鎖，刪除key.
存在的問(wèn)題1 ：
獲得鎖后棚亩，服務(wù)宕機(jī)蓖议，由于key是唯一的，所以無(wú)法被刪除.
問(wèn)題1解決方案
設(shè)置過(guò)期時(shí)間讥蟆。
存在的問(wèn)題2
任務(wù)執(zhí)行過(guò)長(zhǎng)勒虾，超過(guò)過(guò)期時(shí)間。
問(wèn)題2解決方案
通過(guò)一個(gè)守護(hù)線程瘸彤，給線程續(xù)命.
存在的問(wèn)題3:
任務(wù)執(zhí)行造成死循環(huán)修然，會(huì)造成無(wú)限續(xù)命.
問(wèn)題3解決方案 ：
設(shè)置最大續(xù)命時(shí)間。
使用redisTemplate代碼如下
String uuid = UUID.randomUUID().toString();
boolean key = redisTemplate.opsForValue().setIfAbsent("key",uuid,5, TimeUnit.SECONDS);
if(key){
log.info("獲得鎖.");
int current =(int)redisTemplate.opsForValue().get("foodNum");
log.info("當(dāng)前值:"+current);
redisTemplate.opsForValue().increment("foodNum");
redisTemplate.opsForList().rightPush("list","portal:"+current);
log.info("更新值:"+redisTemplate.opsForValue().get("foodNum"));
redisTemplate.delete("key");
}else {
log.info("無(wú)法獲得鎖");
}
