Spring Cloud Alibaba 微服务全栈体系详解

解读： Nacos 客户端并没有使用复杂的长连接来维持注册状态，而是通过 ScheduledThreadPoolExecutor 实现了一个简单的定时循环调用 HTTP 接口发送心跳。这种设计简单且健壮。

2.4 实战代码要点

依赖 (pom.xml):

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>

配置 (bootstrap.yml - 必须在 bootstrap 中配置才能生效配置中心):

spring:
  application:
    name: order-service
  cloud:
    nacos:
      server-addr: 127.0.0.1:8848 # Nacos 服务器地址
      discovery:
        namespace: dev # 命名空间隔离
      config:
        file-extension: yaml # 配置文件格式
        shared-configs:
          - data-id: common.yaml
            refresh: true

3. 核心组件二：Sentinel —— 分布式流量防卫兵

3.1 核心功能与定位

Sentinel 不仅仅是 Hystrix 的替代品，它的视野更广阔。Hystrix 侧重于隔离和熔断，而 Sentinel 侧重于多样化的流量控制。

• 流量控制：QPS 限流、线程数限流、关联限流、链路限流、流控效果（快速失败、WarmUp 预热、排队等待）。
• 熔断降级：支持按慢调用比例、异常比例、异常数进行熔断。
• 系统负载保护：提供系统维度的自适应保护，根据系统的整体负载（如 load1, CPU 使用率）自动阻断流量，让系统'喘口气'。

3.2 深层原理：责任链模式 (Slot Chain)

Sentinel 的核心骨架是一个极其精巧的责任链模式（Chain of Responsibility Pattern）。

所有的资源（被保护的代码块、接口）在被访问时，都会创建一个 Entry 对象。这个 Entry 对象在创建过程中，会按顺序经过一系列的 ProcessorSlot（处理槽）。每个 Slot 负责一项特定的职能，如果某个 Slot 验证失败（如触发限流），则抛出 BlockException，终止后续流程。

核心 Slot 链条：

1. NodeSelectorSlot：负责收集资源的路径，并将这些资源的调用路径，以树状结构存储起来，用于根据调用链路来限流。
2. ClusterBuilderSlot：用于存储资源的统计信息以及调用者信息，例如该资源的 RT, QPS, thread count 等等，这些信息将用作为多维度限流，降级的依据。
3. StatisticSlot（关键）：用于记录、统计不同纬度的 runtime 指标监控信息（使用滑动时间窗口算法）。
4. FlowSlot（核心）：用于根据预设的限流规则以及前面 slot 统计的状态，来进行流量控制。
5. DegradeSlot（核心）：通过统计信息以及预设的规则，来实现熔断降级。
6. SystemSlot：通过系统的状态，例如 load1 等，来控制总的入口流量。

3.3 源码核'心'：处理槽链的入口

一切从 SphU.entry() 开始。

// 源码位置：com.alibaba.csp.sentinel.CtSph
// 这是最常用的埋点入口
public Entry entry(String name, EntryType type, int count, Object... args) throws BlockException {
    // ...
    // 创建资源包装对象
    StringResourceWrapper resource = new StringResourceWrapper(name, type);
    // 【核心入口】进入责任链处理
    return entryWithPriority(resource, count, false, args);
}

private Entry entryWithPriority(ResourceWrapper resource, int count, boolean prioritized, Object... args) throws BlockException {
    // 获取当前线程的上下文
    Context context = ContextUtil.getContext();
    // ... 省略上下文初始化逻辑
    // 【核心】查找针对该资源的处理链 (ProcessorSlotChain)
    ProcessorSlot<Object> chain = lookProcessChain(resource);
    // 创建 Entry 对象
    Entry e = new CtEntry(resource, chain, context);
    try {
        // 【关键动作】启动责任链的流转！
        // chain.entry() 会依次调用链条中每个 Slot 的 entry 方法
        chain.entry(context, resource, null, count, prioritized, args);
    } catch (BlockException e1) {
        // 如果被阻塞，退出 Entry，并向上抛出异常
        e.exit(count, args);
        throw e1;
    } catch (Throwable e1) {
        // ... 其他异常处理
    }
    return e;
}

