【系统设计】高效的分布式系统:使用 Spring Boot 和 Kafka 实现 Saga 模式

在现代分布式系统中,管理跨多个服务的长事务至关重要。传统的分布式事务解决方案往往面临性能瓶颈和复杂性问题,而 Saga 模式 作为一种灵活高效的解决方案,逐渐受到开发者的青睐。本文将探讨如何利用 Spring BootKafka 实现 Saga 模式,并详细介绍事务补偿机制,帮助你构建稳定可靠的分布式系统。

什么是 Saga 模式?

原理介绍

在微服务架构中,一个业务流程通常涉及多个独立的服务。这些服务必须协同工作以完成完整的业务操作。例如,用户下单可能需要订单服务、支付服务和库存服务的合作。然而,跨服务操作通常涉及复杂的事务管理,传统的分布式事务(如两阶段提交)不仅效率低下,还难以扩展和维护。

Saga 模式 提供了一种替代方案,通过将一个长事务分解为一系列的本地事务,并通过事件或命令进行协调,从而实现最终一致性。这种方法不仅提高了系统的可扩展性,还简化了事务管理。

解决的问题及其重要性

Saga 模式解决了以下问题:

  1. 分布式事务管理:通过拆分事务,避免了传统分布式事务的性能和复杂性问题。
  2. 系统可扩展性:各服务独立运行,易于扩展和维护。
  3. 错误恢复:通过补偿机制,确保在步骤失败时,系统能恢复到一致状态。

在现代微服务架构中,确保跨服务操作的可靠性和一致性至关重要。Saga 模式提供了一个高效且灵活的解决方案,使系统在面对复杂业务流程和潜在错误时能够稳定运行。

Saga 模式的组成部分与实现方法

Saga 模式主要有两种实现方式:Choreography(编排)Orchestration(指挥)。下面将详细介绍这两种模式,并展示如何使用 Spring Boot 和 Kafka 实现它们,包括事务补偿机制。

架构图

编排模式
+----------------+        +----------------+        +----------------+
|  OrderService  |        | PaymentService |        | InventoryService|
+----------------+        +----------------+        +----------------+|                          |                         ||  CreateOrderCommand      |                         ||------------------------->|                         ||                          |                         ||      OrderCreatedEvent   |                         ||<-------------------------|                         ||                          |                         ||                          |      PaymentCommand     ||                          |------------------------>||                          |                         ||                          |    PaymentProcessedEvent ||                          |<------------------------||                          |                         ||      InventoryCommand    |                         ||------------------------->|                         ||                          |                         ||                          |    InventoryUpdatedEvent||<-------------------------|                         ||                          |                         |
指挥模式
+----------------+          +----------------+          +----------------+
| SagaOrchestrator|          | OrderService  |          | PaymentService |
+----------------+          +----------------+          +----------------+|                        |                           ||   CreateOrderCommand   |                           ||----------------------->|                           ||                        |                           ||   OrderCreatedEvent    |                           ||<-----------------------|                           ||                        |                           ||   PaymentCommand       |                           ||--------------------------------------------------->||                        |                           ||   PaymentApprovedEvent |                           ||<---------------------------------------------------||                        |                           ||                        |                           ||   InventoryCommand     |                           ||----------------------->|                           ||                        |                           |

1. 编排模式

编排模式 下,各服务通过事件进行通信和协调,没有中央控制器。每个服务独立地监听和发布事件,以完成整个业务流程。

1.1 组成部分
  • 事件定义:服务之间传递的消息,如 OrderCreatedEventPaymentProcessedEvent 等。
  • Kafka 生产者与消费者:用于事件的发布和订阅。
  • 各服务逻辑:根据收到的事件执行相应的操作,并发布下一个事件。
