Redis消息传递模式与Lua脚本

你的名字 2022-11-18 04:32 229阅读 0赞

**目录**

发布-订阅模式

示例

活跃频道

Lua脚本

测试用例

--------------------

以前钻研Java多线程编程时有接触到一种并发编程方式叫反应式编程，当时这方面学习不深入，简单来说反应式编程就是处理异步流中的数据，因为以流的形式处理数据，所以执行效率很高。反应式编程其中一个重要特点是消息驱动，即对输入有反应，典型的消息处理模式是“发布-订阅”模式，记得Java中用到的组件是Publisher和Subscriber，分别代表发布者和订阅者。回到Redis，在Redis中也有这一经典消息传递模式，这篇日志就来总结下Redis发布订阅模式和Lua脚本相关。

## 发布-订阅模式 ##

发布-订阅模式是经典的消息传递模式，发布者发布消息，订阅者接收消息，除此之外还有一个组成部分：Channel，在Redis里，Channel频道作为Redis服务器端，发布者和订阅者作为Redis客户端，Redis订阅者客户端可以订阅多个频道，发布者如果想要发布消息，会将消息发送到PubSub Channel中，PubSub频道会将消息发送给每一个订阅了该频道的订阅者。

### 示例 ###

来具体看个例子：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70][]

我们打开三个命令行控制台，一个作为发布者，另外两个作为订阅者，一个订阅者订阅了Rap\_radio和Rap\_remix两个频道，另一个订阅者只订阅了Rap\_radio频道，订阅频道使用的命令是SUBSCRIBE，该命令用来设置监听特定频道中的消息，解除监听频道使用命令UNSUBSCRIBE。客户端可以设置监听多个数量的频道，订阅成功会返回相应的信息，每当有新的消息发送到被订阅频道后，消息会通过Channel发送给所有订阅了该频道的客户端。接着用一个控制台作为发布者，发布者通过PUBLISH命令向指定的频道发送消息，从上面的例子可以看到，发布者向Rap\_radio频道发布一条消息“Release new songs tomorrow.”，下面两个订阅者都收到了这条消息，因为它们都一同订阅了该频道，如果我们再使用PUBLISH命令向Rap\_remix频道发送一条消息，由于其中一个订阅者没有订阅Rap\_remix频道，所以只有那个同时订阅了两个频道的订阅者收到了此条消息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70 1][]

### 活跃频道 ###

如果我们想知道当前都有哪些频道是活跃的，可以在发布者控制台使用命令PUBSUB来查看当前活跃的频道：

![20210412120044696.PNG][]

从上面的例子中我们发现，在订阅者订阅一个或多个频道时，并不需要提前创建这些频道，SUBSCRIBE命令在订阅Channel时会自动创建这些频道，反之，如果一个频道没有被任何订阅者订阅，那么该频道会被删除，且之前被发送到该频道上的消息都会被丢弃掉。

## Lua脚本 ##

Lua是脚本语言，动态语言，有8个基本数据类型，nil、boolean、number、string、userdata、function、thread和table。可以嵌入到其他语言和应用中，Redis也支持将Lua作为自己的服务器端脚本语言，实现一些扩展性功能。

### 测试用例 ###

先来看一个例子，在Redis中编写一个Lua脚本实现对JSON字符串的更新：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70 2][]

在redis/ins/lua目录下我们创建一个Lua脚本，该脚本需要两个参数，KEYS和ARGV，一开始我们用两个变量userID和userName分别接收KEYS和ARGV，得到键和要更新的JSON内容，接着使用cjson。Decode（）对原JSON内容进行反序列化，得到的userSource是一个table，里面存放的是用户信息键值对。往下，通过redis.call（）函数指定参数GET命令来获取userID，如果返回值retJson为false，表示键不存在，那么就要retJson设置为空表，否则将该键对应的值作为JSON字符串进行解析。接着我们对userSource进行遍历，设置retJson中的键和值，最后返回结果。脚本编写完后，使用命令redis-cli加上选项--eval来执行这个脚本：

![202104121201210.PNG][]

传入的参数有userID和要更新的用户信息，其中userID被当作KEYS\[ \]里的元素，用户信息被当作ARGC\[ \]里的元素。Redis中的Lua脚本和事务一样都是原子性的，也就是说Lua脚本在执行期间，Redis服务器不会处理其他事件，如果一个脚本执行过长，会一直占用服务器，当然我们可以用SCRIPT KILL来终止当前正在执行的脚本，这里有个前提就是Lua脚本的运行时间超过了时长限制，默认为5s，如果在这个时长没到时使用SCRIPT KILL命令，那么该命令会被阻塞，直到5s后才执行。如果正在执行的Lua脚本调用了写入命令，就要换成SHUTDOWN NOSAVE命令来终止脚本执行。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70]: /images/20221022/64edbf81f15c41879b53507d36a07560.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70 1]: /images/20221022/3df99ee1b86c4c7482a13f98596595bf.png
[20210412120044696.PNG]: /images/20221022/1c62d78aab6f4fa9a8cbb6a2a4612762.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2p1c3RpbnplbmdUTQ_size_16_color_FFFFFF_t_70 2]: /images/20221022/ab3be7e8ff4744d79356c57b12fd57eb.png
[202104121201210.PNG]: /images/20221022/fad7f61a2f1b4f79ac291eb19dcb16ec.png