解读： Sentinel 的设计极其模块化。它没有写一堆复杂的 if-else 来判断是否限流或熔断，而是将所有逻辑封装在不同的 Slot 中，通过责任链串联起来。这使得扩展 Sentinel 的功能变得非常容易（只需添加新的 Slot）。

3.4 实战代码要点

Spring Cloud Alibaba 提供了完美的适配，通常我们不需要手动写 SphU.entry()。

依赖 (pom.xml):

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>sentinel-datasource-nacos</artifactId>
</dependency>

使用注解 (推荐):

@Service
public class OrderService {
    // 定义资源点，并指定降级方法
    @SentinelResource(value = "createOrder", blockHandler = "handleCreateOrderBlock")
    public String createOrder(Long goodsId) {
        // 业务逻辑
        return "Order Created";
    }

    // 降级处理方法，参数和返回值必须保持一致，且最后多一个 BlockException 参数
    public String handleCreateOrderBlock(Long goodsId, BlockException ex) {
        ex.printStackTrace();
        return "系统繁忙，下单失败 (限流降级)";
    }
}

4. 核心组件三：Seata —— 分布式事务终极解决方案

4.1 核心功能与定位

在微服务架构中，一个业务操作往往跨越多个服务、多个数据库。传统的本地事务失效，Seata 旨在提供高性能和简单易用的分布式事务服务。

Seata 提供了四种模式：AT、TCC、SAGA、XA。其中 AT 模式 (Automatic Transaction) 是其主推的、对业务无侵入的模式。

Seata 模型中的三个角色（TC、TM、RM）：

• TC (Transaction Coordinator) - 事务协调者：维护全局和分支事务的状态，驱动全局事务提交或回滚。（Seata Server 端）
• TM (Transaction Manager) - 事务管理器：定义全局事务的范围：开始全局事务、提交或回滚全局事务。（通常是发起方服务，标注 @GlobalTransactional 的地方）
• RM (Resource Manager) - 资源管理器：管理分支事务处理的资源，与 TC 交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚。（各个微服务中的数据库代理）

4.2 深层原理：AT 模式二阶段提交剖析

AT 模式本质上是一种改进的 2PC (两阶段提交) 协议，其核心在于利用本地事务和 Undo Log 实现自动回滚。

前提：基于支持本地 ACID 事务的关系型数据库。

关键：Seata 会代理应用的数据源 (DataSource Proxy)。

第一阶段 (Phase 1)：业务数据和回滚日志记录在同一个本地事务中提交

1. TM 向 TC 申请开启一个全局事务，生成全局唯一 XID。
2. XID 在微服务调用链路中传递。
3. RM (Seata 代理的数据源) 拦截业务 SQL。
4. 解析 SQL：RM 解析 SQL 语义，找到要操作的表和行。
5. 查询前镜像 (Before Image)：根据解析结果，查询数据执行前的数据状态，保存下来。
6. 执行业务 SQL：在本地数据库执行业务 SQL。
7. 查询后镜像 (After Image)：查询数据执行后的数据状态，保存下来。
8. 生成 Undo Log：利用前镜像和后镜像，生成一条回滚日志（SQL 语句），如 INSERT 对应 DELETE，UPDATE 对应反向 UPDATE。
9. 一并提交：将业务数据更新和 Undo Log 插入在同一个本地事务中提交到数据库。这样保证了业务执行和撤销记录的原子性。
10. RM 向 TC 汇报分支事务状态：成功。

第二阶段 (Phase 2)：TC 根据所有分支的状态决定提交或回滚

