分布式相关理论

1
graph TD
2
    A[用户下单] --> B[订单服务执行本地事务]
3
    B --> C{本地事务成功？}
4
    C -- 否 --> D[返回下单失败]
5
    C -- 是 --> E[订单服务：在本地消息表插入“扣减库存”消息（状态：待发送）]
6
    E --> F[订单服务：提交本地事务（订单创建 + 消息插入 原子性）]
7
    F --> G[订单服务启动定时任务/消息发送线程，扫描本地消息表“待发送”消息]
8
    G --> H[发送消息到MQ（如RocketMQ/Kafka）]
9
    H --> I{MQ确认接收？}
10
    I -- 是 --> J[订单服务：更新本地消息表状态为“已发送”]
11
    I -- 否 --> K[定时任务重试发送（最多N次），仍失败则告警人工介入]
12
    H --> L[库存服务监听MQ消息]
13
    L --> M[库存服务执行扣减库存本地事务]
14
    M --> N{库存扣减成功？}
15
    N -- 是 --> O[库存服务：向MQ发送“扣减成功”确认消息（可选）]
16
    N -- 否 --> P[重试扣减（最多N次），仍失败则告警/触发补偿逻辑]
17
    O --> Q[订单服务监听“扣减成功”消息，更新订单状态为“已扣库存”（可选）]

1
// 1. 防重表结构（MySQL）
2
/*
3
CREATE TABLE `mq_message_confirm` (
4
  `id` bigint NOT NULL AUTO_INCREMENT,
5
  `message_id` varchar(64) NOT NULL COMMENT '消息唯一ID',
6
  `business_type` varchar(32) NOT NULL COMMENT '业务类型（如扣库存）',
7
  `status` tinyint NOT NULL COMMENT '0-处理中 1-处理成功 2-处理失败',
8
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP,
9
  PRIMARY KEY (`id`),
10
  UNIQUE KEY `uk_message_id` (`message_id`) COMMENT '唯一索引，防止重复插入'
11
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
12
*/
13

14
// 2. 消费端处理逻辑
15
@Service
16
public class StockConsumer {
17
    @Resource
18
    private StockMapper stockMapper;
19
    @Resource
20
    private MqMessageConfirmMapper confirmMapper;
21

22
    @Transactional
23
    public void consume(String messageId, Long productId, Integer deductNum) {
24
        // 步骤1：插入防重表（唯一索引保证幂等）
25
        MqMessageConfirm confirm = new MqMessageConfirm();
26
        confirm.setMessageId(messageId);
27
        confirm.setBusinessType("DEDUCT_STOCK");
28
        confirm.setStatus(0);
29
        try {
30
            confirmMapper.insert(confirm);
31
        } catch (DuplicateKeyException e) {
32
            // 重复消费，直接返回成功
33
            return;
34
        }
35

36
        // 步骤2：执行扣库存业务（乐观锁保证幂等）
37
        int updateCount = stockMapper.deductStock(productId, deductNum);
38
        if (updateCount == 0) {
39
            // 库存不足/版本号不匹配，更新失败
40
            confirm.setStatus(2);
41
            confirmMapper.updateById(confirm);
42
            throw new RuntimeException("库存扣减失败");
43
        }
44

45
        // 步骤3：更新防重表状态为成功
46
        confirm.setStatus(1);
47
        confirmMapper.updateById(confirm);
48
    }
49
}

1
graph TD
2
    A[用户登录] --> B[认证服务校验账号密码]
3
    B --> C{校验通过？}
4
    C -- 否 --> D[返回登录失败]
5
    C -- 是 --> E[认证服务生成JWT令牌：Header+Payload+Signature]
6
    E --> F[返回JWT令牌给客户端（存储在LocalStorage/Header）]
7
    F --> G[客户端发起请求（如/user/info），在Header中携带JWT令牌]
8
    G --> H[网关/任意微服务节点接收请求]
9
    H --> I[服务端解析Header，获取签名算法]
10
    I --> J[服务端用相同密钥重新计算Signature]
11
    J --> K{Signature一致？}
12
    K -- 否 --> L[返回401：令牌被篡改/无效]
13
    K -- 是 --> M{Payload中exp未过期？}
14
    M -- 否 --> N[返回401：令牌过期]
15
    M -- 是 --> O[解析Payload获取用户信息（如userId）]
16
    O --> P[完成身份/权限校验，处理业务请求]
17
    P --> Q[返回响应给客户端]