最近博主在看 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 命令
, 可以直接包括了 setNx 和 expire 的作用。
- set(lock, expire,"NX", expireTime,"EX")
消息队列主要应用在网络服务中异步任务的实现,redis 可以充当消息队列实现生产者 / 消费者模型和订阅 / 发布模型。
生产者 / 消费者模型需要存在生产者和消费者两方,而在 redis 中队列的存储和获取可以作为消息队列被生产者和消费者使用,这里就不用 Java 代码写了,使用 redis 命令来说明。
其实 redis 在其中做的还是缓存的作用,
,将 task 放到 queue 队列里面,这里稍微偏题一句,其实 redis 有 lpush 和 rpush,意思就是从左边插入队列和从右边插入队列。这就是生产者的部分,将任务插入到指定队列中。
- LPUSH queue task
,当然这里的 BRPOP 也有对应的 BLPOP,由于队列是按顺序取任务的,所以这边做的是左边插入,右边取出。这里需要注意的是,redis 有 BRPOP 和 RPOP,之所以用 BRPOP 的原因是这个有一个等待,就是命令中的 10,这是一个等待时间,以秒为单位,意思是如果队列中是空的,那么我先不返回,我等待 10 秒,如果期间有新的任务插入,那么我就取新的任务返回,还是没有的话,返回空。 另外 BRPOP 还支持优先级,就是
- BRPOP queue 10
,这个意思是顺序获取,如果 queue:1 没有取到任务,到 queue:2 去取,依次往后。
- BRPOP queue:1 queue:2 queue:3 10
订阅 / 发布模型简单来说就是由发布者向所有订阅者发送任务,任何订阅者都可以获取任务,这里 redis 的实现就是使用订阅命令。
发布者可以使用
来发布相关的任务,而订阅者则是使用
- publish channel task
,这是一个监听命令,redis 会一直监听这个 channel,如果发布者发布新的任务,监听命令会返回任务,直到订阅者主动退出监听。但是 redis 也为这个设置超时,保证监听的有效性,默认如果 60s 内没收到消息就异常退出,当然这个可配置。
- subscribe channel
来源: http://www.cnblogs.com/xudilei/p/7225495.html