编程中一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。就是说,一次和多次请求某一个资源会产生同样的作用影响。
2、HTTP请求遵循Http协议的请求,越来越强调Rest请求风格,可以更好的规范和理解接口的设计。
GET:用于获取资源,不应有副作用,所以是幂等的;
POST:用于创建资源,重复提交POST请求可能产生两个不同的资源,有副作用不满足幂等性;
PUT:用于更新操作,重复提交PUT请求只会对其URL中指定的资源有副作用,满足幂等性;
DELETE:用于删除资源,有副作用,但它应该满足幂等性;
HEAD:和GET本质是一样的,但HEAD不含有呈现数据,仅是HTTP头信息,没有副作用,满足幂等性;
OPTIONS:用于获取当前URL所支持的请求方法,满足幂等性;
二、场景业务分析 1、订单支付实际开发中,经常会面对订单支付问题,基本流程如下:
客户端发起订单支付请求 ;
支付前系统本地相关业务处理 ;
请求第三方支付服务执行扣款;
第三方支付返回处理结果;
本地服务基于支付结果响应客户端;
该业务流程中要处理相当复杂的问题,比如事务,分布式事务,接口延迟超时,客户端重复提交等等,这里只基于幂等接口角度来看该流程,其他问题后续再聊。
2、幂等接口当上述流程的支付请求有明确结果的时候:失败或成功,这样业务流程都好处理,但是例如支付场景如果请求超时,如何判断服务的结果状态:客户端请求超时,本地服务超时,请求支付超时,支付回调超时,客户端响应超时等等。
这就需要设计流程化的状态管理。
3、基础操作案例模拟管理上述流程,设计幂等接口:
表结构设计
CREATE TABLE `dp_order_state` ( `order_id` BIGINT (20) NOT NULL AUTO_INCREMENT COMMENT '订单id', `token_id` VARCHAR (50) DEFAULT NULL COMMENT '防重复提交', `state` INT (1) DEFAULT '1' COMMENT '1创建订单,2本地业务,3支付业务', PRIMARY KEY (`order_id`) ) ENGINE = INNODB DEFAULT CHARSET = utf8 COMMENT = '订单状态表'; CREATE TABLE `dp_state_record` ( `id` INT (11) NOT NULL AUTO_INCREMENT COMMENT '主键ID', `order_id` BIGINT (20) NOT NULL COMMENT '订单id', `state_dec` VARCHAR (50) DEFAULT NULL COMMENT '状态描述', PRIMARY KEY (`id`) ) ENGINE = INNODB DEFAULT CHARSET = utf8 COMMENT = '状态记录表';模拟业务流程
将订单创建,本地业务,支付业务,分开分段管理提交。分阶段测试异常熔断的业务。
@Service public class OrderServiceImpl implements OrderService { @Resource private OrderStateMapper orderStateMapper ; @Resource private StateRecordMapper stateRecordMapper ; @Override public OrderState queryOrder(OrderState orderState) { Map<String,Object> paramMap = new HashMap<>() ; paramMap.put("order_id",orderState.getOrderId()); List<OrderState> orderStateList = orderStateMapper.selectByMap(paramMap); if (orderStateList != null && orderStateList.size()>0){ return orderStateList.get(0) ; } return null ; } @Override public boolean createOrder(OrderState orderState) { int saveRes = orderStateMapper.insert(orderState); if (saveRes > 0){ saveStateRecord(orderState.getOrderId(),"订单创建成功"); } return saveRes > 0 ; } @Override public boolean localBiz(OrderState orderState) { orderState.setState(2); int updateRes = orderStateMapper.updateState(orderState) ; if (updateRes > 0){ saveStateRecord(orderState.getOrderId(),"本地业务成功"); } return updateRes > 0; } @Override public boolean paymentBiz(OrderState orderState) { orderState.setState(3); int updateRes = orderStateMapper.updateState(orderState) ; if (updateRes > 0){ saveStateRecord(orderState.getOrderId(),"支付业务成功"); } return updateRes > 0; } private void saveStateRecord (Long orderId,String stateDec){ StateRecord stateRecord = new StateRecord() ; stateRecord.setOrderId(orderId); stateRecord.setStateDec(stateDec); stateRecordMapper.insert(stateRecord) ; } }测试接口
根据订单状态,分段补偿执行未完成的业务,如果该订单已经完成,多次提交不影响最终结果。
@Api(value = "OrderController") @RestController public class OrderController { @Resource private OrderService orderService ; @PostMapping("/submitOrder") public String submitOrder (OrderState orderState){ OrderState orderState01 = orderService.queryOrder(orderState) ; if (orderState01 == null){ // 正常业务流程 orderService.createOrder(orderState) ; orderService.localBiz(orderState) ; orderService.paymentBiz(orderState) ; } else { switch (orderState01.getState()){ case 1: // 订单创建成功:后推执行本地和支付业务 orderService.localBiz(orderState01) ; orderService.paymentBiz(orderState01) ; break ; case 2: // 订单本地业务成功:后推执行支付业务 orderService.paymentBiz(orderState01) ; break ; default: break ; } } return "success" ; } }