Redis消息队列

2020-03-20 分类:数据库相关 阅读(72) 评论(0)

生产消费模型

什么是消息队列

在生活中,其实有很多的例子,都类似消息队列。

比如:工厂生产出来的面包,交给超市,商场来出售,客户通过超市,商场来买面包,客户不会针对某一个工厂去选择,只管从超市买出来,工厂也不会管是哪一个客户买了面包,只管生产出来之后,交给超市,商场来处理。

消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,有消息系统来确保信息的可靠专递,消息生产者只管把消息发布到MQ中而不管谁来取,消息消费者只管从MQ中取消息而不管谁发布的,这样发布者和使用者都不用知道对方的存在。

为什么使用消息队列

首先,我们可以知道,消息队列是一种异步的工作机制,比如说日志收集系统,为了避免数据在传输过程中丢失,还有订单系统,下单后,会生成对应的单据,库存的扣减,消费信息的发送,一个下单,产生这么多的消息,都是通过一个操作的触发,然后将其他的消息放入消息队列中,依次产生。再就是很多网站的,秒杀活动之类的,前多少名用户会便宜,都是通过消息队列来实现的。

这些例子,都是通过消息队列,来实现,业务的解耦,最终数据的一致性,广播,错峰流控等等,从而完成业务的逻辑。

消息队列产品

1)rabbit-MQ(最初起源于金融系统,用于分布式系统中存储转发消息。OpenStack)
2)Zero-MQ(SaltStack)
3)Kafka(JAVA)
4)redis(key:value数据库,缓存,消息队列)

Redis发布消息的两种模式

任务队列模式(queuing)

任务队列:顾名思义,就是“传递消息的队列”。
与任务队列进行交互的实体有两类,
> 一类是生产(producer)
> 一类则是消费者(consumer)

生产者将需要处理的任务放入任务队列中,而消费者则不断地从任务独立中读入任务信息并执行。
任务队列的好处
> 1)松耦合。
生产者和消费者只需按照约定的任务描述格式,进行编写代码。
2)易于扩展。
多消费者模式下,消费者可以分布在多个不同的服务器中,由此降低单台服务器的负载。

发布-订阅模式(publish-subscribe)

其实从Pub/Sub的机制来看,它更像是一个广播系统,多个订阅者(Subscriber)可以订阅多个频道(Channel),多个发布者(Publisher)可以往多个频道(Channel)中发布消息。
> 可以理解为:
1)Subscriber:收音机,可以收到多个频道,并以队列方式显示
2)Publisher:电台,可以往不同的FM频道中发消息
3)Channel:不同频率的FM频道

Redis发布订阅实践

1)PUBLISH channel msg
将信息 message 发送到指定的频道 channel

2)SUBSCRIBE channel [channel ...]
订阅频道,可以同时订阅多个频道

3)UNSUBSCRIBE [channel ...]
取消订阅指定的频道, 如果不指定频道,则会取消订阅所有频道

4)PSUBSCRIBE pattern [pattern ...]
订阅一个或多个符合给定模式的频道,每个模式以 * 作为匹配符,比如 it* 匹配所  有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等), news.* 匹配所有  以 news. 开头的频道( news.it 、 news.global.today 等等),诸如此类

5)PUNSUBSCRIBE [pattern [pattern ...]]
退订指定的规则, 如果没有参数则会退订所有规则

6)PUBSUB subcommand [argument [argument ...]]
查看订阅与发布系统状态

注意:使用发布订阅模式实现的消息队列,当有客户端订阅channel后只能收到后续发布到该频道的消息,之前发送的不会缓存,必须Provider和Consumer同时在线。

订阅单个频道

#第一个窗口
#登录Redis
[root@db01 ~]# redis-cli -a 123
#在订阅者的服务器上输入订阅nfsnobody
127.0.0.1:6379> SUBSCRIBE nfsnobody
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "nfsnobody"
3) (integer) 1

#第二个窗口
#登录Redis
[root@db01 ~]# redis-cli -a 123
#在发布者的服务器上输入信息
127.0.0.1:6379> PUBLISH nfsnobody "The Nice Boy Like Me."
(integer) 1

#第一个窗口
#在订阅者的服务器上会看到如下信息
1) "message"
2) "nfsnobody"
3) "The Nice Boy Like Me."

订阅多个频道

#第一个窗口
#登录Redis
[root@db01 ~]# redis-cli -a 123
#在订阅者服务器上输入订阅所有频道
127.0.0.1:6379> PSUBSCRIBE *
Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "*"
3) (integer) 1

#第二个窗口
#在发布者服务器上输入多频道信息
127.0.0.1:6379> PUBLISH nfsnobody "The Nice Boy Like Me."
(integer) 1
127.0.0.1:6379> PUBLISH nfs "The Ugly Old Man Like Me."
(integer) 1

#第一个窗口
#在订阅者的服务器上会看到如下信息
1) "pmessage"
2) "*"
3) "nfsnobody"
4) "The Nice Boy Like Me."

1) "pmessage"
2) "*"
3) "nfs"
4) "The Ugly Old Man Like Me."

消息队列系统对比

客户端在执行订阅命令之后进入了订阅状态
只能接收 SUBSCRIBE 、PSUBSCRIBE、 UNSUBSCRIBE 、PUNSUBSCRIBE 四个命令。
开启的订阅客户端,无法收到该频道之前的消息,因为 Redis 不会对发布的消息进行持久化。
和很多专业的消息队列系统(例如Kafka、RocketMQ、RabbitMQ)相比,Redis的发布订阅略显粗糙。

例如:无法实现消息堆积和回溯。但胜在足够简单,如果当前场景可以容忍的这些缺点,也不失为一个不错的选择。

标签:

您可能也喜欢:

Redis主从复制及高可用

Redis主从复制 Redis复制功能介绍 1)使用异步复制。 2)一个主服务器可以有多个从服务器。 3)从服务器也可以有自己的从服务器。 4)复制功能不会阻塞主服务器。 5)可以通过复制功能来让主服务器免于执行持久化操作,由从服务器去执行持久化操作即可。 Redis复制功能介绍(重点了解) 1...

more

Redis事务、锁、管理命令

事务介绍 Redis的事务与关系型数据库中的事务区别 1)在MySQL中讲过的事务,具有A、C、I、D四个特性 Atomic(原子性) > 所有语句作为一个单元全部成功执行或全部取消。 Consistent(一致性) > 如果数据库在事务开始时处于一致状态,则在执行该。
事务期间将保...

more

Redis管理实战

数据类型 String: 字符串类型 Hash: 哈希类型 List: 列表类型 Set: 集合类型 Sorted set: 顺序集合类型 管理实战 通用操作 #查看所有的key 127.0.0.1:6...

more

欢迎新朋友你的到来!
还没有人抢沙发呢~
昵称
邮箱
网站

切换注册

登录

忘记密码 ?

切换登录

注册