后端架构实录：从核心交易链路设计到分布式避坑指南

package payment

import (
	"context"
	"database/sql"
	"errors"
	"fmt"
	"time"

	"github.com/go-redis/redis/v8"
)

type PaymentService struct {
	rdb *redis.Client
	db  *sql.DB
}

func (s *PaymentService) ProcessPayment(ctx context.Context, bizPaymentNo string, amount int64) error {
	lockKey := fmt.Sprintf("lock:pay:%s", bizPaymentNo)
	
	// 1. 获取分布式锁，防止并发瞬时打穿（TTL 设为 10 秒，防止死锁）
	ok, err := s.rdb.SetNX(ctx, lockKey, "1", 10*time.Second).Result()
	if err != nil || !ok {
		return errors.New("concurrent request detected or redis error, please retry later")
	}
	defer s.rdb.Del(ctx, lockKey)

	// 2. 查单状态机判断
	var status string
	err = s.db.QueryRowContext(ctx, "SELECT status FROM payment_order WHERE biz_payment_no = ?", bizPaymentNo).Scan(&status)
	if err == nil {
		if status == "SUCCESS" {
			// 已经支付成功，直接返回成功（幂等返回）
			return nil
		}
		if status == "PROCESSING" {
			return errors.New("payment is processing")
		}
	} else if !errors.Is(err, sql.ErrNoRows) {
		return err
	}

	// 3. 开启本地事务，插入初始态支付单（依赖 biz_payment_no 唯一索引托底）
	tx, err := s.db.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer tx.Rollback()

	_, err = tx.ExecContext(ctx, 
		"INSERT INTO payment_order(biz_payment_no, amount, status, created_at) VALUES (?, ?, 'PROCESSING', NOW())", 
		bizPaymentNo, amount)
	if err != nil {
		// 命中 DB 唯一键冲突，说明有并发请求已入库
		return fmt.Errorf("duplicate payment request: %w", err)
	}

	// 4. 调用下游真实扣款渠道
	channelErr := callThirdPartyChannel(bizPaymentNo, amount)
	if channelErr != nil {
		// 注意：此处若为网络超时，不可直接标 FAIL，需交给异步对账任务处理
		return channelErr
	}

	// 5. 更新本地状态为成功
	_, err = tx.ExecContext(ctx, "UPDATE payment_order SET status = 'SUCCESS' WHERE biz_payment_no = ?", bizPaymentNo)
	if err != nil {
		return err
	}

	return tx.Commit()
}

func callThirdPartyChannel(bizNo string, amount int64) error {
	// 模拟远程渠道调用
	return nil
}

[ 订单服务 (Order Service) ]
       │
       ├─ 1. 开启本地 DB 事务
       ├─ 2. 更新订单状态 = PAID
       ├─ 3. 插入本地事件表 (outbox_event: "ORDER_PAID")
       └─ 4. 提交本地 DB 事务 (保证订单状态与消息落库强一致)
       │
       ▼ (轮询 / CDC / Transactional MQ)
[ 投递到 MQ (Kafka / RocketMQ) ]
       │
       ▼
[ 积分/库存/通知服务 (Downstream) ]
       │
       ├─ 1. 消费消息
       ├─ 2. 幂等消费校验 (根据 order_id)
       └─ 3. 执行业务动作并 ACK