127.0.0.1:6379> multi
OK
127.0.0.1:6379> set user:001 zhangsan
QUEUED
127.0.0.1:6379> set user:002 lisi
QUEUED
127.0.0.1:6379> get user:001
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK
3) "zhangsan"


127.0.0.1:6379> multi
OK
127.0.0.1:6379> set user:001 xiaoming
QUEUED
127.0.0.1:6379> set user:002 xiaozhang
QUEUED
127.0.0.1:6379> discard    # 使用discard命令取消隊列
OK
127.0.0.1:6379> exec    # 執(zhí)行exec報錯
(error) ERR EXEC without MULTI

# watch 命令演示

# 客戶端2，在客戶端1執(zhí)行exec之前，執(zhí)行 set user:001 xiaoming，客戶端1的事務(wù)被打斷
127.0.0.1:6379> get user:001
"zhangsan"
127.0.0.1:6379> watch user:001
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set user:001 lisi
QUEUED
127.0.0.1:6379> exec   # 客戶端1的事務(wù)被打斷
(nil)
127.0.0.1:6379> get user:001
"xiaoming"

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
        </dependency>

spring:
  redis:
    host: 192.168.235.131
    port: 6379
    database: 0
    connect-timeout: 1800000
    password: 123456
    lettuce:
      pool:
        #連接池最大連接數(shù)（使用負(fù)值表示沒有限制）
        max-active: 20
        #最大阻塞等待時間(負(fù)數(shù)表示沒限制)
        max-wait: -1
        #連接池中的最大空閑連接
        max-idle: 8
        #連接池中的最小空閑連接
        min-idle: 0

@Service
@Slf4j
public class OrderServiceImpl implements OrderService {
    @Autowired
    private StringRedisTemplate redisTemplate;
    //庫存
    private final String STOCK_KEY="stock:num";
    //秒殺成功的用戶
    private final String USER_KEY="success:user";
    /**
     * Redis樂觀鎖秒殺案例
     * @param userId  用戶ID
     * @return
     */
    @Override
    public boolean secKill(String userId) {
        Object stockObj = redisTemplate.opsForValue().get(STOCK_KEY);
        if (stockObj==null){
            log.info("庫存為空，秒殺還未開始！");
            return false;
        }
        int stockNum=Integer.parseInt(stockObj.toString());
        if (stockNum<=0){
            log.info("庫存為0，秒殺已經(jīng)結(jié)束！");
            return false;
        }
        //判斷當(dāng)前用戶是否已經(jīng)秒殺成功
        Boolean member = redisTemplate.opsForSet().isMember(USER_KEY, userId);
        if (member){
            log.info("您已經(jīng)秒殺成功，不能重復(fù)參與！");
            return false;
        }
        List txList =redisTemplate.execute(new SessionCallback<List<Object>>() {
           @Override
           public List<Object> execute(RedisOperations operations) throws DataAccessException {
               //監(jiān)聽庫存
                operations.watch(STOCK_KEY);
               //開啟事務(wù)
               operations.multi();
               //扣減庫存
               operations.opsForValue().decrement(STOCK_KEY);
               //把秒殺成功的用戶加入到set集合
               operations.opsForSet().add(USER_KEY,userId);
               //執(zhí)行事務(wù)
               List<Object> result=operations.exec();
               return result;
           }
       });
        if (txList==null||txList.size()==0){
            log.info("用戶:{}，秒殺失敗",userId);
            return false;
        }
        log.info("用戶:{}，秒殺成功",userId);
        return true;
    }
}

/**
 * 秒殺
 * @return
 */
@RequestMapping("secKill")
public String secKill(){
    String userId= UUID.randomUUID().toString();
    boolean res = orderService.secKill(userId);
    if (res){
        return "秒殺成功";
    }else {
        return "秒殺失敗";
    }
}

ab -n 500 -c 100  http://192.168.1.171/order/secKill