本文例項為大家分享了springboot整合redis實現簡單秒殺系統的具體程式碼，供大家參考，具體內容如下

專案是有地址的，我會放到文章的最後面

1. 直接service，我們會介紹兩種秒殺模式

public interface GoodsService {

 /**
  * 通過lua指令碼實現的秒殺
  * @param skuCode 商品編碼
  * @param buyNum 購買數量
  * @return 購買數量
  */
 Long flashSellByLuaScript(String skuCode,int buyNum);
 /**
  * 通過redis 事務 實現的秒殺
  * @param skuCode 商品編碼
  * @param buyNum 購買數量
  * @return 購買數量
  */
 Long flashSellByRedisWatch(String skuCode,int buyNum);

}

2. service實現類

import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.core.RedisOperations;
import org.springframework.data.redis.core.SessionCallback;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;

@Service
public class GoodsServiceImpl implements GoodsService {

 @Resource
 private StringRedisTemplate stringRedisTemplate;

 @Override
 public Long flashSellByLuaScript(String skuCode,int num) {
  //下面是lua指令碼
  String luaScript ="local buyNum = ARGV[1]\n" +
    "local goodsKey = KEYS[1] \n" +
    "local goodsNum = redis.call('get',goodsKey) \n" +
    "if goodsNum >= buyNum \n" +
    "then redis.call('decrby',goodsKey,buyNum) \n" +
    "return buyNum \n" +
    "else \n" +
    "return '0'\n" +
    "end\n" +
    "\n" ;

  DefaultRedisScript<String> re = new DefaultRedisScript<String>();
  //設定指令碼
  re.setScriptText(luaScript);
  //定義返回值型別，注意，如果沒有這個定義，Spring不會返回結果
  re.setResultType(String.class);
  RedisSerializer<String> stringRedisSerializer = stringRedisTemplate.getStringSerializer();
  //執行LUA指令碼
  String result = (String) stringRedisTemplate.execute(re,stringRedisSerializer,null);
  return Long.valueOf(result);
 }

 @Override
 public Long flashSellByRedisWatch(String skuCode,int num){

  SessionCallback<Long> sessionCallback = new SessionCallback<Long>() {
   @Override
   public Long execute(RedisOperations operations) throws DataAccessException {
    int result = num;
    //redis 樂觀鎖
    //我們觀察商品編碼是否發生改變
    operations.watch(skuCode);
    ValueOperations<String,String> valueOperations = operations.opsForValue();
    String goodsNumStr = valueOperations.get(skuCode);
    Integer goodsNum = Integer.valueOf(goodsNumStr);
    //標記一個事務塊的開始。
    //事務塊內的多條命令會按照先後順序被放進一個隊列當中，
    //最後由 EXEC 命令原子性(atomic)地執行。
    operations.multi();
    if (goodsNum >= num) {
     valueOperations.increment(skuCode,0 - num);
    } else {
     result = 0;
    }
    //多條命令執行的結果集合
    List exec = operations.exec();
    if(exec.size()>0){
     System.out.println(exec);
    }
    return (long) result;
   }
  };
  return stringRedisTemplate.execute(sessionCallback);
 }
//省略 其他的方法


}

3. controller

但是首先要向你的redis裡面仍一個數據，key='xiaomi'，value='100'

@ApiOperation(value = "用事務秒殺測試介面",notes = "用事務秒殺測試介面")
@RequestMapping(value = "/miaoTransaction",method = RequestMethod.GET)
@ResponseBody
 public Long miaoTransaction() {

  Long res = goodsService.flashSellByRedisWatch("xiaomi",1);
  return res;
 }


 @ApiOperation(value = " 秒殺Lua測試介面",notes = "秒殺Lua測試介面")
 @RequestMapping(value = "/miaoLua",method = RequestMethod.GET)
 @ResponseBody
 public Long miaoLua() {

  Long res = goodsService.flashSellByRedisWatch("xiaomi",1);
  System.out.println(res.toString());
  return res;
 }

然後就可以用jemeter併發訪問了。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。