zoukankan      html  css  js  c++  java
  • .net Core数据的幕等性

    一、背景 

    代码实例:https://gitee.com/D_C_L/CurtainEtcAOP.git
    我们实际系统中有很多操作,是不管做多少次,都应该产生一样的效果或返回一样的结果。 
    例如:
     

    1. 前端重复提交选中的数据,应该后台只产生对应这个数据的一个反应结果。 
    2. 我们发起一笔付款请求,应该只扣用户账户一次钱,当遇到网络重发或系统bug重发,也应该只扣一次钱; 
    3. 发送消息,也应该只发一次,同样的短信发给用户,用户会哭的; 
    4. 创建业务订单,一次业务请求只能创建一个,创建多个就会出大问题。 

    等等很多重要的情况,这些逻辑都需要幂等的特性来支持。 

    二、幂等性概念
     
    幂等(idempotent、idempotence)是一个数学与计算机学概念,常见于抽象代数中。 

    在编程中.一个幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。幂等函数,或幂等方法,是指可以使用相同参数重复执行,并能获得相同结果的函数。这些函数不会影响系统状态,也不用担心重复执行会对系统造成改变。例如,“getUsername()和setTrue()”函数就是一个幂等函数. 

    更复杂的操作幂等保证是利用唯一交易号(流水号)实现. 

    我的理解:幂等就是一个操作,不论执行多少次,产生的效果和返回的结果都是一样的 

    一,正式开始了

    现在我们们要做一个点击按钮之后等待后台返回之后才可以再次请求方法,其他的重复请求直接进行拦截

    在这里我使用拦截器进行实现(也可以使用中间件来实现),主要就是以AOP(切面编程是面向对象的优化),将一些紧密的业务进行切开,在中间进行自己的一些逻辑处理

    主要的实现思路就是使用toekn+Redis缓存进行(当我们访问某个方法的时候给用户的客户端存取一个cookie)cookie里面主要是存的toekn,当我们访问接口的时候一定要带上有效的

    token才能访问方法或者控制器。

    客户端访问方法的时候存token到Redis里面,当请求方法的时候带上token,拦截器里面判断是不是存放在Redis里面的token如果不是的直接拦截返回,如果带上的是有效的token删除旧token

    生成一个新的token存放在cookie里面,存到Redis,给第二次请求发放token。

    代码理解:

    //视图页面
        public partial class HomeController : Controller
        {
            private readonly RedisHelp cache = new RedisHelp();
            /// <summary>
            /// 首页  获取token
            /// </summary>
            /// <returns></returns>
            [NoSign]
            public IActionResult Index()
            {
                string token = Guid.NewGuid().ToString();
                HttpContext.Response.Cookies.Append("token", token);
                cache.SetValue("token", token);
                return View();
            }
        }

    当浏览器访问这个视图的时候给他发放一个token。

    这里存在cooke的好处就是,下一次请求会直接带上上一次发放的Toekn,我们在前台就不需要去做任何操作了,这样拦截器才能算上是一个独立的模块。

    我们需要访问这个接口,保证同时点击的时候只能有一次

     /// <summary>
        /// 接口控制器
        /// </summary>
        public partial class HomeController : Controller
        {
            /// <summary>
            /// 接受提交请求
            /// </summary>
            /// <returns></returns>
            public JsonResult Submit()
            {
                ResponseJson responseJson = new ResponseJson();
                responseJson.msg = "更新了token";
                return Json(responseJson);
            }
        }

    下面就是拦截器的代码

        /// <summary>
        /// 适合全局的
        /// </summary>
        public class SignFilter : ActionFilterAttribute
        {
            private RedisHelp cache = new RedisHelp();
            /// <summary>
            /// 请求之前
            /// </summary>
            /// <param name="context"></param>
            public override void OnActionExecuting(ActionExecutingContext context)
            {
                // 判断是否检查登陆
                var noNeedCheck = false;
                if (context.ActionDescriptor is ControllerActionDescriptor controllerActionDescriptor)
                {
                    noNeedCheck = controllerActionDescriptor.MethodInfo.GetCustomAttributes(inherit: true)
                      .Any(a => a.GetType().Equals(typeof(NoSignAttribute)));
                }
                if (noNeedCheck)return;
    
                ResponseJson responseJson = new ResponseJson();
                var token = context.HttpContext.Request.Cookies["token"];
                #region 判断数据有效性
                if (string.IsNullOrWhiteSpace(token))
                {
                    responseJson.msg = "toekn不能空";
                    context.Result = new JsonResult(responseJson);
                    return;
                } else if (cache.GetValue("token") ==null) {
                    responseJson.msg = "toekn不能空";
                    context.Result = new JsonResult(responseJson);
                    return;
                } else if (!cache.DeleteKey("token")) {
                    responseJson.msg = "token已不存在";
                    context.Result = new JsonResult(responseJson);
                    return;
                }
                #endregion
                base.OnActionExecuting(context);
            }
    
            /// <summary>
            /// 请求过了之后,在去分发token
            /// </summary>
            /// <param name="context"></param>
            public override void OnActionExecuted(ActionExecutedContext context)
            {
                //随机值
                string redisToken = Guid.NewGuid().ToString() + new Random().Next(100000, 99999999);
                context.HttpContext.Response.Cookies.Append("token", redisToken);
                //初使化并设置Cookie的名称
                cache.SetValue("token", redisToken);
            }
        }
    
        /// <summary>
        /// 不需要登陆的地方加个特性
        /// </summary>
        public class NoSignAttribute : ActionFilterAttribute { }

     

    但是这个只适合于个人在点击的时候的,下次我分享一下多人的模式。

  • 相关阅读:
    数据加载存储和文件格式
    基本概率分布图的绘制
    pandas处理各类表格数据
    python时间处理
    matplotlib实现数据可视化
    sql学习笔记:表的运算
    sql杂记:一些坑和数据库恢复
    exists关键词和case表达式
    后台工具screen
    SQL函数小记
  • 原文地址:https://www.cnblogs.com/chenxi001/p/11668541.html
Copyright © 2011-2022 走看看