十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
本篇内容主要讲解“redis中的发布订阅和事务怎么使用”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Redis中的发布订阅和事务怎么使用”吧!
创新互联是一家专注于网站设计、网站建设与策划设计,科尔沁右翼前网站建设哪家好?创新互联做网站,专注于网站建设十余年,网设计领域的专业建站公司;建站业务涵盖:科尔沁右翼前等地区。科尔沁右翼前做网站价格咨询:13518219792
redis的发布订阅系统有点类似于我们生活中的电台,电台可以在某一个频率上发送广播,而我们可以接收任何一个频率的广播,Android中的broadcast也和这类似。
订阅消息的方式如下:
127.0.0.1:6379> SUBSCRIBE c1 c2 c3 Reading messages... (press Ctrl-C to quit) 1) "subscribe" 2) "c1" 3) (integer) 1 1) "subscribe" 2) "c2" 3) (integer) 2 1) "subscribe" 2) "c3" 3) (integer) 3
这个表示接收c1,c2,c3三个频道传来的消息,发送消息的方式如下:
127.0.0.1:6379> PUBLISH c1 "hello redis!" (integer) 1
当c1这个频道上有消息发出时,此时在消息订阅控制台可以看到如下输出:
1) "message" 2) "c1" 3) "hello redis!"
在redis中,我们也可以使用模式匹配订阅,如下:
127.0.0.1:6379> PSUBSCRIBE c* Reading messages... (press Ctrl-C to quit) 1) "psubscribe" 2) "c*" 3) (integer) 1
此时可以接收到所有以c开头的频道发来的消息。
redis中的发布订阅系统在某些场景下还是非常好用的,但是也有一些问题需要注意:由于网络在传输过程中可能会遭遇断线等意外情况,断线后需要进行重连,然而这会导致断线期间的数据丢失。
既然redis是一种NoSql数据库,那它当然也有事务的功能,不过这里的事务和我们关系型数据库中的事务有一点点差异。
redis中事务的用法非常简单,我们通过MULTI命令开启一个事务,如下:
127.0.0.1:6379> MULTI OK
在MULTI命令执行之后,我们可以继续发送命令去执行,此时的命令不会被立马执行,而是放在一个队列中,如下:
127.0.0.1:6379> set k1 v1 QUEUED 127.0.0.1:6379> set k2 v2 QUEUED 127.0.0.1:6379> set k3 v3 QUEUED
当所有的命令都输入完成后,我们可以通过EXEC命令发起执行,也可以通过DISCARD命令清空队列,如下:
127.0.0.1:6379> EXEC 1) OK 2) OK 3) OK
redis中事务的异常情况总的来说分为两类:
1.进入队列之前就能发现的错误,比如命令输错;
2.执行EXEC之后才能发现的错误,比如给一个非数字字符加1;
那么对于这两种不同的异常,redis中有不同的处理策略。对于第一种错误,服务器会对命令入队失败的情况进行记录,并在客户端调用 EXEC 命令时,拒绝执行并自动放弃这个事务(这个是2.6.5之后的版本做法,之前的版本做法小伙伴可以参考官方文档)。如下:
127.0.0.1:6379> MULTI OK 127.0.0.1:6379> set kv1 v1 QUEUED 127.0.0.1:6379> set k2 v2 QUEUED 127.0.0.1:6379> set k3 v3 3 3 QUEUED 127.0.0.1:6379> set k4 v4 QUEUED 127.0.0.1:6379> EXEC 1) OK 2) OK 3) (error) ERR syntax error 4) OK 127.0.0.1:6379> keys * 1) "k4" 2) "k2" 3) "kv1"
而对于第二种情况,redis并没有对它们进行特别处理, 即使事务中有某个/某些命令在执行时产生了错误, 事务中的其他命令仍然会继续执行。如下:
127.0.0.1:6379> MULTI OK 127.0.0.1:6379> set k1 vv QUEUED 127.0.0.1:6379> INCR k1 QUEUED 127.0.0.1:6379> EXEC 1) OK 2) (error) ERR value is not an integer or out of range 127.0.0.1:6379> GET k1 "vv"
不同于关系型数据库,redis中的事务出错时没有回滚,对此,官方的解释如下:
Redis 命令只会因为错误的语法而失败(并且这些问题不能在入队时发现),或是命令用在了错误类型的键上面:这也就是说,从实用性的角度来说,失败的命令是由编程错误造成的,而这些错误应该在开发的过程中被发现,而不应该出现在生产环境中。因为不需要对回滚进行支持,所以 Redis 的内部可以保持简单且快速。
事务中的WATCH命令可以用来监控一个key,通过这种监控,我们可以为redis事务提供(CAS)行为。 如果有至少一个被WATCH监视的键在EXEC执行之前被修改了,那么整个事务都会被取消,EXEC返回nil-reply来表示事务已经失败。如下:
通过unwatch命令,可以取消对一个key的监控,如下:
到此,相信大家对“Redis中的发布订阅和事务怎么使用”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!