redis分布式锁(生产环境可用,支持多种高并发)

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了redis分布式锁(生产环境可用,支持多种高并发)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4039字，纯文字阅读大概需要6分钟。

内容图文

package com.redis.lock;

import com.google.common.hash.BloomFilter;
import com.google.common.hash.Funnels;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.PostConstruct;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.Set;
import java.util.UUID;
import java.util.concurrent.TimeUnit;

/**
 * 不同的jvm或者夸jvm,实质上是指夸的是不同的物理机ip,那么redis为什么能在不同的jvm,不同的物理机上运行,并且对不同的物理机
 * 都是可见的,其实质就是redis的共享性,将竞争资源放在redis上,解决并发问题
 * <p>
 * 2.分布式锁的三种问题:
 * 1.系统抛异常   try---finally--
 * 2.系统宕机     锁失效时间,自动失效时间
 * 3.锁互换      超时时间<业务执行时间,导致锁互换,被其他的线程释放掉,通过加值判断
 * 4.锁续命
 * 5.如果redis的内存满了,则采用淘汰策略,默认使用的是IRU
 */
@RestController
public class InndexController {

    private static final Logger logger = LoggerFactory.getLogger(InndexController.class);

    //解决redis缓存穿透的问题-布隆过滤器
    BloomFilter<String> bloomFilter = BloomFilter.create(Funnels.stringFunnel(Charset.forName("utf-8")), 1000, 0.01);
    //
//    @Autowired
//    private Redisson redisson;
    @Autowired
    private StringRedisTemplate redisTemplate;

    /**
     * sysnchronized关键字怎么知道是同一个对象获取的锁?
     * 原子操作没法执行,最完美的就是原子操作;
     * redisson用了大量的原子操作,
     * 主存锁失效的解决方案: 1.zookeeper 强一致性
     * 2.redLock
     * 代码的线性执行...锁的原理;
     * 高并发分布式锁的实现:
     * 抢购同一个商品.
     * 分段锁:
     * 抢购不同的商品,可以加机器,redis-cluster的集群;
     *
     * @return
     */
    @PostConstruct
    public void init() {
        Set<String> keys = redisTemplate.keys("*");  //获取所有的key
        HashMap<String, Object> map = new HashMap<>();
        for (String onlKey : keys) {
            String s = redisTemplate.opsForValue().get(onlKey);
            map.put(onlKey, s);
        }
        //将所有的key放入到bloom过滤器中
        for (String key : keys) {
            bloomFilter.put("product_0001");
        }
    }

    @GetMapping("/deduct_stock")
    public String deductStock() {
        String lockKey = "product_0001";
        String clientID = UUID.randomUUID().toString();
//        RLock redissonLock = redisson.getLock(lockKey);
        try {
            boolean contain = bloomFilter.mightContain(lockKey);
            if (!contain) {
                return "";
            }
            //获取锁
//            Boolean result = redisTemplate.opsForValue().setIfAbsent(lockKey, "zhuge"); //1
//            如果在1和2之间出问题呢?用下面的综合解决
            Boolean result = redisTemplate.opsForValue().setIfAbsent(lockKey, clientID, 10, TimeUnit.SECONDS);
//            2.系统宕机,加超时时间
//            redisTemplate.expire(lockKey, 10, TimeUnit.SECONDS);//2
//              3.锁互换问题-->锁失效的时间<系统业务执行的时间,发生锁互换的问题;
            if (!result) {   //如果返回false,那么redis中已经存在这个key
                return "error";
            }
            //缓存穿透的判断.
            //逻辑理解清楚,剩下的就是代码编写的顺序问题,也就是让程序不要运行的太深然后出现问题,让问题提前出现
            //判断key是否存在,如果不存在则直接返回
            //加锁实现锁续命功能
//            redissonLock.lock();
            //jdk的各种锁都是基于jvm存在的,如果是夸jvm或者分布式微服务架构,那么用redis的共享特性,夸jvm存在的共享资源
            String stock = redisTemplate.opsForValue().get("stock");//key是业务的唯一标示
            int parseInt = Integer.parseInt(stock);
            if (parseInt > 0) {
                int realStock = parseInt - 1;
                redisTemplate.opsForValue().set("stock", realStock + ""); //值是业务的值;\
                System.out.println("剩余的库存值为: " + realStock);
            } else {
                System.out.println("扣减失败,库存不足");
            }
        } finally {
//            redissonLock.unlock();
            String s = redisTemplate.opsForValue().get(lockKey);
            System.out.println("当前key对应的值为: " + s);
            if (clientID.equals(s)) {
                System.out.println("删除锁成功");
                redisTemplate.delete(lockKey);
            } else {
                System.out.println("删除锁失败");
            }
        }
        //假如中间的代码出问题了,抛异常了,那么锁释放不了,怎么办?try...finally,要不然就死锁了
        /**
         * 1.抛异常,导致死锁,用try..finally..去解决
         *
         */
        //释放锁

        return "end";
    }
}

• 点赞
• 收藏
• 分享
• • 文章举报

内容总结

以上是互联网集市为您收集整理的redis分布式锁(生产环境可用,支持多种高并发)全部内容，希望文章能够帮你解决redis分布式锁(生产环境可用,支持多种高并发)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端