idempotent:{業(yè)務(wù)類型}:{序列號}

客戶端 -> 生成唯一序列號 -> 攜帶序列號發(fā)起請求 -> 服務(wù)端
服務(wù)端 -> 檢查Redis中是否存在該序列號
       -> 不存在：存儲序列號到Redis，執(zhí)行業(yè)務(wù)邏輯，返回結(jié)果
       -> 存在：直接返回之前的處理結(jié)果

public class SerialNumberGenerator {
    
    /**
     * 生成UUID作為唯一序列號
     */
    public static String generateUUID() {
        return UUID.randomUUID().toString();
    }
    
    /**
     * 生成包含業(yè)務(wù)前綴的唯一序列號
     */
    public static String generateWithPrefix(String prefix) {
        return prefix + ":" + UUID.randomUUID().toString().replaceAll("-", "");
    }
}

@Component
public class RedisIdempotentUtils {
    
    @Resource
    private RedisTemplate<String, Object> redisTemplate;
    
    /**
     * 檢查并設(shè)置序列號
     * @param key 序列號鍵
     * @param value 存儲的值
     * @param expireTime 過期時間
     * @param timeUnit 時間單位
     * @returntrue-首次請求，false-重復(fù)請求
     */
    public boolean checkAndSet(String key, Object value, long expireTime, TimeUnit timeUnit) {
        // 使用Redis的setIfAbsent實(shí)現(xiàn)原子操作，確保線程安全
        Boolean result = redisTemplate.opsForValue().setIfAbsent(key, value, expireTime, timeUnit);
        return Boolean.TRUE.equals(result);
    }
    
    /**
     * 獲取序列號對應(yīng)的值
     */
    public Object get(String key) {
        return redisTemplate.opsForValue().get(key);
    }
    
    /**
     * 構(gòu)建Redis鍵
     */
    public String buildKey(String businessType, String serialNumber) {
        return"idempotent:" + businessType + ":" + serialNumber;
    }
}

@RestController
public class PaymentController {
    
    @Resource
    private RedisIdempotentUtils redisIdempotentUtils;
    
    @Resource
    private PaymentService paymentService;
    
    /**
     * 支付接口
     * @param serialNumber 唯一序列號，從請求頭獲取
     * @param paymentRequest 支付請求參數(shù)
     */
    @PostMapping("/api/payment")
    public Result<PaymentResponse> processPayment(
            @RequestHeader("Idempotent-Serial") String serialNumber,
            @RequestBody PaymentRequest paymentRequest) {
        
        // 1. 構(gòu)建Redis鍵
        String redisKey = redisIdempotentUtils.buildKey("payment", serialNumber);
        
        // 2. 檢查是否為重復(fù)請求
        boolean isFirstRequest = redisIdempotentUtils.checkAndSet(
                redisKey, 
                paymentRequest.getUserId(), 
                24, 
                TimeUnit.HOURS);
        
        if (!isFirstRequest) {
            // 重復(fù)請求，返回之前的處理結(jié)果或提示
            Object userId = redisIdempotentUtils.get(redisKey);
            PaymentResponse cachedResponse = getCachedPaymentResponse(serialNumber);
            return Result.success("重復(fù)請求，已處理", cachedResponse);
        }
        
        try {
            // 3. 首次請求，執(zhí)行業(yè)務(wù)邏輯
            PaymentResponse response = paymentService.processPayment(paymentRequest);
            
            // 4. 緩存處理結(jié)果（可選）
            cachePaymentResponse(serialNumber, response);
            
            return Result.success("支付成功", response);
        } catch (Exception e) {
            // 5. 業(yè)務(wù)處理失敗，刪除序列號（根據(jù)業(yè)務(wù)需求決定）
            // redisTemplate.delete(redisKey);
            return Result.fail("支付失?。? + e.getMessage());
        }
    }
    
    // 緩存和獲取支付結(jié)果的方法（實(shí)際實(shí)現(xiàn)略）
    private void cachePaymentResponse(String serialNumber, PaymentResponse response) {
        // 實(shí)現(xiàn)緩存邏輯
    }
    
    private PaymentResponse getCachedPaymentResponse(String serialNumber) {
        // 實(shí)現(xiàn)獲取緩存邏輯
        return new PaymentResponse();
    }
}