关于分布式项目的补偿机制（案例总结）

news2024/11/23 7:46:39

【辰兮要努力】：hello你好我是辰兮，很高兴你能来阅读，昵称是希望自己能不断精进，向着优秀程序员前行！

博客来源于项目以及编程中遇到的问题总结，偶尔会有读书分享，我会陆续更新Java前端、后台、数据库、项目案例等相关知识点总结，感谢你的阅读和关注，希望我的博客能帮助到更多的人，分享获取新知，大家一起进步!

吾等采石之人，应怀大教堂之心，愿我们奔赴在各自的热爱里…

一、业务场景

在这里插入图片描述

给大家整理一下最近遇到的项目问题： A服务生成数据后推送给B服务，此时B服务挂掉，后续如何解决

先说一下我的解决思路，因为我们项目没有用到分布式事务，所以就用补偿机制和手动回滚数据来解决分享思路交流经验

二、补偿解决

1.创建一个数据表记录推送失败的数据
2.创建一个定时任务隔一段时间后重推数据到B系统

记录表里对应的数据会有一个标识号，如果数据成功推送或者补偿成功，修改此标识符合，数据不会重复推送

我这里说的是创建MySQL表来实现对应的补偿。同时还有很多其余的补偿方法

例如

重试机制：A服务可以设计一个重试机制，在B服务挂掉后，定期尝试重新推送数据。如果在一定时间内B服务重启，并能够恢复接收数据，A服务就可以将数据成功推送给B服务。

存储数据：A服务可以将生成的数据暂时存储在一个数据存储系统中（如Redis、Kafka），等待B服务重新恢复后，再从存储系统中读取数据并推送给B服务。

下面是一个简单的定时任务推送案例的Java代码：

import java.util.*;
import java.util.concurrent.TimeUnit;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

@Component
public class OrderTask {
    
    @Autowired
    private RestTemplate restTemplate;
    
    // 定义推送订单信息的方法
    private void pushOrderInfo(OrderInfo orderInfo) {
        String url = "http://logistics-service/push_order_info";
        try {
            String response = restTemplate.postForObject(url, orderInfo, String.class);
            System.out.println("订单信息已成功推送！响应内容为：" + response);
        } catch (Exception e) {
            System.out.println("订单信息推送失败，错误信息为：" + e.getMessage());
        }
    }
    
    // 定时任务：检查未处理的订单信息并重新推送给物流服务
    @Scheduled(fixedRate = 10000) // 每10秒钟执行一次
    private void checkUnprocessedOrders() {
        // 查询未处理的订单信息
        List<OrderInfo> unprocessedOrders = getUnprocessedOrders();
        // 遍历未处理的订单信息，并重新推送给物流服务
        for (OrderInfo order : unprocessedOrders) {
            pushOrderInfo(order);
        }
    }
    
    // 查询未处理的订单信息（这个方法的具体实现可以根据实际情况而定）
    private List<OrderInfo> getUnprocessedOrders() {
        // TODO: 查询未处理的订单信息
        return new ArrayList<>();
    }

}

其中，pushOrderInfo()方法用于将订单信息推送给物流服务，checkUnprocessedOrders()方法则用于定时查询未被处理的订单信息，并重新推送给物流服务。在OrderTask类上，使用了Spring的@Component注解，表示这是一个组件类，可以被Spring容器扫描到并实例化。使用了Spring的@Autowired注解，表示需要注入RestTemplate对象，用于发送HTTP请求。在checkUnprocessedOrders()方法上，使用了Spring的@Scheduled注解，表示这是一个定时任务，可以定期执行指定的方法。这里设置了fixedRate属性为10000，表示每隔10秒钟执行一次。在实际使用中，可以根据具体需求来设置定时任务的执行频率。