无码精品a∨在线观看中文,熟妇搡bbbb搡bbbb太国

1：解決思路

將活動(dòng)寫入 redis 中，通過 redis 自減指令扣除庫存。

2：添加 redis 常量

commons/constant/RedisKeyConstant.java

seckill_vouchers("seckill_vouchers:","秒殺券的 key"),

3：添加 redis 配置類

4：修改業(yè)務(wù)層

廢話不多說，直接上源碼

1：秒殺業(yè)務(wù)邏輯層

@Service
public class SeckillService {
@Resource
private SeckillVouchersMapper seckillVouchersMapper;
@Resource
2private VoucherOrdersMapper voucherOrdersMapper;
@Value("${service.name.ms-oauth-server}")
private String oauthServerName;
@Resource
private RestTemplate restTemplate;
@Resource
private RedisTemplate redisTemplate;

2：添加需要搶購的代金券

@Transactional(rollbackFor = Exception.class)
public void addSeckillVouchers(SeckillVouchers seckillVouchers) {
// 非空校驗(yàn)
AssertUtil.isTrue(seckillVouchers.getFkVoucherId()== null,"請(qǐng)選擇需要搶購的代金券");
AssertUtil.isTrue(seckillVouchers.getAmount()== 0,"請(qǐng)輸入搶購總數(shù)量");
Date now = new Date();
AssertUtil.isNotNull(seckillVouchers.getStartTime(),"請(qǐng)輸入開始時(shí)間");
 
// 生產(chǎn)環(huán)境下面一行代碼需放行，這里注釋方便測(cè)試
// AssertUtil.isTrue(now.after(seckillVouchers.getStartTime()),"開始時(shí)間不能早于當(dāng)前時(shí)間");
AssertUtil.isNotNull(seckillVouchers.getEndTime(),"請(qǐng)輸入結(jié)束時(shí)間");
AssertUtil.isTrue(now.after(seckillVouchers.getEndTime()),"結(jié)束時(shí)間不能早于當(dāng)前時(shí)間");
AssertUtil.isTrue(seckillVouchers.getStartTime().after(seckillVouchers.getEndTime()),"開始時(shí)間不能晚于結(jié)束時(shí)間");
 
// 采用 Redis 實(shí)現(xiàn)
String key= RedisKeyConstant.seckill_vouchers.getKey() +seckillVouchers.getFkVoucherId();
// 驗(yàn)證 Redis 中是否已經(jīng)存在該券的秒殺活動(dòng),hash 不會(huì)做序列化和反序列化，
有利于性能的提高。entries(key），取到 key
Map<String, Object> map= redisTemplate.opsForHash().entries(key);
//如果不為空或 amount 庫存>0,該券已經(jīng)擁有了搶購活動(dòng),就不要再創(chuàng)建。
AssertUtil.isTrue(!map.isEmpty() && (int) map.get("amou

3：搶購代金券

@Transactional(rollbackFor = Exception.class)
public ResultInfo doSeckill(Integer voucherId, String accessToken, String path)
{
// 基本參數(shù)校驗(yàn)
AssertUtil.isTrue(voucherId == null || voucherId < 0,"請(qǐng)選擇需要搶購的代金券");
AssertUtil.isNotEmpty(accessToken,"請(qǐng)登錄");
 
// 采用 Redis
String key= RedisKeyConstant.seckill_vouchers.getKey() + voucherId;//根據(jù) key 獲取 map
Map<String, Object> map= redisTemplate.opsForHash().entries(key);
//map 轉(zhuǎn)對(duì)象
SeckillVouchers seckillVouchers = BeanUtil.mapToBean(map,SeckillVouchers.class, true, null);
 
// 判斷是否開始、結(jié)束
Date now = new Date();
AssertUtil.isTrue(now.before(seckillVouchers.getStartTime()),"該搶購還未開始");
AssertUtil.isTrue(now.after(seckillVouchers.getEndTime()),"該搶購已結(jié)束");
 
// 判斷是否賣完
AssertUtil.isTrue(seckillVouchers.getAmount() < 1,"該券已經(jīng)賣完了");
 
// 獲取登錄用戶信息
String url = oauthServerName +"user/me?access_token={accessToken}";
ResultInfo resultInfo = restTemplate.getForObject(url, ResultInfo.class,accessToken);
if (resultInfo.getCode() != ApiConstant.SUCCESS_CODE) {
resultInfo.setPath(path);
return resultInfo;
}
 
// 這里的 data 是一個(gè) LinkedHashMap，SignInDinerInfo
SignInDinerInfo dinerInfo = BeanUtil.fillBeanWithMap((LinkedHashMap)resultInfo.getData(), new SignInDinerInfo(), false);
 
// 判斷登錄用戶是否已搶到(一個(gè)用戶針對(duì)這次活動(dòng)只能買一次)
VoucherOrders order =voucherOrdersMapper.findDinerOrder(dinerInfo.getId(),seckillVouchers.getFkVoucherId());
AssertUtil.isTrue(order != null,"該用戶已搶到該代金券，無需再搶");
 
//扣庫存，采用 redis,redis 沒有設(shè)置自減，所以要自減，將步長(zhǎng)設(shè)置為-1
long count = redisTemplate.opsForHash().increment(key,"amou

5：postman 測(cè)試

http://localhost:8083/add

{
"fkVoucherId":1,
"amou

查看 redis

再次運(yùn)行 http://localhost:8083/add

6：壓力測(cè)試

查看 redis 中的庫存出現(xiàn)負(fù)值

在 redis 中修改庫存要分兩部進(jìn)行，先要獲取庫存的值，再扣減庫存。所以在高并發(fā)情況下，會(huì)導(dǎo)致 redis 扣減庫存出問題。可以使用 redis 的弱事務(wù)或 lua 腳本解決。 7：安裝Lua resources/stock.lua

if (redis.call('hexists', KEYS[1], KEYS[2])== 1) then
  local stock = tonumber(redis.call('hget', KEYS[1], KEYS[2]));
  if (stock > 0) then
    redis.call('hincrby', KEYS[1], KEYS[2],-1);
    return stock;
  end;
    return 0;
end;

hexists', KEYS[1], KEYS[2]) == 1
hexists 是判斷 redis 中 key 是否存在。
KEYS[1] 是 seckill_vouchers:1 KEYS[2] 是 amount
hget 是獲取 amount 賦給 stock
hincrby 是自增，當(dāng)為-1 是為自減。
因?yàn)樵?redis 中沒有自減指令，所以當(dāng)步長(zhǎng)為 -1 表示自減。
現(xiàn)在使用 lua 腳本，將 redis 中查詢庫存和扣減庫存當(dāng)成原子性操作在一個(gè)線程內(nèi).

8：配置Lua

config/RedisTemplateConfiguration.java

@Bean
public DefaultRedisScript<Long> stockScript() {
  DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
  //放在和 application.yml 同層目錄下
  redisScript.setLocation(new ClassPathResource("stock.lua"));
  redisScript.setResultType(Long.class);
  return redisScript;
}

9：修改業(yè)務(wù)層

ms-seckill/service/SeckilService.java

1：搶購代金券

@Transactional(rollbackFor = Exception.class)
public ResultInfo doSeckill(Integer voucherId, String accessToken, String path)
{
// 基本參數(shù)校驗(yàn)
AssertUtil.isTrue(voucherId == null || voucherId < 0,"請(qǐng)選擇需要搶購的代金券");
AssertUtil.isNotEmpty(accessToken,"請(qǐng)登錄");
// 采用 Redis
String key= RedisKeyConstant.seckill_vouchers.getKey() + voucherId;
//根據(jù) key 獲取 map
Map<String, Object> map= redisTemplate.opsForHash().entries(key);
//map 轉(zhuǎn)對(duì)象
SeckillVouchers seckillVouchers = BeanUtil.mapToBean(map,SeckillVouchers.class, true, null);
// 判斷是否開始、結(jié)束
Date now = new Date();AssertUtil.isTrue(now.before(seckillVouchers.getStartTime()),"該搶購還未開始");
AssertUtil.isTrue(now.after(seckillVouchers.getEndTime()),"該搶購已結(jié)束");
// 判斷是否賣完
AssertUtil.isTrue(seckillVouchers.getAmount() < 1,"該券已經(jīng)賣完了");
// 獲取登錄用戶信息
String url = oauthServerName +"user/me?access_token={accessToken}";
ResultInfo resultInfo = restTemplate.getForObject(url, ResultInfo.class,
accessToken);
if (resultInfo.getCode() != ApiConstant.SUCCESS_CODE) {
resultInfo.setPath(path);
return resultInfo;
}
// 這里的 data 是一個(gè) LinkedHashMap，SignInDinerInfo
SignInDinerInfo dinerInfo = BeanUtil.fillBeanWithMap((LinkedHashMap)
resultInfo.getData(), new SignInDinerInfo(), false);
// 判斷登錄用戶是否已搶到(一個(gè)用戶針對(duì)這次活動(dòng)只能買一次)
VoucherOrders order =voucherOrdersMapper.findDinerOrder(dinerInfo.getId(),
seckillVouchers.getFkVoucherId());
AssertUtil.isTrue(order != null,"該用戶已搶到該代金券，無需再搶");
 
//扣庫存，采用 redis,redis 沒有設(shè)置自減，所以要自減，將步長(zhǎng)設(shè)置為-1
// long count = redisTemplate.opsForHash().increment(key,"amou

10：壓力測(cè)試

將 redis 中庫存改回 100

壓力測(cè)試

查看 redis 中 amount=0 ，不會(huì)變成負(fù)值查看數(shù)據(jù)庫下單表 t_voucher_orders ，共計(jì)下 100 個(gè)訂單。

到此這篇關(guān)于Redis高并發(fā)防止秒殺超賣實(shí)戰(zhàn)源碼解決方案的文章就介紹到這了,更多相關(guān)Redis高并發(fā)防止秒殺超賣內(nèi)容請(qǐng)搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！

海外服務(wù)器租用

版權(quán)聲明：本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。

相關(guān)文章

mysql學(xué)習(xí)筆記之表的基本操作

centos編譯安裝mysql 5.6及安裝多個(gè)mysql實(shí)例詳解

mysql 5.7.11 winx64.zip安裝配置方法圖文教程

mysql 5.7.17 winx64.zip安裝配置方法圖文教程

CentOS安裝mysql5.7 及簡(jiǎn)單配置教程詳解

MySQL 5.7 zip版本(zip版)安裝配置步驟詳解

MySQL5.6.31 winx64.zip 安裝配置教程詳解

MySQL注入繞開過濾的技巧總結(jié)

一次Mysql死鎖排查過程的全紀(jì)錄

Windows10 64位安裝MySQL5.6.35的圖文教程