Redis学习:消息通知

一.任务队列

1.什么是任务队列?
我们可以从字面意思去理解:传递任务的队列。与任务队列进行交互的实体有两种,一种是生产者,负责向队列中添加任务,一类是消费者,负责从队列中提取任务并执行。

2.使用任务队列的好处
1)松耦合:生产者消费者无需知道彼此的实现细节,只需要约定好任务的描述格式就行了。
2)易于扩展:我们可以扩展出多个消费者分布在不同的服务器中,从而可以降低单台服务器的性能压力,如图:
Redis学习:消息通知
3.Redis中实现任务队列

1)BRPOP命令
BRPOP命令接收两个参数,第一个是键名,第二个是超时时间(单位s),当超过了此时间仍然没有获得新元素就会返回nil。 如果设置超时时间为0,则表示不限时等待(如果没有新元素加入永久等待)

使用实例:
首先我们在一个命令窗口A中设置任务对列:
Redis学习:消息通知
然后在另一个窗口B向queue中添加元素:
Redis学习:消息通知
这时我们看到窗口A中出现下面消息:
Redis学习:消息通知
上面就是任务队列的实例演示过程,除了BRPOP(从右边取元素)之外,Redis还提供了BLPOP,顾名思义,就是从左边取元素。

4.优先级队列
BRPOP命令可以同时接收多个键,如果所有键都没有元素则阻塞,如果其中一个键有元素则会从该键中弹出元素,如果多个键都有元素,则按照从左到右的顺序取第一个键中的一个元素。我们可以利用这个特性设置优先级任务。

5.发布/订阅 模式
除了实现任务队列之外,Redis还提供了一组命令可以让开发者实现 发布/订阅 模式。
这个模式有两种角色:发布者和订阅者,发布者每次发布消息后都会通知订阅者。

1)PUBLISH命令和SUBSCRIBE命令
首先我们在一个命令窗口订阅一个频道:
Redis学习:消息通知
然后再另一个窗口发布该频道的一个消息:
Redis学习:消息通知
我们可以看到:
Redis学习:消息通知
按照规则订阅:
PSUBSCRIBE命令
它可以定义订阅的规则,既可以一次订阅多个符合匹配表达式的频道:
Redis学习:消息通知
它可以匹配channel.1和channel.10等等。

退定命令:
UNSUBSCRIBE命令
Redis学习:消息通知

PUNSUBSCRIBE命令
Redis学习:消息通知