1.2 实现步骤与代码
1.2.1 定义事件
// OrderCreatedEvent.java
public class OrderCreatedEvent {private String orderId;private String product;private int quantity;// getters and setters
}// PaymentProcessedEvent.java
public class PaymentProcessedEvent {private String orderId;private boolean success;// getters and setters
}// PaymentFailedEvent.java
public class PaymentFailedEvent {private String orderId;private String reason;// getters and setters
}// OrderCancelledEvent.java
public class OrderCancelledEvent {private String orderId;// getters and setters
}
1.2.2 配置 Kafka
# application.yml
spring:kafka:bootstrap-servers: localhost:9092consumer:group-id: saga-groupauto-offset-reset: earliestkey-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializerproducer:key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializer
1.2.3 实现 OrderService
@Service
public class OrderService {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;private ObjectMapper mapper = new ObjectMapper();@KafkaListener(topics = "create-order-command", groupId = "order-service-group")public void handleCreateOrder(String message) throws JsonProcessingException {CreateOrderCommand command = mapper.readValue(message, CreateOrderCommand.class);// 创建订单逻辑// TODO: 保存订单到数据库// 发布 OrderCreatedEventOrderCreatedEvent event = new OrderCreatedEvent();event.setOrderId(command.getOrderId());event.setProduct(command.getProduct());event.setQuantity(command.getQuantity());String eventMsg = mapper.writeValueAsString(event);kafkaTemplate.send("order-created", eventMsg);}@KafkaListener(topics = "payment-failed", groupId = "saga-group")public void handlePaymentFailed(String message) throws JsonProcessingException {PaymentFailedEvent failedEvent = mapper.readValue(message, PaymentFailedEvent.class);// 取消订单逻辑cancelOrder(failedEvent.getOrderId());// 发布 OrderCancelledEventOrderCancelledEvent cancelledEvent = new OrderCancelledEvent();cancelledEvent.setOrderId(failedEvent.getOrderId());String cancelledMsg = mapper.writeValueAsString(cancelledEvent);kafkaTemplate.send("order-cancelled", cancelledMsg);}private void cancelOrder(String orderId) {// TODO: 取消订单逻辑}
}
1.2.4 实现 PaymentService
@Service
public class PaymentService {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;private ObjectMapper mapper = new ObjectMapper();@KafkaListener(topics = "order-created", groupId = "saga-group")public void handleOrderCreated(String message) throws JsonProcessingException {OrderCreatedEvent event = mapper.readValue(message, OrderCreatedEvent.class);// 处理支付逻辑boolean success = processPayment(event.getOrderId(), event.getQuantity());if (success) {// 发布 PaymentProcessedEventPaymentProcessedEvent paymentEvent = new PaymentProcessedEvent(event.getOrderId(), true);String paymentMsg = mapper.writeValueAsString(paymentEvent);kafkaTemplate.send("payment-processed", paymentMsg);} else {// 发布 PaymentFailedEventPaymentFailedEvent failedEvent = new PaymentFailedEvent();failedEvent.setOrderId(event.getOrderId());failedEvent.setReason("Payment processing failed.");String failedMsg = mapper.writeValueAsString(failedEvent);kafkaTemplate.send("payment-failed", failedMsg);}}private boolean processPayment(String orderId, int quantity) {// TODO: 实现支付逻辑,模拟支付失败return false;}
}
1.2.5 实现 InventoryService
@Service
public class InventoryService {@KafkaListener(topics = "order-cancelled", groupId = "saga-group")public void handleOrderCancelled(String message) throws JsonProcessingException {OrderCancelledEvent cancelledEvent = new ObjectMapper().readValue(message, OrderCancelledEvent.class);// 回滚库存逻辑rollbackInventory(cancelledEvent.getOrderId());}private void rollbackInventory(String orderId) {// TODO: 实现库存回滚逻辑}
}
1.3 事务补偿机制

编排模式 中,当某个服务的操作失败时,需要通过发布补偿事件来反向撤销之前的操作。上述代码中,PaymentService 在支付失败时发布 PaymentFailedEventOrderService 监听该事件并执行订单取消逻辑,随后发布 OrderCancelledEvent,最后 InventoryService 监听并回滚库存。

2. 指挥模式

指挥模式 下,存在一个中央的 Saga 管理器(Orchestrator),负责调度和协调各个服务的操作,并在需要时触发补偿机制。

2.1 组成部分
  • Saga Orchestrator:负责整个事务流程的控制和协调。
  • 命令和事件定义:如 CreateOrderCommandPaymentCommand 等。
  • Kafka 生产者与消费者:用于命令和事件的发布与订阅。
  • 各服务逻辑:根据接收到的命令执行操作,并发布相应的事件。
2.2 实现步骤与代码
2.2.1 定义命令和事件
// CreateOrderCommand.java
public class CreateOrderCommand {private String orderId;private String product;private int quantity;// getters and setters
}// OrderCreatedEvent.java
public class OrderCreatedEvent {private String orderId;// getters and setters
}// PaymentCommand.java
public class PaymentCommand {private String orderId;private double amount;// getters and setters
}// PaymentApprovedEvent.java
public class PaymentApprovedEvent {private String orderId;// getters and setters
}// PaymentRejectedEvent.java
public class PaymentRejectedEvent {private String orderId;private String reason;// getters and setters
}// CancelOrderCommand.java
public class CancelOrderCommand {private String orderId;// getters and setters
}// OrderCancelledEvent.java
public class OrderCancelledEvent {private String orderId;// getters and setters
}
2.2.2 实现 SagaOrchestrator
@Service
public class SagaOrchestrator {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;private ObjectMapper mapper = new ObjectMapper();@KafkaListener(topics = "order-created", groupId = "saga-orchestrator-group")public void handleOrderCreated(String message) throws JsonProcessingException {OrderCreatedEvent event = mapper.readValue(message, OrderCreatedEvent.class);try {// 发送 PaymentCommandPaymentCommand paymentCommand = new PaymentCommand();paymentCommand.setOrderId(event.getOrderId());paymentCommand.setAmount(calculateAmount(event.getOrderId()));String paymentCmd = mapper.writeValueAsString(paymentCommand);kafkaTemplate.send("payment-command", paymentCmd);} catch (Exception e) {// 发送补偿命令sendCancelOrderCommand(event.getOrderId());}}@KafkaListener(topics = "payment-approved", groupId = "saga-orchestrator-group")public void handlePaymentApproved(String message) throws JsonProcessingException {PaymentApprovedEvent event = mapper.readValue(message, PaymentApprovedEvent.class);// 继续后续操作,如库存更新// TODO: 发送其他命令或处理逻辑}@KafkaListener(topics = "payment-rejected", groupId = "saga-orchestrator-group")public void handlePaymentRejected(String message) throws JsonProcessingException {PaymentRejectedEvent event = mapper.readValue(message, PaymentRejectedEvent.class);// 发送补偿命令sendCancelOrderCommand(event.getOrderId());}public void startSaga(Order order) throws JsonProcessingException {// 发送 CreateOrderCommandCreateOrderCommand createCommand = new CreateOrderCommand();createCommand.setOrderId(order.getId());createCommand.setProduct(order.getProduct());createCommand.setQuantity(order.getQuantity());String createCmd = mapper.writeValueAsString(createCommand);kafkaTemplate.send("create-order-command", createCmd);}private void sendCancelOrderCommand(String orderId) throws JsonProcessingException {CancelOrderCommand cancelCommand = new CancelOrderCommand();cancelCommand.setOrderId(orderId);String cancelMsg = mapper.writeValueAsString(cancelCommand);kafkaTemplate.send("cancel-order-command", cancelMsg);}private double calculateAmount(String orderId) {// TODO: 实现金额计算逻辑return 100.0;}
}
2.2.3 修改 OrderService
@Service
public class OrderService {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;private ObjectMapper mapper = new ObjectMapper();@KafkaListener(topics = "create-order-command", groupId = "order-service-group")public void handleCreateOrder(String message) throws JsonProcessingException {CreateOrderCommand command = mapper.readValue(message, CreateOrderCommand.class);// 创建订单逻辑// TODO: 保存订单到数据库// 发布 OrderCreatedEventOrderCreatedEvent event = new OrderCreatedEvent();event.setOrderId(command.getOrderId());String eventMsg = mapper.writeValueAsString(event);kafkaTemplate.send("order-created", eventMsg);}@KafkaListener(topics = "cancel-order-command", groupId = "order-service-group")public void handleCancelOrder(String message) throws JsonProcessingException {CancelOrderCommand command = mapper.readValue(message, CancelOrderCommand.class);// 取消订单逻辑cancelOrder(command.getOrderId());// 发布 OrderCancelledEventOrderCancelledEvent event = new OrderCancelledEvent();event.setOrderId(command.getOrderId());String cancelledMsg = mapper.writeValueAsString(event);kafkaTemplate.send("order-cancelled", cancelledMsg);}private void cancelOrder(String orderId) {// TODO: 实现取消订单逻辑}
}
2.2.4 修改 PaymentService
@Service
public class PaymentService {@Autowiredprivate KafkaTemplate<String, String> kafkaTemplate;private ObjectMapper mapper = new ObjectMapper();@KafkaListener(topics = "payment-command", groupId = "payment-service-group")public void handlePaymentCommand(String message) throws JsonProcessingException {PaymentCommand command = mapper.readValue(message, PaymentCommand.class);// 处理支付逻辑boolean approved = processPayment(command.getOrderId(), command.getAmount());if (approved) {// 发布 PaymentApprovedEventPaymentApprovedEvent event = new PaymentApprovedEvent();event.setOrderId(command.getOrderId());String approvedMsg = mapper.writeValueAsString(event);kafkaTemplate.send("payment-approved", approvedMsg);} else {// 发布 PaymentRejectedEventPaymentRejectedEvent rejectedEvent = new PaymentRejectedEvent();rejectedEvent.setOrderId(command.getOrderId());rejectedEvent.setReason("Payment was rejected.");String rejectedMsg = mapper.writeValueAsString(rejectedEvent);kafkaTemplate.send("payment-rejected", rejectedMsg);}}private boolean processPayment(String orderId, double amount) {// TODO: 实现支付逻辑,模拟支付失败return false;}
}
2.2.5 实现 InventoryService
@Service
public class InventoryService {@KafkaListener(topics = "order-cancelled", groupId = "saga-orchestrator-group")public void handleOrderCancelled(String message) throws JsonProcessingException {OrderCancelledEvent cancelledEvent = new ObjectMapper().readValue(message, OrderCancelledEvent.class);// 回滚库存逻辑rollbackInventory(cancelledEvent.getOrderId());}private void rollbackInventory(String orderId) {// TODO: 实现库存回滚逻辑}
}
2.3 事务补偿机制

指挥模式 中,Saga Orchestrator 作为中央控制器,负责监控事务流程并在发生错误时触发补偿操作。例如,当 PaymentService 处理支付失败时,发布 PaymentRejectedEvent,Saga Orchestrator 监听到该事件后,发送 CancelOrderCommandOrderService 执行订单取消操作,确保系统一致性。

总结

Saga 模式为分布式系统中的长事务管理提供了一种高效且灵活的解决方案。通过 编排指挥 两种实现方式,开发者可以根据具体业务需求和系统架构选择最合适的方式。

