【02】Redis for OPS:消息订阅和事务管理

写在前面的话

上一节谈了 Redis 的安装以及五种基本数据类型的一些简单的操作,本章节主要看看 Redis 的另外一些特征,虽然可能不常用,但是还是需要了解的。对于我们运维人员来讲,这些东西更像拓展的知识,可能我们工作很多年都不会用到,但是当你慢慢的需要往运维开发方向发展以后,这些东西就会成为你解决问题的又一方案。另外一种思路。

发布订阅

Redis 发布消息一般有两种方式,消息队列和发布订阅。

对于消息队列,其角色包含:生产者 --> 消息队列 --> 消费者

生产者讲需要处理的任务放到队列中,消费者再不断的从队列中读取任务然后执行。其好处在于解耦合,易于横向扩展。

对于发布订阅,我们可以看成广播FM,我们只有在一个频道,就能收听到广播,调到这个频道的过程就是订阅。

和广播的原理类似,订阅者需要先将频道打开到指定频道,然后另外一个窗口开始发布消息:

SUBSCRIBE fm110

结果如图:

此时另外一个窗口开始往 fm110 的频道发布消息:

PUBLISH fm110 "hello"

结果如图:

此时查看订阅者窗口:

这就有点像QQ群聊天,只允许群主发言,其它可以多个人接收。

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

# 订阅一个或多个符合给定模式的频道,以 * 作匹配符,如 it* 匹配以 it 开头的频道(it.news 、 it.blog等等)
PSUBSCRIBE pattern [pattern ...]

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

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

当然,Redis 的消息队列发布订阅其实是很粗糙的,如果真需要这样的内容,可以选择 RabbitMQ,Kafka 等。

事务处理

在 MySQL 中知道开启一个事务后,如果不 commit 的话是不会将修改刷写到磁盘的,在 Redis 中也存在这样的操作。

在 MySQL 中使用 start transaction 或者 begin 开启一个事务,在 Redis 则使用 multi。

在 MySQL 中取消回滚可以使用 rollback,Redis 则使用 discard 取消,不叫回滚,运维 Redis 并未执行。

在 MySQL 中提交采用 commit,在 Redis 中则使用 exec。

在 Redis 中采用的是乐观锁,可以通过模拟网上买票来测试:

在窗口1执行:

127.0.0.1:6379> set ticket 1
OK
127.0.0.1:6379> watch ticket
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set ticket 0
QUEUED

暂时不执行它,然后取窗口2执行:

127.0.0.1:6379> get ticket
"1"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set ticket 0
QUEUED
127.0.0.1:6379> exec
1) OK

此时再去窗口1执行:

127.0.0.1:6379> exec
(nil)

发现票以及被别人买走了!其中 watch 的作用在于监视一个(或多个) key ,如果在事务执行之前这个(或这些) key 被其他命令所改动,那么事务将被打断。

其它全局操作

常用的命令如下:

# 显示连接的客户端
CLIENT LIST

# 杀掉客户端
CLIENT KILL id 10

# 获取所有系统配置
CONFIG GET *

# 获取匹配的配置
CONFIG GET log*

# 在线修改配置
CONFIG SET requirepass helloworld

# 登录
AUTH helloworld

# 将修改的配置写入 redis.conf
CONFIG REWRITE

# 显示当前库中key数量
DBSIZE

# 打印redis收到的命令
MONITOR

# 删除当前库所有key
FLUSHDB

# 删除所有库的key
FLUSHALL

# 当前时间
TIME

# 手动持久化
SAVE

# 异步执行一个 AOF(AppendOnly File) 文件重写操作
BGREWRITEAOF

# 在后台异步保存当前数据库的数据到磁盘
BGSAVE

结果如下:

127.0.0.1:6379> CLIENT LIST
id=5 addr=127.0.0.1:48567 fd=8 name= age=15091 idle=0 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=32768 obl=0 oll=0 omem=0 events=r cmd=client
id=8 addr=127.0.0.1:48573 fd=9 name= age=660 idle=600 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=0 obl=0 oll=0 omem=0 events=r cmd=exec
id=10 addr=127.0.0.1:48577 fd=10 name= age=14 idle=14 flags=N db=0 sub=0 psub=0 multi=-1 qbuf=0 qbuf-free=0 obl=0 oll=0 omem=0 events=r cmd=keys
127.0.0.1:6379> CLIENT KILL id 10
(integer) 1
127.0.0.1:6379> CONFIG GET log*
1) "logfile"
2) "/data/services/redis/logs/redis-6379.log"
3) "loglevel"
4) "notice"
127.0.0.1:6379> CONFIG SET requirepass helloworld
OK
127.0.0.1:6379> keys *
(error) NOAUTH Authentication required.
127.0.0.1:6379> AUTH helloworld
OK
127.0.0.1:6379> CONFIG GET requirepass
1) "requirepass"
2) "helloworld"
127.0.0.1:6379> CONFIG REWRITE
OK
127.0.0.1:6379> DBSIZE
(integer) 1
127.0.0.1:6379> FLUSHDB
OK
127.0.0.1:6379> FLUSHALL
OK
127.0.0.1:6379> TIME
1) "1573022355"
2) "256540"
127.0.0.1:6379> MONITOR
OK
1573022218.974627 [0 127.0.0.1:48573] "AUTH" "helloworld"
1573022226.451991 [0 127.0.0.1:48573] "keys" "*"
1573022268.293698 [0 127.0.0.1:48573] "FLUSHDB"
1573022292.090727 [0 127.0.0.1:48573] "FLUSHALL"
1573022355.256531 [0 127.0.0.1:48573] "TIME"

