欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

如何使用redis实现分布式锁 博客分类: spring MVC分布式锁 分布式锁redis 

程序员文章站 2024-02-24 18:54:58
...

如何使用redis实现分布式锁

为什么要使用分布式锁?场景?

涉及到重复提交或交易的地方

场景一:提交订单

如何使用redis实现分布式锁
            
    
    博客分类: spring MVC分布式锁 分布式锁redis 

用户购买商品,下单时,有时不小心连续点击多次;
或者网络不好,导致用户以为没有提交,重复点击提交按钮;
网络层面比如nginx的重发.

对于分布式系统,提交订单的n个请求可能会被不同的服务单体消费,
那么就会生成多个相同(除了订单号,其他购买信息完全一样)的订单,

后果:

  1. 产生了脏数据,影响了校验,有时甚至会影响正常业务的执行;
  2. 前端用户会发现产生了多个订单,让用户迷茫,不知所措.

场景二:

有哪些解决方法呢?

使用其他方式实现分布式锁

参考: 分布式系统后台如何防止重复提交

使用redis

流程如下:
如何使用redis实现分布式锁
            
    
    博客分类: spring MVC分布式锁 分布式锁redis 
如何使用redis实现分布式锁
            
    
    博客分类: spring MVC分布式锁 分布式锁redis 
代码如下:

/***
     * 提交订单
     * @param model
     * @param request
     * @param response
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "/order/submit/json", produces = SystemHWUtil.RESPONSE_CONTENTTYPE_JSON_UTF)
    public String jsonSubmitOrder2(Model model, HttpServletRequest request, HttpServletResponse response
            , @RequestParam(required = false) Boolean del) {
        //可以抽取出常量
        String lockUniquePrefix = "lock";

        Jedis jedis = getJedis();
        //1. 获取锁
        // key:"lock"+方法名,value:时间戳
        //NX -- Only set the key if it does not already exist.
        String key = lockUniquePrefix + Thread.currentThread().getStackTrace()[1].getMethodName();
        //"OK":成功;null:失败
        String result = jedis.set(key, "aa", "NX", "EX"/*seconds*/, 1000);
        Const.pool.returnResource(jedis);
        boolean success = "OK".equals(result);
        System.out.println("success :" + success);
        System.out.println("result :" + result);

        if (success) {
            //2. 执行具体业务逻辑
            //...
        }


        //3. 业务逻辑执行完成之后,释放锁
        
        jedis = getJedis();
        jedis.del(key);
        Const.pool.returnResource(jedis);
        

        return BaseResponseDto.put2("result", result).put("success", success).toJson();
    }

 


如何使用redis实现分布式锁
            
    
    博客分类: spring MVC分布式锁 分布式锁redis  为什么jedis.set方法中要使用"NX"呢? 因为只有当key不存在时,操作才会成功, 即key不存在时,jedis.set返回"OK",表示获取锁成功; key存在时,jedis.set返回null,表示获取锁失败

为什么要使用redis

因为关于锁有两个重要的操作:

  1. 获取锁;
  2. 释放锁.

在分布式环境,必须保证这两个操作是原子性的,
即不能把获取锁分为两步:先查询,再add.
同时,获取锁时,能够设置有效期.

分布式锁实现时要注意的问题

  1. 提供锁的服务必须是一个唯一的服务,即负载均衡的n个服务单体访问的是同一个服务;
  2. 能够设置锁的有效期,不能让某个消费者永久地持有锁;
  3. 能够释放锁;
  4. 不同的业务逻辑竞争不同的锁,必须下单和减库存 使用不同的锁.

redis 还能做什么

redis除了可以实现分布式锁,还能作为缓存服务器,
在实现需求中,我经常把一些容易变化的配置放在redis中, 这样当产品经理需求变更时,我只需修改redis,即时生效,不用上线

参考:

https://my.oschina.net/huangweiindex/blog/1853160

相关标签: 分布式锁 redis