- 当前位置：首页 >IT科技类资讯 >互联网业务幂等性实现之基于MySQL
互联网业务幂等性实现之基于MySQL
发布时间：2025-11-05 02:34:02 来源：创站工坊 作者：IT科技类资讯
背景
在互联网业务领域中，互联我们经常会遇到应用到请求幂等性问题，网业务幂即多次重复请求，等性所得到的实现结果，和一次请求一致。互联
以某互联网电商的网业务幂取消订单为例子，当订单取消，等性需要返回给消费者下单所消费的实现虚拟产品，如优惠券、互联红包、网业务幂京豆等。等性通过幂等形式，实现确保返还给消费者的互联权益不多、不少。网业务幂
那幂等性具体开发是等性怎么实现的呢?本文带来基于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
- Copyright © 2025 Powered by 互联网业务幂等性实现之基于MySQL,创站工坊 滇ICP备2023006006号-44sitemap