到此,简单的命令我们就学的差不多的,真正会用的其实没几个,接下来的内容才是我们运维更加在意的东西!那就是调优和架构方面的设计。

原文地址:https://www.cnblogs.com/Dy1an/p/11805098.html

时间: 2024-09-30 09:28:46

【02】Redis for OPS:消息订阅和事务管理的相关文章

redis事务和消息订阅与发布

开始事务:multi开启 exec结束 mutil后面的语句有两种情况 1.语法错误,exec的时候报错,所有的不能执行 2,语法本身没有错,但适用的对象有问题,会执行正确的语句,跳过不适的语句 3.discard 取消事务(在队列里面的都不执行) 4,watch key1 key2 key3 监控key,如果发生变化就不执行事务,控制数据的统一性 5,unwatch 取消监视 消息订阅与发布 publish key value  发布消息 subscribe key  订阅频道(只要订阅了频道

Redis的消息订阅及发布及事务机制

Redis的消息订阅及发布及事务机制 订阅发布 SUBSCRIBE PUBLISH 订阅消息队列及发布消息. # 首先要打开redis-cli shell窗口 一个用于消息发布 一个用于消息订阅 # SUBSCRIBE 订阅一个频道,如果频道不存在 就新增一个 # 返回参数 表示 第一个是命令 第二个是频道名称 第三个表示当前订阅该频道的数量 127.0.0.1:6379> SUBSCRIBE mychannel Reading messages... (press Ctrl-C to quit

详谈:Redis事务和消息订阅

一.Redis事务 1.概念 可以一次执行多个命令,本质是一组命令的集合.一个事务中的 所有命令都会序列化,按顺序地串行化执行而不会被其它命令插入,不许加塞. 事务能做的事: 一个队列中,一次性.顺序性.排他性的执行一系列命令 常用命令: DISCARD: 取消事务,放弃执行事务块内的所有命令: EXEC : 执行所有事务块内的命令: MULTI : 标记一个事务块的开始: WATCH key([key ....]) : 监视一个(或多个) key,如果在事务执行之前这个(或这些)key被其他命

Redis Sentinel环境下的Key过期事件消息订阅

一.Redis Sentinel Sentinel是Redis 2.8之后官方发布的HA解决方案,通过Sentinel可以保障整个Redis系统的高可用性.当Redis系统中的Master在异常情况下停止服务后,若干Sentinel会及时察觉并主观判断Master down(Subjectively Down),并且随后由一定数量的Sentinel共同确定Master确实客观已down(Objectively Down),这个时候Sentinel们会选举出一个新的Master继续提供服务.Red

redis学习教程三《发送订阅、事务、连接》

redis学习教程三<发送订阅.事务.连接> 一:发送订阅      Redis发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息.Redis 发布订阅(pub/sub)实现了消息系统,发送者(在redis术语中称为发布者)在接收者(订阅者)接收消息时发送消息.传送消息的链路称为信道. 示例 以下示例说明了发布用户概念的工作原理. 在以下示例中,一个客户端订阅名为"redisChat"的信道. redis 127.0.0.1:6

Redis 小白指南(三)- 事务、过期、消息通知、管道和优化内存空间

Redis 小白指南(三)- 事务.过期.消息通知.管道和优化内存空间 简介 <Redis 小白指南(一)- 简介.安装.GUI 和 C# 驱动介绍> 讲的是 Redis 的介绍,以及如何在 Windows 上安装并使用,一些 GUI 工具和自己简单封装的 RedisHelper. <Redis 小白指南(二)- 聊聊五大类型:字符串.散列.列表.集合和有序集合>讲的是 Redis 中最核心的内容,最常用的就是和数据类型打交道. 目录 事务 过期时间 消息通知 管道 优化内存空间

redis的消息订阅发布介绍

1.redis的消息订阅发布: 进程间的一种消息通信模式:发送者(pub)发送信息,订阅者(sub)接收信息. 注: 图1为 三个客户端 client2.client5.client1 通过 subscribe 命令订阅 频道 channel1 ,图二为 当有新消息通过 publish 命令发送给频道 channel1时,这个消息就会被发送给订阅它的三个客户端. 2.消息订阅发布的相关命令: PSUBSCRIBE pattern [pattern...]: 订阅一个或者多个符合给定模式的频道 P

Redis 发布订阅、事务、脚本、连接、HyperLogLog

欢迎大家加入 459479177QQ群进行交流 本次主要介绍Redis的发布订阅.事务.脚本.连接.HyperLogLog 一.发布订阅 1>psubscribe,订阅一个或多个指定的频道 Reading messages... (press Ctrl-C to quit) 1) "psubscribe" 2) "tv1" 3) (integer) 1 127.0.0.1:6379> psubscribe tv2 tv3                \

基于Redis的消息订阅/发布

在工业生产设计中,我们往往需要实现一个基于消息订阅的模式,用来对非定时的的消息进行监听订阅. 这种设计模式在 总线设计模式中得到体现.微软以前的WCF中实现了服务总线 ServiceBus的设计模式.然并卵.WCF已经好像是上个世纪的产物................ 基于事件订阅的模式,比如 EventBus类的组件产品.但是往往设计比较复杂. 如果依赖于 Redis做事件消息推送.那就大大简化了这种设计模式,而且性能也比较客观. Redis在 2.0之后的版本中 实现了 事件推送的  pu