当前位置：首页 > news >正文

定位线上同步锁仍然重复扣费的Bug定位及Redis分布式锁解决方案

news 来源：原创 2024/7/7 16:04:07

在实际生产环境中，处理订单的并发请求时，我们经常会遇到重复扣费的问题。本文将通过一个具体的代码示例，分析在使用同步锁时仍然导致重复扣费的原因，并提供一个基于Redis分布式锁的解决方案。

背景：这个案例出现在商家在小程序端接单重复扣费,PC端也能接单，并且PC端和小程序端不是一套代码，但是接单的代码几乎一致

一、问题描述

在以下代码中，OrderServiceImpl 类使用了 Java 的同步锁来保证对订单状态变更的操作是线程安全的：

public class OrderServiceImpl {public Operating orderStateChange(OrderStateReq orderStateReq) {synchronized (OrderServiceImpl.class) {//订单idInteger orderId = orderStateReq.getOrderId();//根据订单id查看订单是否满足扣费  不满足则抛异常  满足则扣费}}  
}

二、问题分析

尽管我们在 orderStateChange 方法中使用了同步锁，但仍然可能导致重复扣费的问题，原因有以下几点：

锁粒度过大：synchronized (OrderServiceImpl.class) 锁定的是整个类，这样虽然可以避免多个线程同时进入临界区，但在分布式环境下，这种锁机制无法跨JVM工作。

锁的范围有限：Java 的 synchronized 锁仅在单个 JVM 中有效，如果你的应用程序部署在多台服务器上，每个服务器上的 JVM 都会有自己的锁，这就无法避免分布式环境下的并发问题。

业务逻辑不完善：即使在单机环境中，锁住整个类也会导致性能瓶颈，因为所有订单处理请求都必须排队进入同步块，无法充分利用多线程的优势。

三、解决方案

为了解决上述问题，我们可以使用 Redis 分布式锁。Redis 分布式锁的特点是可以跨多个 JVM 保证唯一性，从而避免分布式环境下的并发问题。

1. 引入 Redis 依赖
首先，在你的项目中引入 Redis 相关依赖（以 Spring Boot 为例）：

<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.16.2</version></dependency>

2. 实现 Redis 分布式锁
然后，我们实现一个简单的 Redis 分布式锁机制。可以使用 Redisson 库，这个库封装了 Redis 锁的实现，使用起来非常方便。

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import java.util.concurrent.TimeUnit;public class RedisLockUtil {private static RedissonClient redissonClient;// 有指定库和密码也需要赋值static {Config config = new Config();config.useSingleServer().setAddress("redis://localhost:6379");config.useSingleServer().setPassword("redisPassword");config.useSingleServer().setDatabase("database");redissonClient = Redisson.create(config);}public static RLock getLock(String lockKey) {return redissonClient.getLock(lockKey);}
}

3. 使用 Redis 分布式锁
在 OrderServiceImpl 中使用 Redis 分布式锁来实现订单状态变更操作：

import org.redisson.api.RLock;public class OrderServiceImpl {public Operating orderStateChange(OrderStateReq orderStateReq) {String lockKey = "orderLock:" + orderStateReq.getOrderId();RLock lock = RedisLockUtil.getLock(lockKey);try {// 尝试加锁，等待时间为10秒，锁超时时间为30秒if (lock.tryLock(10, 30, TimeUnit.SECONDS)) {try {//订单idInteger orderId = orderStateReq.getOrderId();//根据订单id查看订单是否满足扣费  不满足则抛异常  满足则扣费} finally {lock.unlock();}} else {// 获取锁失败，处理逻辑throw new RuntimeException("获取锁失败，请稍后再试");}} catch (InterruptedException e) {Thread.currentThread().interrupt();throw new RuntimeException("线程中断", e);}}
}