用Redisson实现库存扣减的方法

news2025/5/9 19:45:15

Redisson是一个在Redis基础上实现的Java客户端，提供了许多高级功能，包括分布式锁、计数器、集合等。使用Redisson实现库存扣减可以保证操作的原子性和高效性。本文将详细介绍如何使用Redisson实现一个简单的库存扣减功能。

一、初始化Redisson客户端

首先，需要初始化Redisson客户端。以下是一个基本的配置示例：

import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;

public class RedissonManager {
    private static RedissonClient redissonClient;

    static {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://localhost:6379");
        redissonClient = Redisson.create(config);
    }

    public static RedissonClient getClient() {
        return redissonClient;
    }
}

二、实现库存扣减的方法

我们可以使用Redisson的分布式锁来确保库存扣减操作的原子性，防止并发问题。

2.1 库存扣减方法

以下是实现库存扣减的方法：

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.api.RMap;

public class InventoryService {
    private RedissonClient redissonClient;

    public InventoryService(RedissonClient redissonClient) {
        this.redissonClient = redissonClient;
    }

    /**
     * 扣减库存
     * @param productId 商品ID
     * @param quantity 扣减数量
     * @return 是否扣减成功
     */
    public boolean reduceStock(String productId, int quantity) {
        RLock lock = redissonClient.getLock("lock:inventory:" + productId);
        try {
            // 尝试获取分布式锁，等待时间3秒，锁定时间10秒
            if (lock.tryLock(3, 10, TimeUnit.SECONDS)) {
                try {
                    RMap<String, Integer> stockMap = redissonClient.getMap("inventory");
                    Integer stock = stockMap.get(productId);
                    if (stock == null) {
                        System.out.println("商品不存在");
                        return false;
                    }
                    if (stock < quantity) {
                        System.out.println("库存不足");
                        return false;
                    }
                    stockMap.put(productId, stock - quantity);
                    return true;
                } finally {
                    lock.unlock();
                }
            } else {
                System.out.println("获取锁失败");
                return false;
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
            return false;
        }
    }

    public static void main(String[] args) {
        RedissonClient client = RedissonManager.getClient();
        InventoryService inventoryService = new InventoryService(client);

        // 初始化库存
        client.getMap("inventory").put("product123", 100);

        // 扣减库存
        boolean result = inventoryService.reduceStock("product123", 10);
        if (result) {
            System.out.println("扣减库存成功");
        } else {
            System.out.println("扣减库存失败");
        }
    }
}

2.2 代码解释

初始化Redisson客户端：
- RedissonManager类用于初始化并获取Redisson客户端实例。
实现库存扣减方法：
- reduceStock方法接收商品ID和扣减数量作为参数。
- 使用 RLock获取分布式锁，确保并发情况下的原子性操作。
- 尝试获取锁，如果成功，获取库存并检查是否足够。
- 扣减库存并更新Redis中的库存值。
- 最终释放锁。
示例运行：
- 在 main方法中，初始化库存数据，并调用 reduceStock方法测试扣减库存的功能。