文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

使用Redis解决高并发方案及思路解读

2023-03-31 09:49

关注

NoSQL

Not Only SQL的简称。NoSQL是解决传统的RDBMS在应对某些问题时比较乏力而提出的。

即非关系型数据库,它们不保证关系数据的ACID特性,数据之间一般没有关联,在扩展上就非常容易实现,并且拥有较高的性能。

Redis

redis是nosql的典型代表,也是目前互联网公司的必用技术。

redis是键值(Key-Value)存储数据库,主要会使用到哈希表。大多数时候是直接以缓存的形式被使用,使得请求不直接访问到磁盘,所以效率方面是很不错的,完全能满足中小型企业的使用需求。

常用数据类型

使用频率上string和hash会高一些,各个类型有各自的操作命令,无非增删改查,具体的命令后面我会整理一份。

痛点

web应用在众多请求同时发生时,可能会导致数据读取、存储上出现错误,即发生脏读、脏数据生成。

在分布式项目下,会出现更多的问题。

思路

并发时,本质其实就是多个请求同时进来了,没办法正确的去进行处理。

可以将所有的请求放在 一个队列,让请求们按照一个顺序,挨个进来执行业务逻辑。目前成熟的解决方案就是使用消息队列,下次我会整理一篇消息队列处理高并发的;

还有一个方法是直接将并行转为串行,Java提供了synchronized,即同步,不过这个在效率要求比较苛刻的地方 或者 分布式项目下还是不太合适的方案,这里就引出了使用redis来实现分布式锁,从而解决并发问题。

分布式锁

在分布式项目中,使用一个唯一、通用、效率高的标识,来表示上锁和解锁。

redis实现起来很简单,即对一个key是否存在来表示是否上锁、是否解锁。

以string类型举例:

Integer stock = goodsMapper.getStock();
if (stock > 0) {
  stock =- 1;
  goodsMapper.updateStock(stock);
}

以上是最简单的秒杀伪代码,我们尝试用redis实现分布式锁。

// 这里是错误代码,只是一个思考过程,请耐心看完哦
String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
String value = jedisUtils.get(key);
if (value != null) { // 未上锁
  // wingzingliu
  jedisUtils.set(key, 1); // 上锁
  Integer stock = goodsMapper.getStock();
  if (stock > 0) {
    stock =- 1;
    goodsMapper.updateStock(stock);
    jedisUtils.del(key); // 释放锁
  }
}

以上代码可能会出现一个问题,就是当同时多个请求进来,某次多个请求都拿到value为空,线程A进入if 走到// wingzingliu这里的时候,还未上锁,其他请求也进来了,这样就会出现脏数据了。

这里的代码问题就是出在没有考虑原子性问题。

所以我们要使用到redis的一个setNx命令,本质也是设置值,但是这是一个原子操作,执行之后会返回是否设置成功。

redis> SETNX job "programmer"  # job 设置成功
(integer) 1

redis> SETNX job "code-farmer"  # 尝试覆盖 job ,失败
(integer) 0

redis> GET job          # 没有被覆盖
"programmer"

重点关注 当有值时,会失败,返回0。所以我们的代码会改造成以下这个样子。

// 这里是错误代码,只是一个思考过程,请耐心看完哦
String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
Long result = jedisUtils.setNx(key, 1);
if (result > 0) { // 上锁成功,进入逻辑
  // wingzingliu1
  Integer stock = goodsMapper.getStock();
  if (stock > 0) {
    stock =- 1;
    goodsMapper.updateStock(stock);

    System.out.println("购买成功!");
  } else {
    System.out.println("没有库存了!");
  }
  // wingzingliu2
  jedisUtils.del(key); // 释放锁
}

以上我们就可以保证原子性,能正确的按照顺序去处理。

可是还有一个隐藏的问题,就是当某个线程执行上锁成功后,在wingzingliu1到wingzingliu2之间时,程序抛异常了,那么程序终止了,就无法释放锁,其他线程也都进不来了。

解决方案是加上try catch finally块,在finally里面去释放锁。

可是那如果是宕机呢?上锁之后宕机了,finally里面的依然不会执行,锁没有得到释放,不手动处理的情况下,以后所有线程也无法进入。

所以引入了redis的过期时间,到了某个时间自动解锁。

// 这里是不够完善的代码,请耐心看完哦
try {
  String key = "REDIS_DISTRIBUTION_LOCKER"; // 分布式锁名称
  Long result = jedisUtils.setNx(key, 1, 30); // 假设处理逻辑需要20s左右,设置了30秒自动过期
  if (result > 0) { // 上锁成功,进入逻辑
    Integer stock = goodsMapper.getStock();
    if (stock > 0) {
      stock =- 1;
      goodsMapper.updateStock(stock);

      System.out.println("购买成功!");
    } else {
      System.out.println("没有库存了!");
    }
  }
} catch (Exception e) {
 
} finally {
  jedisUtils.del(key); // 释放锁
}

以上是比较完善的分布式锁了,但是还有一个小瑕疵,就是假设某一次请求A处理的很慢,预计20s但是跑了35s,到了30s的时候锁过期了,其他请求就自然进来了。

这不仅仅会导致一次并行,当请求A处理完时,依然会执行释放锁,这实际上是下一个线程上的锁。以此类推,整个并发控制就乱了。

理论上可以设置一个更大的key过期时间,但是并不是最好的解决方案。这里就引出一个概念:锁续命。

锁续命

如其名,给锁续命。实现就是 当锁快过期的时候,去延长锁的时间。假设一个30s的锁,每个10s去检测一下,锁是否还在 如果在就重新延长至30s。这样就避免掉了上面的这个可能出现的问题。

这里使用一个定时任务,周期性的调用即可。

扩展

刚刚对key设置的value是1,其实能使用请求ID来进行保存,这样就能知道锁是由哪个请求上的,在解锁的时候 也可以避免解锁了其他线程上的锁。具体由前端传递,或者由服务端以某种规则生成都可以。

结语

至此我们就使用redis,一步一步的解决了在分布式项目下的并发问题。redis不是唯一的解决方案,但是对于大部分互联网公司来说,是一个很成熟、性能不错、便捷的方案。

还可以使用synchronized(非分布式项目)、mq 、zookeeper等方案去实现分布式锁 以 解决高并发问题。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持我们。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     801人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     348人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     311人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     432人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     220人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-数据库
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