zoukankan      html  css  js  c++  java
  • 接口幂等性实现

    什么是幂等性?

    对于同一笔业务操作,不管调用多少次,得到的结果都是一样的。

    幂等性设计

    我们以对接支付宝充值为例,来分析支付回调接口如何设计?

    如果我们系统中对接过支付宝充值功能的,我们需要给支付宝提供一个回调接口,支付宝回调信息中会携带(out_trade_no【商户订单号】,trade_no【支付宝交易号】),trade_no在支付宝中是唯一的,out_trade_no在商户系统中是唯一的。

    回调接口实现有以下实现方式。

    方式1(普通方式)

    过程如下:

    1.接收到支付宝支付成功请求

    2.根据trade_no查询当前订单是否处理过

    3.如果订单已处理直接返回,若未处理,继续向下执行

    4.开启本地事务

    5.本地系统给用户加钱

    6.将订单状态置为成功

    7.提交本地事务

    上面的过程,对于同一笔订单,如果支付宝同时通知多次,会出现什么问题?当多次通知同时到达第2步时候,查询订单都是未处理的,会继续向下执行,最终本地会给用户加两次钱。

    此方式适用于单机其,通知按顺序执行的情况,只能用于自己写着玩玩。

    方式2(jvm加锁方式)

    方式1中由于并发出现了问题,此时我们使用java中的Lock加锁,来防止并发操作,过程如下:

    1.接收到支付宝支付成功请求

    2.调用java中的Lock加锁

    3.根据trade_no查询当前订单是否处理过

    4.如果订单已处理直接返回,若未处理,继续向下执行

    5.开启本地事务

    6.本地系统给用户加钱

    7.将订单状态置为成功

    8.提交本地事务

    9.释放Lock锁

    分析问题:Lock只能在一个jvm中起效,如果多个请求都被同一套系统处理,上面这种使用Lock的方式是没有问题的,不过互联网系统中,多数是采用集群方式部署系统,同一套代码后面会部署多套,如果支付宝同时发来多个通知经过负载均衡转发到不同的机器,上面的锁就不起效了。此时对于多个请求相当于无锁处理了,又会出现方式1中的结果。此时我们需要分布式锁来做处理。

    方式3(悲观锁方式)

    使用数据库中悲观锁实现。悲观锁类似于方式二中的Lock,只不过是依靠数据库来实现的。数据中悲观锁使用for update来实现,过程如下:

    1.接收到支付宝支付成功请求

    2.打开本地事物

    3.查询订单信息并加悲观锁

    select * from t_order where order_id = trade_no for update;

    4.判断订单是已处理

    5.如果订单已处理直接返回,若未处理,继续向下执行

    6.给本地系统给用户加钱

    7.将订单状态置为成功

    8.提交本地事物

    重点在于for update,对for update,做一下说明:

    1.当线程A执行for update,数据会对当前记录加锁,其他线程执行到此行代码的时候,会等待线程A释放锁之后,才可以获取锁,继续后续操作。

    2.事物提交时,for update获取的锁会自动释放。

    方式3可以正常实现我们需要的效果,能保证接口的幂等性,不过存在一些缺点:1.如果业务处理比较耗时,并发情况下,后面线程会长期处于等待状态,占用了很多线程,让这些线程处于无效等待状态,我们的web服务中的线程数量一般都是有限的,如果大量线程由于获取for update锁处于等待状态,不利于系统并发操作。

    方式4(乐观锁方式)

    依靠数据库中的乐观锁来实现。

    1.接收到支付宝支付成功请求

    2.查询订单信息

    select * from t_order where order_id = trade_no;

    3.判断订单是已处理

    4.如果订单已处理直接返回,若未处理,继续向下执行

    5.打开本地事物

    6.给本地系统给用户加钱

    7.将订单状态置为成功,注意这块是重点,伪代码:

    update t_order set status = 1 where order_id = trade_no where status = 0;
    //上面的update操作会返回影响的行数num
    if(num==1){
      //表示更新成功
      提交事务;
    }else{
      //表示更新失败
      回滚事务;
    }

    注意:

    update t_order set status = 1 where order_id = trade_no where status = 0; 是依靠乐观锁来实现的,status=0作为条件去更新,类似于java中的cas操作;

    执行这条sql的时候,如果有多个线程同时到达这条代码,数据内部会保证update同一条记录会排队执行,最终最有一条update会执行成功,其他未成功的,他们的num为0,然后根据num来进行提交或者回滚操作。

    方式5(唯一约束方式)

    依赖数据库中唯一约束来实现。

    我们可以创建一个表:

    CREATE TABLE `t_uq_dipose` (
    `id` bigint(20) NOT AUTO_INCREMENT,
    `ref_type` varchar(32) NOT DEFAULT '' COMMENT '关联对象类型',
    `ref_id` varchar(64) NOT DEFAULT '' COMMENT '关联对象id',
    PRIMARY KEY (`id`),
    UNIQUE KEY `uq_1` (`ref_type`,`ref_id`) COMMENT '保证业务唯一性'
    );

    对于任何一个业务,有一个业务类型(ref_type),业务有一个全局唯一的订单号,业务来的时候,先查询t_uq_dipose表中是否存在相关记录,若不存在,继续放行。

    过程如下:

    1.接收到支付宝支付成功请求

    2.查询t_uq_dipose(条件ref_id,ref_type),可以判断订单是否已处理

    select * from t_uq_dipose where ref_type = '充值订单' and ref_id = trade_no;

    3.判断订单是已处理

    4.如果订单已处理直接返回,若未处理,继续向下执行

    5.打开本地事物

    6.给本地系统给用户加钱

    7.将订单状态置为成功

    8.向t_uq_dipose插入数据,插入成功,提交本地事务,插入失败,回滚本地事务,伪代码:

    try{
    insert into t_uq_dipose (ref_type,ref_id) values ('充值订单',trade_no);
    //提交本地事务:
    }catch(Exception e){
    //回滚本地事务;
    }

    说明:

    对于同一个业务,ref_type是一样的,当并发时,插入数据只会有一条成功,其他的会违法唯一约束,进入catch逻辑,当前事务会被回滚,最终最有一个操作会成功,从而保证了幂等性操作。

    关于这种方式可以写成通用的方式,不过业务量大的情况下,t_uq_dipose插入数据会成为系统的瓶颈,需要考虑分表操作,解决性能问题。

    上面的过程中向t_uq_dipose插入记录,最好放在最后执行,原因:插入操作会锁表,放在最后能让锁表的时间降到最低,提升系统的并发性。

    关于消息服务中,消费者如何保证消息处理的幂等性?每条消息都有一个唯一的消息id,类似于上面业务中的trade_no,使用上面的方式即可实现消息消费的幂等性。

  • 相关阅读:
    人一生最后悔五件事
    C# 实现程序只启动一次(多次运行激活第一个实例,使其获得焦点,并在最前端显示)
    socket 编程 学习2
    Linux内核源码阅读以及工具(转)
    迭代法
    C语言程序设计 C语言中的时间函数(转)
    线段的平移
    数独(sudoku)的生成与破解(转)
    PageBase,ControlBase,Base Class
    Oracle “万年虫”
  • 原文地址:https://www.cnblogs.com/aaron911/p/11612871.html
Copyright © 2011-2022 走看看