当前位置：首页 > news >正文

接口幂等设计

news 2026/5/12 11:32:44

幂等接口设计
常见策略
唯一索引/约束
去重表（配合唯一索引）
状态机幂等
Token 机制（适用于防止重复提交）
分布式锁（Redis/ Zookeeper）
总结
幂等接口设计
网络重试
客户端因超时重试导致请求重复提交

消息重复
消息队列中间件可能重复投递消息

用户误操作
用户多次点击提交按钮

系统容错
分布式系统依赖重试保证最终一致性，幂等性是基础

常见策略
唯一索引/约束

利用数据库的唯一索引防止重复数据插入。
适用于创建业务单据（如订单号、支付流水号唯一）

CREATE TABLE order (
id bigint(20) NOT NULL AUTO_INCREMENT,
order_no varchar(64) NOT NULL COMMENT '订单号',
status tinyint(4) DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY uk_order_no (order_no)
) ENGINE=InnoDB;
去重表（配合唯一索引）

使用独立的去重表记录已处理的请求标识，利用数据库唯一约束实现幂等

@Transactional
public void processOrder(Request request) {
String requestId = request.getRequestId();
// 插入去重记录，利用数据库唯一约束
try {
deduplicationDao.insert(requestId);
} catch (DuplicateKeyException e) {
// 已处理，直接返回或抛出异常
return;
}
// 执行实际业务逻辑
orderDao.create(request.getOrder());
}
状态机幂等

对于有状态变更的业务（如订单状态流转），通过限制状态转移方向实现幂等

public boolean payOrder(String orderId) {
Order order = orderDao.selectByOrderId(orderId);
if (order.getStatus() == OrderStatus.PENDING_PAY) {
order.setStatus(OrderStatus.PAID);
orderDao.update(order);
return true;
}
// 已经支付过了，视为成功但不再重复处理
return false;
}
Token 机制（适用于防止重复提交）

服务端生成唯一token下发到客户端（如表单隐藏域）

// 生成token
public String generateToken(String userId) {
String token = UUID.randomUUID().toString();
redisTemplate.opsForValue().set(TOKEN_PREFIX + userId, token, 30, TimeUnit.MINUTES);
return token;
}

// 执行业务前校验token
public boolean checkAndRemoveToken(String userId, String token) {
String key = TOKEN_PREFIX + userId;
String storedToken = redisTemplate.opsForValue().get(key);
if (token.equals(storedToken)) {
redisTemplate.delete(key);
return true;
}
return false;
}
分布式锁（Redis/ Zookeeper）

public void handleRequest(String orderId) {
String lockKey = "lock:order:" + orderId;
boolean locked = redisLock.tryLock(lockKey, 10, TimeUnit.SECONDS);
if (!locked) {
// 未获取到锁，可能是重复请求，直接返回或稍后重试
return;
}
try {
// 检查是否已处理（结合去重表）
if (processedChecker.isProcessed(orderId)) {
return;
}
// 业务处理
doBusiness(orderId);
// 标记已处理
processedChecker.markProcessed(orderId);
} finally {
redisLock.unlock(lockKey);
}
}
总结