深入理解redis分布式锁和消息队列

 更新时间:2017年07月24日 10:22:31   作者:叶下梧桐  
本篇文章主要介绍了深入理解redis分布式锁和消息队列,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

最近博主在看redis的时候发现了两种redis使用方式,与之前redis作为缓存不同,利用的是redis可设置key的有效时间和redis的BRPOP命令。

分布式锁

由于目前一些编程语言,如PHP等,不能在内存中使用锁,或者如Java这样的,需要一下更为简单的锁校验的时候,redis分布式锁的使用就足够满足了。

redis的分布式锁其实就是基于setnx方法和redis对key可设置有效时间的功能来实现的。基本用法比较简单。

public boolean tryLock(String lock,long expireTime){
  String expire = String.valueOf(System.currentTimeMillis() + expireTime + 1);
  Long result = jedis.setNx(lock,expire);
  if(result == 1L){
    jedis.expire(lock, expireTime);
    return true;
  }
  //判断超时key可能未删掉
  String currentValue = jedis.get(lock);
  if(Long.parseLong(currentValue) < System.currentTimeMillis()){
    jedis.set(lock, expire);
    jedis.expire(lock, expireTime);
    return true;
  }
  return false;
}
//expire是key的值,这里是为了防止运行超时锁被其他线程拿走之后误删锁
public unlock(String lock,String expire){
  String value = jedis.get(lock);
  if(value != null && value != expire && Long.parseLong(value) > System.currentTimeMillis())
    jedis.del(lock);
}  

这里就是我根据redis的机制写的加锁和解锁方法。现在redis不推荐使用setNx了,而是直接使用set命令set(lock, expire,"NX", expireTime,"EX"),可以直接包括了setNx和expire的作用。

消息队列

消息队列主要应用在网络服务中异步任务的实现,redis可以充当消息队列实现生产者/消费者模型和订阅/发布模型。

生产者/消费者模型

生产者/消费者模型需要存在生产者和消费者两方,而在redis中队列的存储和获取可以作为消息队列被生产者和消费者使用,这里就不用Java代码写了,使用redis命令来说明。

 其实redis在其中做的还是缓存的作用,LPUSH queue task,将task放到queue队列里面,这里稍微偏题一句,其实redis有lpush和rpush,意思就是从左边插入队列和从右边插入队列。这就是生产者的部分,将任务插入到指定队列中。

 消费者的部分有点相似,就是使用BRPOP queue 10,当然这里的BRPOP也有对应的BLPOP,由于队列是按顺序取任务的,所以这边做的是左边插入,右边取出。这里需要注意的是,redis有BRPOP和RPOP,之所以用BRPOP的原因是这个有一个等待,就是命令中的10,这是一个等待时间,以秒为单位,意思是如果队列中是空的,那么我先不返回,我等待10秒,如果期间有新的任务插入,那么我就取新的任务返回,还是没有的话,返回空。

 另外BRPOP还支持优先级,就是BRPOP queue:1 queue:2 queue:3 10,这个意思是顺序获取,如果queue:1没有取到任务,到queue:2去取,依次往后。

订阅/发布模型

订阅/发布模型简单来说就是由发布者向所有订阅者发送任务,任何订阅者都可以获取任务,这里redis的实现就是使用订阅命令。

 发布者可以使用publish channel task来发布相关的任务,而订阅者则是使用subscribe channel,这是一个监听命令,redis会一直监听这个channel,如果发布者发布新的任务,监听命令会返回任务,直到订阅者主动退出监听。但是redis也为这个设置超时,保证监听的有效性,默认如果60s内没收到消息就异常退出,当然这个可配置。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Redis教程(十四):内存优化介绍

    Redis教程(十四):内存优化介绍

    这篇文章主要介绍了Redis教程(十四):内存优化介绍,本文讲解了特殊编码、BIT和Byte级别的操作、尽可能使用Hash等内容,需要的朋友可以参考下
    2015-05-05
  • Redis的共享session应用实现短信登录

    Redis的共享session应用实现短信登录

    本文主要介绍了Redis的共享session应用实现短信登录,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-08-08
  • 高并发场景分析之redis+lua防重校验

    高并发场景分析之redis+lua防重校验

    这篇文章主要介绍了高并发场景分析之redis+lua防重校验,本文通过示例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-07-07
  • Redis缓冲区溢出及解决方案分享

    Redis缓冲区溢出及解决方案分享

    Redis缓冲区溢出是指Redis缓冲区被写入的数据超过了它的容量,导致数据无法存储或被覆盖。造成缓冲区溢出的原因可能是快速写入大量数据、缓冲区未及时刷新或Redis服务器配置不当等。
    2023-04-04
  • Redis高并发问题的解决方法

    Redis高并发问题的解决方法

    这篇文章主要介绍了Redis高并发问题的解决办法,具有很好的参考价值,感兴趣的小伙伴们可以参考一下,具体如下:
    2018-05-05
  • Redis中Scan命令的基本使用教程

    Redis中Scan命令的基本使用教程

    这篇文章主要给大家介绍了关于Redis中Scan命令的基本使用教程,文中通过示例代码介绍的非常详细,对大家学习或者使用Redis具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-06-06
  • 详解Centos7下配置Redis并开机自启动

    详解Centos7下配置Redis并开机自启动

    本篇文章主要介绍了Centos7下配置Redis并开机自启动,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
    2016-11-11
  • Redis解决跨域存取Session问题

    Redis解决跨域存取Session问题

    本文主要介绍了Redis解决跨域存取Session问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2023-04-04
  • Redis教程之代理ip池设计方法详解

    Redis教程之代理ip池设计方法详解

    这篇文章主要介绍了Redis实现代理ip池的设计方法,文中给出了详细的介绍与示例代码,相信对大家的理解和学习具有一定的参考借鉴价值,有需要的朋友们下面来一起看看吧。
    2017-01-01
  • Redis如何优雅的删除特定前缀key

    Redis如何优雅的删除特定前缀key

    这篇文章主要给大家介绍了关于Redis如何优雅的删除特定前缀key的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Redis具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-06-06

最新评论