Redis发布消息通常有两种模式：

• 队列模式（queuing）
• 发布-订阅模式(publish-subscribe)

1、任务队列

顾名思义，就是“传递消息的队列”。与任务队列进行交互的实体有两类，一类是生产者（producer），另一类则是消费者（consumer）。生产者将需要处理的任务放入任务队列中，而消费者则不断地从任务独立中读入任务信息并执行。

1、任务队列的好处

1、松耦合

生产者和消费者只需按照约定的任务描述格式，进行编写代码。

2、易于扩展

多消费者模式下，消费者可以分布在多个不同的服务器中，由此降低单台服务器的负载。

3、Redis 发布订阅

其实从Pub/Sub的机制来看，它更像是一个广播系统，多个Subscriber可以订阅多个Channel，多个Publisher可以往多个Channel中发布消息。可以这么简单的理解：

• Subscriber：收音机，可以收到多个频道，并以队列方式显示
• Publisher：电台，可以往不同的FM频道中发消息
• Channel：不同频率的FM频道

1、发布订阅模型

1、一个Publisher，多个Subscriber模型

如下图所示，可以作为消息队列或者消息管道。

主要应用：通知、公告。

2、多个Publisher，一个Subscriber模型

可以将PubSub做成独立的HTTP接口，各应用程序作为Publisher向Channel中发送消息，Subscriber端收到消息后执行相应的业务逻辑，比如写数据库，显示等等。

主要应用：排行榜、投票、计数。

3、多个Publisher，多个Subscriber模型

故名思议，就是可以向不同的Channel中发送消息，由不同的Subscriber接收。

主要应用：群聊、聊天。

2、实践发布订阅

发布订阅实践命令

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

3、消息队列系统对比

客户端在执行订阅命令之后进入了订阅状态，只能接收 SUBSCRIBE 、PSUBSCRIBE、 UNSUBSCRIBE 、PUNSUBSCRIBE 四个命令。

开启的订阅客户端，无法收到该频道之前的消息，因为 Redis 不会对发布的消息进行持久化。

和很多专业的消息队列系统（例如Kafka、RocketMQ）相比，Redis的发布订阅略显粗糙，例如无法实现消息堆积和回溯。但胜在足够简单，如果当前场景可以容忍的这些缺点，也不失为一个不错的选择。

4、Redis 事务管理

• redis中的事务跟关系型数据库中的事务是一个相似的概念，但是有不同之处。

• 关系型数据库事务执行失败后面的sql语句不在执行，而redis中的一条命令执行失败，其余的命令照常执行。

• redis中开启一个事务是使用multi，相当于begin\start transaction，exec提交事务，discard取消队列命令（非回滚操作）。

1、Redis 于 MySQL 对比

2、 Redis 事务命令

1、事务执行举例

ZADD salary 2000 user1
ZADD salary 3000 user2
ZRANGE salary 0 -1 WITHSCORES
MULTI
ZINCRBY salary 1000 user1
ZINCRBY salary -1000 user2
EXEC

3、Redis 中事务中的锁机制

举例：我正在买票 Ticket -1 , money -100

而票只有1张, 如果在我 multi 之后,和 exec 之前, 票被别人买了，即 ticket 变成0了。

我该如何观察这种情景,并不再提交：

• 悲观的想法:
• 世界充满危险,肯定有人和我抢, 给 ticket上锁, 只有我能操作. [悲观锁]
• 乐观的想法:
• 没有那么人和我抢,因此,我只需要注意,有没有人更改 ticket 的值就可以了 [乐观锁]

Redis的事务中,启用的是乐观锁,只负责监测 key 没有被改动.

4、Redis服务管理命令

5、Redis 慢日志查询

• Slow log 是 Redis 用来记录查询执行时间的日志系统。

• slow log 保存在内存里面，读写速度非常快

可以通过改写 redis.conf 文件或者用 CONFIG GET 和 CONFIG SET 命令对它们动态地进行修改

slowlog-log-slower-than 10000 # 超过多少微秒
CONFIG SET slowlog-log-slower-than 100
CONFIG SET slowlog-max-len 1000 # 保存多少条慢日志
CONFIG GET slow*
SLOWLOG GET
SLOWLOG RESET