java redis 批量扣库存代码含有事务

在Java中使用Redis进行批量扣库存操作并包含事务处理，可以保证在一系列操作中的原子性，防止数据不一致。下面是一个简单的示例，假设我们有一个名为`Stock`的Redis键，存储商品的库存信息，键名是商品ID，值是库存数量：

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;

public class RedisInventoryService {
    private final RedisTemplate<String, Integer> redisTemplate;

    public RedisInventoryService(RedisTemplate<String, Integer> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    // 开启事务
    public boolean batchDecrement(String[] productIds, int decrementAmount) {
        try (ValueOperations<String, Integer> operations = redisTemplate.opsForValue()) {
            TransactionStatus status = redisTemplate.startTransaction();
            
            for (String productId : productIds) {
                // 减库存操作
                Integer currentStock = operations.get(productId);
                if (currentStock != null && currentStock >= decrementAmount) {
                    operations.multi().decr(productId).execute(status);
                    // 检查事务是否成功
                    if (!status.isNewTransaction() && !status.isSuccess()) {
                        throw new RuntimeException("Transaction failed for product " + productId);
                    }
                } else {
                    // 如果库存不足则跳出事务，后续不做扣减
                    redisTemplate.execute(status::discard); // 或者使用其他回滚策略
                    return false; // 商品库存不足，扣减失败
                }
            }

            // 提交事务
            redisTemplate.execute(status::commit);
            return true; // 批量扣减成功
        } catch (DataAccessException e) {
            // 发生异常时，回滚事务
            redisTemplate.execute(status::rollback);
            throw e; // 抛出异常
        }
    }
}

在这个例子中，`batchDecrement`方法接收一组产品ID和扣减数量，然后在一个事务上下文中尝试对每个产品的库存进行减一操作。如果某个商品的库存不足以扣减，它会回滚整个事务，确保库存不会减少到负数。