- 当前位置：首页 >人工智能 >互联网业务幂等性实现之基于MySQL
互联网业务幂等性实现之基于MySQL
发布时间：2025-11-05 07:39:23 来源：创站工坊 作者：应用开发
背景
在互联网业务领域中，互联我们经常会遇到应用到请求幂等性问题，网业务幂即多次重复请求，等性所得到的实现结果，和一次请求一致。互联
以某互联网电商的网业务幂取消订单为例子，当订单取消，等性需要返回给消费者下单所消费的实现虚拟产品，如优惠券、互联红包、网业务幂京豆等。等性通过幂等形式，实现确保返还给消费者的互联权益不多、不少。网业务幂
那幂等性具体开发是等性怎么实现的呢?本文带来基于MySQL的UNIQUE KEY的实现方案。
实现
众所周知，UNIQUE KEY是数据库中的唯一索引，数据库的记录中不允许有重复的值，我们可以利用这点，云服务器提供商在处理业务前，先进行唯一索引数据(如订单id)的插入操作：
插入成功，说明是第一次插入，正常处理业务;插入失败，说明该业务逻辑已经处理过了，不做处理，提前返回;如此，即可实现幂等性。
1.数据库设计
幂等性辅助表设计如下：
复制CREATE TABLE `idempotent_validate` ( `id` bigint NOT NULL, `create_time` time DEFAULT NULL, `order_id` bigint DEFAULT NULL, PRIMARY KEY (`id`), UNIQUE KEY `UK_orssam7fgn4uj0lo2sn4on6vg` (`order_id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;1.2.3.4.5.6.7.其中的一个字段order_id，我们定义为唯一索引。
2.代码编写我们主要实现了订单取消方法cancelOrder：
复制package com.example.idempotentmysql.service.impl;import com.example.idempotentmysql.bean.IdempotentValidate;import com.example.idempotentmysql.bean.OrderInfo;import com.example.idempotentmysql.bean.ProductInfo;import com.example.idempotentmysql.bean.UserInfo;import com.example.idempotentmysql.repository.IdempotentValidateRepository;import com.example.idempotentmysql.repository.OrderInfoRepository;import com.example.idempotentmysql.repository.ProductInfoRepository;import com.example.idempotentmysql.repository.UserInfoRepository;import com.example.idempotentmysql.service.OrderService;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.stereotype.Service;import javax.annotation.Resource;import java.util.Optional;/** * 订单服务 * * @author hongcunlin */@Service
public class OrderServiceImpl implements OrderService { /** * 日志 */ private static final Logger LOGGER = LoggerFactory.getLogger(OrderServiceImpl.class); /** * 用户repository */@Resource
private UserInfoRepository userInfoRepository; /** * 商品repository */@Resource
private ProductInfoRepository productInfoRepository; /** * 订单repository */@Resource
private OrderInfoRepository orderInfoRepository; /** * 幂等性校验 */@Resource
private IdempotentValidateRepository idempotentValidateRepository; /** * 取消订单（带幂等性校验） * * @param orderId 订单id */@Override
public void cancelOrder(Long orderId) { // 1.幂等性校验
try { IdempotentValidate idempotentValidate = new IdempotentValidate(); idempotentValidate.setOrderId(orderId); idempotentValidateRepository.save(idempotentValidate); } catch (Exception e) { LOGGER.info("订单退款幂等"); return; } // 2.退款
Optional<OrderInfo> orderInfoOptional = orderInfoRepository.findById(orderId); if (orderInfoOptional.isPresent()) { OrderInfo orderInfo = orderInfoOptional.get(); Optional<UserInfo> userInfoOptional = userInfoRepository.findById(orderInfo.getUserId()); Optional<ProductInfo> productInfoOptional = productInfoRepository.findById(orderInfo.getProductId()); if (userInfoOptional.isPresent() && productInfoOptional.isPresent()) { UserInfo userInfo = userInfoOptional.get(); ProductInfo productInfo = productInfoOptional.get(); userInfo.setMoney(userInfo.getMoney().add(productInfo.getPrice())); userInfoRepository.save(userInfo); } } LOGGER.info("订单成功退款"); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.60.61.62.63.64.65.66.67.68.69.70.71.72.73.74.75.76.77.78.79.80.81.82.83.84.85.86.87.从代码中可以看到，我们在除了订单退款前，幂等性表先拿订单id进行插入操作，若插入成功，说明是第一次取消订单，执行下面的退款逻辑;
若插入失败，说明之前已经进行过退款逻辑了，我们提前返回，不做下面的退款操作。
如此，便实现了订单退款的幂等性。
3.测试我们对订单进行3次取消操作：
复制package com.example.idempotentmysql.service;import com.example.idempotentmysql.bean.OrderInfo;import org.junit.jupiter.api.Test;import org.springframework.boot.test.context.SpringBootTest;import javax.annotation.Resource;@SpringBootTest
public class OrderServiceTest {@Resource
private OrderService orderService;@Test
public void cancelOrderTest() { orderService.cancelOrder(6L); orderService.cancelOrder(6L); orderService.cancelOrder(6L); }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.可以看到，只有第一次是企商汇退款成功的，后面2次触发幂等性，退款失败，符合我们的预期。
其他
幂等性的实现方式还有很多种，基于MySQL的UNIQUE KEY的实现方案，实现起来相当简单，仅适合业务简单，并发量不高的场景。原因是MySQL的qps有限，且MySQL作为系统的最底层的应用，过于后置，如果最终幂等返回，比较浪费前置的业务处理所消耗的资源。
本文代码已经上传到github上了，有需要的同学可以下载参考：https://github.com/larger5/idempotent-mysql
- 用粘土手工打造独特电脑装饰（发挥创意，打造个性化电脑装饰品）
- 标星 1.3 k 的一个开源书籍，带你玩转 Go
- 鸿蒙3. WiFi IoT智能家居套件 - Helloworld及基本开发框架
- Python超市进销存管理系统！老妈开超市有系统了
- 75寸电视最佳观看距离和尺寸的科学指南（如何选择适合的75寸电视？）
- 在Scrapy中如何利用Xpath选择器从网页中采集目标数据——详细教程（上篇）
- 牛掰了！鸿蒙与Android完美融合，将鸿蒙设备当Android设备用
- 一分钟搞定Scrapy分布式爬虫、队列和布隆过滤器
- 手机连接电脑时发生未知错误的解决方法（解决手机连接电脑出现问题的简易步骤）
- 深入Python中的 Collections 模块
随便看看
香港云服务器IT技术网企商汇IT资讯网服务器租用源码下载源码库亿华云益华科技技术快报益华科技智能时代多维IT资讯亿华云益强科技亿华灵动码上建站运维纵横创站工坊云智核亿华互联全栈开发益强数据堂益强编程堂益强编程舍亿华科技益强IT技术网IT资讯网极客码头亿华智慧云益强科技益华IT技术论坛亿华云计算益强智未来科技前瞻益强资讯优选益强智囊团云站无忧极客编程益华科技编程之道益强前沿资讯
- Copyright © 2025 Powered by 互联网业务幂等性实现之基于MySQL,创站工坊 滇ICP备2023006006号-44sitemap