银联订阅ChatGPT支付对接实战：高并发场景下的可靠回调设计

4次阅读

共计 2639 个字符，预计需要花费 7 分钟才能阅读完成。

当银联订阅服务与 ChatGPT 支付系统对接时，面临的核心挑战来自银联回调机制的特性：

不可控的回调频率 ：银联在交易高峰期可能以每秒数千次的频率推送回调，尤其在促销活动时更为明显
网络抖动导致重复通知 ：银联的重试机制可能导致同一笔交易发送多次回调请求
状态同步时效性要求 ：用户支付成功后需要在 5 秒内收到 ChatGPT 服务开通通知
数据一致性难题 ：支付成功但服务未开通或重复开通都会引发客诉

同步处理方案 ：
直接在 Controller 层处理回调请求
优点：实现简单，响应及时
缺点：数据库压力大，容易成为系统瓶颈
异步消息队列方案 ：
回调请求先进入消息队列，消费者异步处理
优点：削峰填谷，系统解耦
缺点：实现复杂度较高

本地事务 ：
仅适用于单机部署
无法解决分布式环境下的数据一致性问题
分布式事务 ：
采用 Spring Cloud Stream + RabbitMQ 实现
通过事务消息保证最终一致性
选择原因：
- RabbitMQ 的 TTL 和死信队列适合支付超时场景
- Spring Cloud Stream 提供统一的 Binder 抽象，便于后期扩展

/**
 * 银联回调签名验证工具
 */
public class UnionPaySignUtil {
    private static final String SIGN_FIELD = "signature";
    private static final String CERT_PATH = "/conf/unionpay/cert.prod";

    /**
     * 验证回调签名有效性
     * @param params 回调参数 Map
     * @return 验签结果
     */
    public static boolean verify(Map<String, String> params) {String sign = params.get(SIGN_FIELD);
        String data = buildSignString(params);

        try {Certificate certificate = loadCertificate();
            Signature signature = Signature.getInstance("SHA256withRSA");
            signature.initVerify(certificate.getPublicKey());
            signature.update(data.getBytes(StandardCharsets.UTF_8));
            return signature.verify(Base64.getDecoder().decode(sign));
        } catch (Exception e) {log.error("验签失败", e);
            return false;
        }
    }

    // 其他辅助方法省略...
}

@Slf4j
@Component
public class IdempotentProcessor {
    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    /**
     * 基于 Redis 的幂等控制
     * @param bizId 业务唯一 ID
     * @param ttlSeconds 锁有效期
     * @return 是否首次处理
     */
    public boolean tryProcess(String bizId, long ttlSeconds) {
        String key = "idempotent:" + bizId;
        Boolean result = redisTemplate.opsForValue()
            .setIfAbsent(key, "1", ttlSeconds, TimeUnit.SECONDS);

        if (result == null || !result) {log.warn("重复请求被拦截: {}", bizId);
            return false;
        }
        return true;
    }
}

public class RedisDistributedLock {
    private static final String LOCK_PREFIX = "lock:";
    private static final int DEFAULT_TIMEOUT = 30;

    /**
     * 获取分布式锁
     * @param lockKey 锁键
     * @param requestId 请求标识
     * @return 是否获取成功
     */
    public boolean tryLock(String lockKey, String requestId) {return tryLock(lockKey, requestId, DEFAULT_TIMEOUT);
    }

    public boolean tryLock(String lockKey, String requestId, int timeoutSec) {
        String key = LOCK_PREFIX + lockKey;
        return redisTemplate.opsForValue()
            .setIfAbsent(key, requestId, timeoutSec, TimeUnit.SECONDS);
    }

    // 释放锁实现省略...
}

系统采用分层架构设计：