快捷導(dǎo)航

redis事務(wù)如何解決超賣問題

更新時(shí)間：2024年11月05日 11:02:37 作者：路西法_Lucifer

使用Redis事務(wù)可以有效避免超賣問題,首先,通過MULTI命令開啟事務(wù),將需要執(zhí)行的多個(gè)命令加入到事務(wù)中,然后通過EXEC命令提交事務(wù),確保這些命令可以一次性、順序地執(zhí)行,在事務(wù)執(zhí)行期間,Redis服務(wù)器不會(huì)執(zhí)行其他客戶端的命令

redis事務(wù)解決超賣問題

Redis的事務(wù)提供了一種將多個(gè)命令請(qǐng)求打包，然后一次性、按順序性地執(zhí)行多個(gè)命令的機(jī)制。

在事務(wù)執(zhí)行期間，服務(wù)器不會(huì)中斷事務(wù)而去執(zhí)行其它客戶端的命令請(qǐng)求，它會(huì)將事務(wù)中的所有命令執(zhí)行完畢，然后才去處理其它客戶端的命令請(qǐng)求。

事務(wù)以MULTI命令開始，然后將多個(gè)命令放到事務(wù)當(dāng)中，最后由EXEC命令將這個(gè)事務(wù)提交給服務(wù)器執(zhí)行。

1.引入相關(guān)jar包

 <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-data-redis</artifactId>
       <version>2.7.0</version>
</dependency>

2.代碼段

package com.example.demo;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.core.RedisOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.SessionCallback;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
import java.util.UUID;
 
/**
 * @author lucifer
 * @description TODO
 * @date 2022-08-10
 */
@RestController
public class Controller {
 
    @Autowired
    RedisTemplate redisTemplate;
 
 
    //寫入緩存中，因?yàn)檫@里的模擬的是一個(gè)商品被多人搶，所以value值隨便吧
    @GetMapping("/test1")
    public void test1(){
        redisTemplate.opsForValue().set("item1",UUID.randomUUID().toString());
    }
 
    //模擬多人搶一個(gè)商品，并且只有一件
    @GetMapping("/test")
    public String test(){
        //生成隨機(jī)的userid(模擬多用戶去搶一個(gè)商品)
        String userid=UUID.randomUUID().toString();
        //redis key 商品id 為了模擬寫成1
        String key="item"+1;
        //如果redis中不存在搶這個(gè)商品的緩存，就代表?yè)屖?
        //商品獨(dú)一份
        if(!redisTemplate.hasKey(key)){
           throw new RuntimeException("你沒有搶到");
        }
        //執(zhí)行redis的事務(wù)
        redisTemplate.execute(new SessionCallback() {
            @Override
            public Object execute(RedisOperations operations) throws DataAccessException {
                //在使用multi()開始的事務(wù)期間觀察給定的修改key
                operations.watch(key);
                //標(biāo)記事務(wù)塊的開始。 命令將被排隊(duì)
                operations.multi();
                //設(shè)置key-value
                operations.opsForValue().set(key,userid);
                //如果任何被監(jiān)視的key已被修改，則操作將失敗
                return operations.exec();
            }
        });
        //刪除  避免這個(gè)商品被其他人搶到了
        redisTemplate.delete(key);
        //todo....數(shù)據(jù)庫(kù)操作
        return "你搶到了";
    }
 
}