• 情况一：全局提交 (Global Commit)：所有分支都成功，TC 通知所有 RM 进行提交。RM 收到提交请求，只需异步删除对应的 Undo Log 即可（因为业务数据在一阶段已经落库了，效率极高）。
• 情况二：全局回滚 (Global Rollback)：任一分支失败，TC 通知所有 RM 进行回滚。RM 收到回滚请求，通过 XID 找到对应的 Undo Log。校验脏写：对比当前数据库数据与'后镜像'数据。如果一致，说明没有其他事务修改过这些数据，安全。执行回滚：根据 Undo Log 生成反向 SQL 并执行，将数据恢复到'前镜像'状态。提交本地回滚事务，并删除 Undo Log。

4.3 源码核'心'：数据源代理

Seata 如何做到无侵入？答案是它'劫持'了你的 JDBC 操作。核心类是 ConnectionProxy。

// 源码概要：io.seata.rm.datasource.ConnectionProxy
// 当业务代码调用 connection.commit() 时，实际上调用的是代理的 commit
@Override
public void commit() throws SQLException {
    try {
        // 代理逻辑：在提交前执行 Seata 的一阶段流程
        targetConnection.commit();
    } catch (SQLException e) {
        // ...
    }
}

// 真正的 Seata 处理逻辑在 processGlobalTransactionCommit
private void processGlobalTransactionCommit() throws SQLException {
    try {
        // 1. 注册分支事务 register();
        // Let server know that the branch is ready to commit.
        // 2. 写入 Undo Log 并执行业务 SQL (在之前已经完成准备)
        // 3. 提交本地事务 (包含业务数据和 Undo Log)
        targetConnection.commit();
        // 4. 向 TC 报告分支状态 report(true);
    } catch (Exception e) {
        // 报告失败
        throw e;
    }
}

(注：以上代码为简化概念演示，实际 Seata 源码中，SQL 解析、镜像构建和 Undo Log 生成是在 StatementProxy 和 ExecuteTemplate 中完成的，远比这复杂得多，但核心思想是代理数据库操作)

4.4 实战代码要点

依赖 (pom.xml):

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-seata</artifactId>
</dependency>

配置 (application.yml):

确保配置文件中配置了 seata server 的地址（或者通过 Nacos 寻址），并且配置了事务组。

使用注解:

在事务发起方的业务方法上添加 @GlobalTransactional。

@Service
public class BusinessService {
    @Autowired
    private StorageFeignClient storageFeignClient;
    @Autowired
    private OrderFeignClient orderFeignClient;

    // 只需这一个注解，开启全局事务
    // name 自定义，rollbackFor 指定回滚异常类型
    @GlobalTransactional(name = "create-order-tx", rollbackFor = Exception.class)
    public void purchase(String userId, String commodityCode, int orderCount) {
        // 1. 扣减库存 (RPC 调用远程服务，远程服务是一个 RM)
        storageFeignClient.deduct(commodityCode, orderCount);
        // 2. 创建订单 (RPC 调用远程服务，远程服务是一个 RM)
        orderFeignClient.create(userId, commodityCode, orderCount);
        // 如果这里抛出异常，上述两个远程服务的数据操作都会回滚
        // throw new RuntimeException("模拟异常，触发分布式回滚");
    }
}

5. 技术视野：SCA vs Spring Cloud Netflix

了解两者的差异有助于做出更优的架构决策。

6. 总结

Spring Cloud Alibaba 并非重复造轮子，而是在吸收了业界标准（Spring Cloud）和大规模生产实践（阿里巴巴内部）的精华后，打造的一套更接地气、更高性能、更易运维的微服务解决方案。

掌握 SCA，重点在于理解：

• Nacos 如何通过推拉结合实现高效服务发现，以及 Distro 协议保证高可用。
• Sentinel 如何利用责任链模式解耦各种流控降级逻辑。
• Seata AT 模式 如何巧妙地利用本地事务和 Undo Log 实现低侵入的分布式事务。

在构建新的微服务系统时，Spring Cloud Alibaba 已成为国内首选的技术栈。