Redis03发布与订阅及事务

àì夳堔傛蜴生んèń 2022-02-04 12:06 200阅读 0赞

## Redis发布和订阅 ##

Redis 发布订阅(pub/sub)是一种消息通信模式：  
发送者(pub)发送消息  
订阅者(sub)接收消息  
Redis 客户端可以订阅任意数量的频道

## 订阅消息 ##

创建三个会话  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwOTg0NTYx_size_16_color_FFFFFF_t_70]  
客户端订阅消息的命令如下test和test1:

127.0.0.1:6379> SUBSCRIBE a s d
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "a"
    3) (integer) 1
    1) "subscribe"
    2) "s"
    3) (integer) 2
    1) "subscribe"
    2) "d"
    3) (integer) 3

127.0.0.1:6379> SUBSCRIBE a z x
    Reading messages... (press Ctrl-C to quit)
    1) "subscribe"
    2) "a"
    3) (integer) 1
    1) "subscribe"
    2) "z"
    3) (integer) 2
    1) "subscribe"
    2) "x"
    3) (integer) 3

发送消息命令如下

127.0.0.1:6379> PUBLISH a haha
    (integer) 2
    127.0.0.1:6379> PUBLISH x haha
    (integer) 1
    127.0.0.1:6379>

客服端收到的消息test和test1:

## 模拟订阅消息 ##

客服端在订阅消息的时候还可以通过模式匹配订阅的方式订阅,test会话如下:

127.0.0.1:6379> PSUBSCRIBE c*
    Reading messages... (press Ctrl-C to quit)
    1) "psubscribe"
    2) "c*"
    3) (integer) 1

发送消息一样:

127.0.0.1:6379> PUBLISH c hha
    (integer) 1
    127.0.0.1:6379>

接受消息test:

127.0.0.1:6379> PSUBSCRIBE c*
    Reading messages... (press Ctrl-C to quit)
    1) "psubscribe"
    2) "c*"
    3) (integer) 1
    1) "pmessage"
    2) "c*"
    3) "c"
    4) "hha"

发布订阅要注意网络连接断开的话需要重新连接，此时就会有可能数据的丢失。这个需要注意~

## 事务实例 ##

Redis中事务的使用其实非常简单,通过multi命令即可

127.0.0.1:6379> MULTI
    OK

在MULTI命令执行之后，我们可以继续发送命令执行，但此时命令不会立即执行，而是保持到一个队列中，如下

127.0.0.1:6379> set user aaa
    QUEUED
    127.0.0.1:6379> set user1 aaa
    QUEUED
    127.0.0.1:6379> set user11 aaa2
    QUEUED
    127.0.0.1:6379> get user
    QUEUED

当所有的命令都输入完成后，我们可以输入EXEC命令来执行队列中的命令，如下

127.0.0.1:6379> EXEC
    1) OK
    2) OK
    3) OK
    4) "aaa"

## 事务异常 ##

事务异常有两种情况

## 进入队列之前发生错误 ##

比较常见的命令错误，此类异常redis的处理方式是，服务器会对进入队列失败的情况进行记录，在执行exec命令提交的时候，对于该命令不会执行并放弃这个事务，如下

127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379> set k a d f 命令错误
    QUEUED
    127.0.0.1:6379> set k1 s
    QUEUED
    127.0.0.1:6379> set k2 t
    QUEUED
    127.0.0.1:6379> EXEC
    1) (error) ERR syntax error 执行命令错误
    2) OK
    3) OK
    127.0.0.1:6379> keys k*
    1) "k1"
    2) "k2"
    127.0.0.1:6379>

注意 redis事务中有一个异常并不会造成其他命令的回滚！

## 执行exec命令后发生的异常 ##

对于这种情况，redis中也不会做特别的处理。事务中的命令继续执行

127.0.0.1:6379> set c1 aaa
    QUEUED
    127.0.0.1:6379> incr c1
    QUEUED
    127.0.0.1:6379> exec
    1) OK
    2) (error) ERR value is not an integer or out of range

不同于关系型数据库，redis中没有回滚操作，官方解释是:

> Redis 命令只会因为错误的语法而失败（并且这些问题不能在入队时发现），或是命令用在了错误类型的键上面：这也就是说，从实用性的角度来说，失败的命令是由编程错误造成的，而这些错误应该在开发的过程中被发现，而不应该出现在生产环境中。  
> 因为不需要对回滚进行支持，所以 Redis 的内部可以保持简单且快速

## Watch ##

watch命令可以监控一个或多个键，一旦其中有一个键被修改（或删除），之后的事务就不会执行。监控一直持续到exec命令（事务中的命令是在exec之后才执行的，所以在multi命令后可以修改watch监控的键值）。假设我们通过watch命令在事务执行之前监控了多个Keys，倘若在watch之后有任何Key的值发生了变化，exec命令执行的事务都将被放弃，同时返回Null multi-bulk应答以通知调用者事务执行失败。

127.0.0.1:6379> set k bbb
    OK
    127.0.0.1:6379> WATCH k
    OK
    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379> set k aaa
    QUEUED
    127.0.0.1:6379> EXEC
    1) OK
    127.0.0.1:6379> get k
    "aaa"
    127.0.0.1:6379> set k1 aaa
    OK
    127.0.0.1:6379> WATCH k1
    OK
    127.0.0.1:6379> set k1 nnn
    OK
    127.0.0.1:6379> set k1 vvv
    OK
    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379> set k1 rrr
    QUEUED
    127.0.0.1:6379> exec
    (nil)

exec后会自动执行unwatch命令，撤销监控

## UnWatch ##

撤销对一个key的监控

127.0.0.1:6379> set k aaa
    OK
    127.0.0.1:6379> WATCH k
    OK
    127.0.0.1:6379> set k ddd
    OK
    127.0.0.1:6379> UNWATCH
    OK
    127.0.0.1:6379> MULTI
    OK
    127.0.0.1:6379> set k eee
    QUEUED
    127.0.0.1:6379> exec
    1) OK
    127.0.0.1:6379> get k
    "eee"
    127.0.0.1:6379>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMwOTg0NTYx_size_16_color_FFFFFF_t_70]: /images/20220204/0060e91708184fa8b9a6aa6de359a3f2.png