ChatGPT会员充值系统架构设计与高并发优化实践

1次阅读

没有评论

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

随着 ChatGPT 用户量激增，会员充值系统面临三大核心挑战：

支付成功率波动 ：高峰时段第三方支付接口超时率达 15%，直接影响转化率
订单重复处理 ：网络抖动导致客户端重复提交，引发资金损失风险
对账效率低下 ：每日千万级交易量使得传统定时任务跑批时间超过 6 小时

采用 DDD 划分三个核心限界上下文：

支付网关服务 ：聚合支付宝 / 微信支付等渠道，提供统一抽象接口
订单服务 ：处理订单生命周期，保证状态机强一致性
账户服务 ：管理用户余额变更，确保资金操作原子性

服务间通过 gRPC 通信，架构图示意如下：

[客户端] → [API Gateway] → [订单服务] → [支付网关服务]
                              ↓
                        [账户服务] ← [对账服务]

def create_order(user_id, plan_id, idempotent_key):
    # 基于 Redis 实现幂等键校验
    with redis.lock(f'order_lock:{user_id}'):
        if redis.get(idempotent_key):
            logging.warning(f'Duplicate request detected: {idempotent_key}')
            return {'status': 'exist', 'order_id': redis.get(idempotent_key)}

        order_id = generate_snowflake_id()
        try:
            db.execute_transaction("INSERT INTO orders(id,user_id,plan_id,status) VALUES(?,?,?,'pending')",
                [order_id, user_id, plan_id]
            )
            redis.setex(idempotent_key, 3600, order_id)  # 1 小时有效期
            return {'status': 'created', 'order_id': order_id}
        except IntegrityError:
            logging.error(f'Order creation conflict: {order_id}')
            raise BusinessException('ORDER_CONFLICT')

方案	TCC 模式	Saga 模式
适用场景	短流程 (2- 3 步)	长事务链 (≥4 步)
一致性	强一致	最终一致
实现成本	需开发 confirm/cancel 接口	仅需补偿逻辑

最终选择 ：支付流程采用 TCC（Try-Confirm），积分发放使用 Saga

支付结果通知通过 RocketMQ 广播
订单服务消费消息后：
更新订单状态
触发账户余额变更
发送会员权益
引入本地消息表解决消息丢失问题

场景	QPS	平均 RT	错误率
纯 DB 写入	1,200	85ms	0.3%
引入 Redis 缓存	8,500	12ms	0.01%
异步削峰模式	24,000	8ms	0.005%

订单查询：Redis LRU 缓存 + 防穿透空值
支付渠道：本地缓存 (Guava) + 二级 Redis
用户余额：Write-Behind 模式异步持久化

def call_payment_gateway(params, max_retries=3):
    for i in range(max_retries):
        try:
            resp = requests.post(PAY_URL, json=params, timeout=2)
            resp.raise_for_status()
            return resp.json()
        except (Timeout, ConnectionError) as e:
            if i == max_retries - 1:
                raise
            wait = min(2 ** i, 10)  # 指数退避
            time.sleep(wait)