1
2
3
4
5

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

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

@Configuration
public class MyRedissonConfig {
    
    @Bean(destroyMethod = "shutdown")
    public RedissonClient redisson() throws IOException {
        Config config = new Config();
        // 单机模式
        config.useSingleServer()
              .setAddress("redis://127.0.0.1:6379")
              .setDatabase(0);
        // 集群模式
        // config.useClusterServers()
        //       .addNodeAddress("redis://127.0.0.1:7001", "redis://127.0.0.1:7002");
        return Redisson.create(config);
    }
}

1
2
3
4
5
6
7
8
9

// 1. 设置分布式锁
RLock lock = redisson.getLock("orderLock");
// 2. 占锁
lock.lock();
// 3. 执行业务
createOrder();
deductStock();
// 4. 释放锁
lock.unlock();

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

public boolean isRepeatSubmit(String userId, String bizType) {
    String key = "repeat:" + bizType + ":" + userId;
    RLock lock = redisson.getLock(key);
    try {
        // 尝试加锁，最多等 0 秒，锁 1 秒过期
        return lock.tryLock(0, 1, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        return false;
    }
}

1
2
3
4
5

if redis.call('get', KEYS[1]) == ARGV[1] then
    return redis.call('del', KEYS[1])
else
    return 0
end

1
2
3
4

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

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface CacheLock {
    /** key 前缀 */
    String prefix() default "";
    /** 过期秒数，默认 5 秒 */
    int expire() default 5;
    /** 超时时间单位 */
    TimeUnit timeUnit() default TimeUnit.SECONDS;
    /** Key 分隔符 */
    String delimiter() default ":";
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

@Aspect
@Component
public class LockCheckAspect {
    
    /** Lua：释放锁时校验 value，避免误删 */
    private static final String RELEASE_LOCK_LUA_SCRIPT = 
        "if redis.call('get', KEYS[1]) == ARGV[1] then " +
        "  return redis.call('del', KEYS[1]) " +
        "else return 0 end";
    
    @Autowired
    private RedisTemplate<String, Object> redisTemplate;
    
    @Pointcut("@annotation(cn.example.api.config.aop.CacheLock)")
    public void pointCut() {}
    
    @Around("pointCut()")
    public Object around(ProceedingJoinPoint joinPoint) throws Throwable {
        // 1. 获取业务唯一 key（如用户手机号）
        String phone = getUserPhone();
        
        MethodSignature signature = (MethodSignature) joinPoint.getSignature();
        Method method = signature.getMethod();
        CacheLock cacheLock = method.getAnnotation(CacheLock.class);
        String prefix = cacheLock.prefix();
        if (StringUtils.isBlank(prefix)) {
            throw new GlobalException("CacheLock prefix can't be null");
        }
        
        // 2. 拼接 key
        String lockKey = prefix + cacheLock.delimiter() + phone;
        String uuid = cn.hutool.core.lang.UUID.fastUUID().toString();
        
        try {
            // 3. 抢锁：SETNX + 过期时间
            boolean success = redisTemplate.opsForValue()
                .setIfAbsent(lockKey, uuid, cacheLock.expire(), cacheLock.timeUnit());
            if (!success) {
                throw new CustomDeniedException("请勿重复提交");
            }
            
            // 4. 执行业务
            return joinPoint.proceed();
        } finally {
            // 5. 释放锁（Lua 原子操作，避免误删）
            DefaultRedisScript<Long> redisScript = 
                new DefaultRedisScript<>(RELEASE_LOCK_LUA_SCRIPT, Long.class);
            redisTemplate.execute(redisScript, Collections.singletonList(lockKey), uuid);
        }
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

@RestController
@RequestMapping("/charge")
@AllArgsConstructor
public class ChargeController {
    
    @PostMapping("/startCharge")
    @CacheLock(prefix = "recharge")
    public Result startCharge(@RequestBody @Validated ChargeQuery query) {
        return chargeService.startCharge(query);
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21

TM                    TC                      RM (Service-A)        RM (Service-B)
│                      │                            │                       │
│ 1. begin global tx   │                            │                       │
│ ──────────────────> │                            │                       │
│ 2. 创建 XID = 192.168│                            │                       │
│ <────────────────── │                            │                       │
│                      │                            │                       │
│ 3. RPC call ──────────────────────────────────────> │                       │
│    (XID 透传)         │                            │                       │
│                      │                            │ 4. register local     │
│                      │ <────────────────────────── │   branch to XID       │
│                      │                            │                       │
│                      │ 5. RPC call ──────────────────────────────────────>  │
│                      │                            │                       │
│                      │ <────────────────────────────────────── 6. register │
│                      │                            │                       │
│ 7. commit / rollback │                            │                       │
│ ──────────────────> │                            │                       │
│                      │ 8. 调度所有分支 ──────────> │ ────────────────────> │
│                      │   提交/回滚                │                       │
│                      │ <────────────── 9. 上报结果 │ <──────────────────── │

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

@Service
public class OrderService {
    
    @GlobalTransactional  // 关键注解
    public void createOrder(Order order) {
        // 1. 扣库存（远程调用）
        storageService.deduct(order.getProductId(), order.getCount());
        // 2. 创建订单
        orderMapper.insert(order);
        // 3. 扣账户余额（远程调用）
        accountService.debit(order.getUserId(), order.getMoney());
    }
}

1
2
3
4
5
6

Message msg = new Message("OrderTopic", "orderTag", 
    JSON.toJSONBytes(order));
// 1 = 1s, 2 = 5s, 3 = 10s, 4 = 30s, 5 = 1m, 6 = 2m, 7 = 3m, 8 = 4m, ...
// 18 = 2h, ... 0 = 不延迟
msg.setDelayTimeLevel(3);
SendResult result = producer.send(msg);

1
2
3
4
5
6
7
8

-- 订单表加字段
ALTER TABLE t_order ADD COLUMN close_status INT DEFAULT 0;
ALTER TABLE t_order ADD COLUMN expire_time DATETIME;

-- 每分钟扫描过期订单
SELECT id FROM t_order 
WHERE close_status = 0 AND expire_time < NOW() 
LIMIT 100;

1
2
3
4
5
6
7

@Scheduled(cron = "0 * * * * ?")
public void closeExpiredOrders() {
    List<Long> ids = orderMapper.selectExpiredIds(100);
    for (Long id : ids) {
        orderService.closeOrder(id);
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18

@RocketMQMessageListener(topic = "OrderTopic", consumerGroup = "order-consumer")
public class OrderConsumer implements RocketMQListener<Order> {
    
    @Override
    public void onMessage(Order order) {
        String msgId = order.getMsgId();
        // 幂等：检查是否已处理
        Boolean processed = redisTemplate.opsForValue()
            .setIfAbsent("msg:" + msgId, "1", 7, TimeUnit.DAYS);
        if (Boolean.FALSE.equals(processed)) {
            log.info("重复消息，跳过：{}", msgId);
            return;
        }
        
        // 执行业务
        orderService.process(order);
    }
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

用户下单
   ↓
@CacheLock (Redis SETNX 防重提交)
   ↓
@GlobalTransactional (Seata AT 分布式事务)
   ├── 1. 扣库存 RPC
   ├── 2. 创建订单 DB
   └── 3. 扣账户 RPC
   ↓
RocketMQ 事务消息发到下游
   ├── 库存系统消费（幂等）
   ├── 物流系统消费（幂等）
   └── 延迟消息：30 分钟后检查未支付订单关闭