  • 编排模式 适用于服务间关系较为松散、需要高扩展性的场景,各服务通过事件进行独立协调,但补偿逻辑较为分散。
  • 指挥模式 适用于需要集中控制事务流程、易于追踪和调试的场景,Saga Orchestrator 作为中央管理者,补偿逻辑统一管理,但可能成为系统的瓶颈。

无论选择哪种模式,事务补偿机制 都是确保系统可靠性和一致性的关键。通过合理设计补偿逻辑,可以有效应对分布式环境下的各种故障和异常,提升系统的健壮性。

借助 Spring BootKafka 强大的生态和工具支持,实现 Saga 模式变得更加便捷和高效。希望本文能够帮助你深入理解 Saga 模式,并在实际项目中灵活应用,打造稳定可靠的分布式系统。

参考资料

  • Saga Patterns: Managing Data Consistency in Microservices
  • Spring Cloud Stream 与 Kafka 集成
  • Axon Framework 官方文档

版权声明

本文为原创内容,转载请注明出处。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/885075.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

私有化视频平台EasyCVR海康大华宇视视频平台视频诊断技术是如何实时监测视频质量的?

在现代视频监控系统中&#xff0c;确保视频流的质量和稳定性至关重要。随着技术的进步&#xff0c;视频诊断技术已经成为实时监测视频质量的关键工具。这种技术通过智能分析算法对视频流进行实时评估和处理&#xff0c;能够自动识别视频中的各种质量问题&#xff0c;并给出相应…

大语言模型(LLM)量化基础知识(一)

请大家关注我的知乎博客&#xff1a;- 派神 - - 知乎 随着大型语言模型 (LLM) 的参数数量的增长,与其支持硬件&#xff08;加速器内存&#xff09;增长速度之间的差距越来越大&#xff0c;如下图所示&#xff1a; 上图显示&#xff0c;从 2017 年到 2022 年&#xff0c;语言模…

【comfyui教程】ComfyUI 现已支持 Stable Diffusion 3.5 Medium!人人都能轻松上手的图像生成利器

前言 ComfyUI 现已支持 Stable Diffusion 3.5 Medium&#xff01;人人都能轻松上手的图像生成利器 大家翘首以盼的Stable Diffusion 3.5 Medium模型终于来了&#xff01;就在今天&#xff0c;Stability AI 正式推出了这款“亲民版”平衡模型&#xff0c;让创作者们得以在消费…

大模型微调技术 --> LoRA 系列之 AdaLoRA

AdaLoRA 1.摘要 之前的微调方法(如低秩更新)通常将增量更新的预算均匀地分布在所有预训练的权重矩阵上&#xff0c;并且忽略了不同权重参数的不同重要性。结果&#xff0c;微调结果不是最优的。 为了弥补这一差距&#xff0c;我们提出了AdaLoRA&#xff0c;它根据权重矩阵的…

带你搞懂红黑树的插入和删除

文章目录 1. 红黑树1.1 红黑树的概念1.2 红黑树的性质1.3 红黑树节点的定义1.4 红黑树的插入找到插入的位置调节平衡 1.5 红黑树的删除删除节点平衡调整 1.6 红黑树和AVL树的比较 1. 红黑树 1.1 红黑树的概念 红黑树也是一种二叉搜索树,但是在每一个节点上增加了一个存储位表…

揭秘全向轮运动学:机动艺术与上下位机通信的智慧桥梁

✨✨ Rqtz 个人主页 : 点击✨✨ &#x1f308;Qt系列专栏:点击 &#x1f388;Qt智能车上位机专栏: 点击&#x1f388; 本篇文章介绍的是有关于全向轮运动学分析&#xff0c;单片机与上位机通信C代码以及ROS里程计解算的内容。 目录 大纲 ROS&#xff08;机器人操作系统&…

移远通信推出八款天线新品,覆盖5G、4G、Wi-Fi和LoRa领域

近日&#xff0c;全球领先的物联网整体解决方案供应商移远通信宣布&#xff0c;再次推出八款高性能天线新品&#xff0c;进一步丰富其天线产品阵容&#xff0c;更好地满足全球客户对高品质天线的更多需求。具体包括5G超宽带天线YECT005W1A和YECT004W1A、5G天线YECT028W1A、4G天…

【设计模式系列】桥接模式(十三)

一、什么是桥接模式 桥接模式&#xff08;Bridge Pattern&#xff09;是一种结构型设计模式&#xff0c;其核心目的是将抽象部分与实现部分分离&#xff0c;使它们可以独立地变化。这种模式主要用于处理那些在设计时无法确定实现细节的场合&#xff0c;或者需要在多个实现之间…

Java多态和继承(下篇)

今天接着学习多态和继承 目录 1 继承1.1 再谈初始化1.2 protect关键字1.3 继承方式1.4 final 关键字1.5 组合 2 多态2.1 多态的概念2.2 多态实现条件2.3 重写2.4 向上转型和向下转型2.4.1 向上转型2.4.2 向下转型 2.5 多态的优缺点2.6 避免在构造方法中使用重写的方法 总结 1 继…

动态规划理论基础和习题【力扣】【算法学习day.25】

前言 ###我做这类文档一个重要的目的还是给正在学习的大家提供方向&#xff08;例如想要掌握基础用法&#xff0c;该刷哪些题&#xff1f;&#xff09;我的解析也不会做的非常详细&#xff0c;只会提供思路和一些关键点&#xff0c;力扣上的大佬们的题解质量是非常非常高滴&am…

数据结构之顺序表(C语言)

1 线性表 线性表是n个具有相同特性的数据元素的有限序列&#xff0c;是一种在实际中广泛应用的数据结构&#xff0c;常见的线性表有&#xff1a;顺序表、链表、栈、队列、字符串等。 线性表在逻辑上是线性结构&#xff0c;也就说是连续的一条直线。但是在物理结构上并不一定是…

Qt——窗口

一.窗口概述 Qt 窗口是通过 QMainWindow 类来实现的。 QMainWindow是一个为用户提供主窗口程序的类&#xff0c;继承QWidget类&#xff0c;并且提供一个预定义的布局。包含一个菜单栏&#xff08;menu bar&#xff09;&#xff0c;多个工具栏&#xff08;tool bars&#xff0…

长亭那个检测能力超强的 WAF,出免费版啦

告诉你们一个震撼人心的消息&#xff0c;那个检测能力超强的 WAF——长亭雷池&#xff0c;他推出免费社区版啦&#xff0c;体验地址见文末。 八年前我刚从学校毕业&#xff0c;在腾讯做安全研究&#xff0c;看到宇森在 BlackHat 上演讲的议题 《永别了&#xff0c;SQL 注入》 …

漏洞分析 | Spring Framework路径遍历漏洞(CVE-2024-38816)

漏洞概述 VMware Spring Framework是美国威睿&#xff08;VMware&#xff09;公司的一套开源的Java、JavaEE应用程序框架。该框架可帮助开发人员构建高质量的应用。 近期&#xff0c;网宿安全演武实验室监测到Spring Framework在特定条件下&#xff0c;存在目录遍历漏洞&…

tp接口 入口文件 500 错误原因

一、描述 二、可能的原因 1、runtime目录没权限 2、关闭了Tp记录日志的功能 3、关闭debug调试模式 4、关闭了debug模式还是报错 一、描述 Thinkphp项目本地正常&#xff0c;上传到线上后静态文件访问正常&#xff0c;访问tp接口报500错误。 经调试发现&#xff0c;在php入…

第07章 运算符的使用

一、算数运算符 算术运算符主要用于数学运算&#xff0c;其可以连接运算符前后的两个数值或表达式&#xff0c;对数值或表达式进行加 &#xff08;&#xff09;、减&#xff08;-&#xff09;、乘&#xff08;*&#xff09;、除&#xff08;/&#xff09;和取模&#xff08;%&a…

十七 MyBatis的注解式开发

十七、MyBatis的注解式开发 mybatis中也提供了注解式开发方式&#xff0c;采用注解可以减少Sql映射文件的配置。 当然&#xff0c;使用注解式开发的话&#xff0c;sql语句是写在java程序中的&#xff0c;这种方式也会给sql语句的维护带来成本。 官方是这么说的&#xff1a; 使…

用 Python 写了一个天天酷跑(附源码)

Hello&#xff0c;大家好&#xff0c;给大家说一下&#xff0c;我要开始装逼了 这期写个天天酷跑玩一下叭&#xff01; 制作一个完整的“天天酷跑”游戏涉及很多方面&#xff0c;包括图形渲染、物理引擎、用户输入处理、游戏逻辑等。由于Python是一种高级编程语言&#xff0c;…

Kettle——CSV文件转换成excel文件输出

1.点击—文件—新建—转换 拖入两个组件&#xff1a; 按shift&#xff0b;鼠标左击建立连接&#xff0c;并点击主输出步骤&#xff0c; 点击CSV文件输入&#xff0c;选择浏览的csv文件&#xff0c;然后点击确定 同样&#xff0c;Excel也同上&#xff0c;只是要删除这个xls 并…

高效管理iPhone存储:苹果手机怎么删除相似照片

在使用iPhone的过程中&#xff0c;我们经常会遇到存储空间不足的问题&#xff0c;尤其是当相册中充满了大量相似照片时。这些照片不仅占用了宝贵的存储空间&#xff0c;还可能使iPhone出现运行卡顿的情况。因此&#xff0c;我们迫切需要寻找苹果手机怎么删除相似照片的方法&…