1.添加項(xiàng)目依賴

<!-- redis依賴 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2.配置文件

spring:
  #Redis配置
  redis:
    host: localhost
    password: 123456

3.模擬搶購商品的Service層

接口類

/**
 * @author 劉路生
 */
public interface SellService {
    /**
     * 根據(jù)商品ID搶購商品并且返回商品的搶購詳情
     * @param productId
     * @return
     */
    String orderGoods(String productId);
    /**
     * 根據(jù)商品ID查詢商品搶購詳情
     * @param productId
     * @return
     */
    String queryGoods(String productId);
}

實(shí)現(xiàn)類

@Service
@Slf4j
/**
 * @author 劉路生
 */
public class SellServiceImpl implements SellService {
    @Autowired
    private RedisLock redisLock;
    /**
     設(shè)置超時(shí)時(shí)間10秒
     */
    private static final int TIMEOUT = 10*1000;
    /**
     * 例如國慶大甩賣 圖書大甩賣 庫存 1000 件
     */
    /**
     * 庫存
     */
    static Map<String, Integer> products;
    /**
     * 庫存余量
     */
    static Map<String, Integer> stock;
    /**
     * 搶購成功者信息
     */
    static Map<String, String> orders;
    static {
        products = new HashMap<>();
        stock = new HashMap<>();
        orders = new HashMap<>();
        products.put("book", 1000);
        stock.put("book", 1000);
    }
    public String queryMap(String productId){
        return "國慶圖書大甩賣，庫存 " + products.get(productId) + " 件，現(xiàn)余 " + stock.get(productId) + " 件，已被搶購 " + orders.size() + " 件";
    }    
    @Override
    public String orderGoods(String productId) {
        //先獲取商品余量
        int number = stock.get(productId);
        if(number == 0){
            throw new RuntimeException("商品已搶購?fù)辏埬麓卧賮恚x謝您的理解...");
        }else {
            //模擬下單（不同用戶擁有不同ID）
            orders.put(String.valueOf(UUID.randomUUID()), productId);
            //減庫存
            number = number - 1;
            //模擬延遲
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            stock.put(productId, number);
        }
        log.info("共搶購 {} 件，搶購詳情:{}", orders.size(), orders);
        //再返回商品的搶購詳情
        return this.queryMap(productId);
    }
    @Override
    public String queryGoods(String productId) {
        return this.queryMap(productId);
    }
}

4.Controller 層

/**
 * @author 劉路生
 */
@RestController
public class SellController {
    @Autowired
    private SellService sellService;
    /**
     * 根據(jù)商品ID進(jìn)行搶購
     * @param productId
     * @return 商品搶購詳情
     */
    @GetMapping("/order/{productId}")
    public String sellGoods(@PathVariable String productId){
        return sellService.orderGoods(productId);
    }
    /**
     * 根據(jù)商品ID進(jìn)行查詢余量
     * @param productId
     * @return 商品搶購詳情
     */
    @GetMapping("/query/{productId}")
    public String queryGoods(@PathVariable String productId){
        return sellService.queryGoods(productId);
    }
}

5.模擬高并發(fā)

使用 Apache ab 模擬高并發(fā)

ab -n 500 -c 80 http://localhost:8080/order/book

6.結(jié)果

7.利用Redis分布式鎖解決高并發(fā)問題

(1)實(shí)現(xiàn)Redis分布式鎖

/**
 * @author 劉路生
 */
@Component
@Slf4j
public class RedisLock {
    @Autowired
    private StringRedisTemplate redisTemplate;
    /**
     * 加鎖
     * @param key
     * @param value 當(dāng)前時(shí)間+超時(shí)時(shí)間
     * @return
     */
    public boolean lock(String key, String value){
        if(redisTemplate.opsForValue().setIfAbsent(key, value)){
            return true;
        }
        String currentValue = redisTemplate.opsForValue().get(key);
        //如果鎖過期
        if(!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()){
            //獲取上一個(gè)鎖的時(shí)間
            String oldValue = redisTemplate.opsForValue().getAndSet(key, value);
            if(!StringUtils.isEmpty(oldValue) && currentValue.equals(oldValue)){
                return true;
            }
        }
        return false;
    }
    /**
     * 解鎖
     * @param key
     * @param value 當(dāng)前時(shí)間+超時(shí)時(shí)間
     */
    public void unlock(String key, String value){
        try{
            String currentValue = redisTemplate.opsForValue().get(key);
            if(!StringUtils.isEmpty(currentValue) && currentValue.equals(value)){
                redisTemplate.opsForValue().getOperations().delete(key);
            }
        }catch (Exception e){
            log.error("【Redis分布式鎖】 解鎖異常 {}", e.getMessage());
        }
    }
}

(2)利用分布式鎖處理Service層方法

/**
 * 第一種方法 synchronized 鎖機(jī)制，解決高并發(fā)產(chǎn)生的超賣問題 但效率大大降低 不推薦使用
 * 第二種方法 使用 Redis 分布式鎖，解決高并發(fā)產(chǎn)生的超賣問題 并且效率相對高很多
 */
@Override
public String orderGoods(String productId) {
    //加鎖
    Long time = System.currentTimeMillis() + TIMEOUT;
    //加鎖失敗 說明有人正在使用
    if(!redisLock.lock(productId, String.valueOf(time))){
        log.info("搶購失敗，請?jiān)僭囋嚢?..");
        //return null;
        throw new RuntimeException("服務(wù)器剛才好像睡著了，請?jiān)僭囋嚢?..");
    }
    //先獲取商品余量
    int number = stock.get(productId);
    if(number == 0){
        throw new RuntimeException("商品已搶購?fù)辏埬麓卧賮恚x謝您的理解...");
    }else {
        //模擬下單（不同用戶擁有不同ID）
        orders.put(String.valueOf(UUID.randomUUID()), productId);
        //減庫存
        number = number - 1;
        //模擬延遲
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        stock.put(productId, number);
    }
    log.info("共搶購 {} 件，搶購詳情:{}", orders.size(), orders);
    //解鎖
    redisLock.unlock(productId, String.valueOf(time));
    //再返回商品的搶購詳情
    return this.queryMap(productId);
}

8.模擬高并發(fā)

使用 Apache ab 模擬高并發(fā)

ab -n 500 -c 80 http://localhost:8080/order/book

9.結(jié)果

瀏覽器顯示

控制臺打印

以上就是動(dòng)力節(jié)點(diǎn)小編介紹的"利用Redis分布式鎖處理高并發(fā)"，希望對大家有幫助，想了解更多可查看Java在線學(xué)習(xí)。動(dòng)力節(jié)點(diǎn)在線學(xué)習(xí)教程，針對沒有任何Java基礎(chǔ)的讀者學(xué)習(xí),讓你從入門到精通,主要介紹了一些Java基礎(chǔ)的核心知識，讓同學(xué)們更好更方便的學(xué)習(xí)和了解Java編程，感興趣的同學(xué)可以關(guān)注一下。