# 扩展库Redis

2021年11月18日,腾讯云和阿里云均支持

使用腾讯云node12及以上版本和redis,务必仔细阅读此文档:keepRunningAfterReturn

Redis是一个基于key/value的内存数据库。在项目中通常作为MongoDB等磁盘数据库的补充来搭配使用。 相对于磁盘数据库,Redis的核心优势是快。因为操作内存要比磁盘快的多,并且Redis只支持key/value数据,读写都很快。但Redis没有磁盘数据库丰富的查询等功能。

Redis一般需要与MongoDB搭配使用,MongoDB做主存储,Redis缓存部分数据应对高性能需求场景。

在uniCloud中,Redis还有一个特点,是它按容量和使用时长计费,访问它不耗费云数据库的读写次数。

Redis常见使用场景:

  • 缓存高频数据,比如首页列表、banner列表、热门排行。MongoDB数据更新后同步给Redis,这些频繁的请求就不再查询MongoDB数据库
  • 秒杀、抢购。短时间大量并发可能发生超卖,此时必须使用Redis解决
  • ip黑名单屏蔽。希望较快封杀某些ip请求,缓解MongoDB数据库压力。
  • 其他数据库操作速度不满足需求的场景

# 开通Redis服务

参考开通redis

# 为云函数启用redis扩展库

Redis的sdk体积不小,没有内置在云函数中。在需要Redis的云函数里,开发者需手动配置Redis扩展库。(Redis没有免费试用,需购买才可以使用)。如何启用扩展库请参考:使用扩展库

# 云函数中调用Redis

// 云函数中调用Redis示例
'use strict';
const redis = uniCloud.redis()
exports.main = async (event, context) => {
	const getResult = await redis.get('my-key')
	const setResult = await redis.set('my-key', 'value-test')
	return {
    getResult,
    setResult
  }
};

注意

  • redis中,以冒号分割key,在redis的uniCloud web控制台的可视化界面中,将以tree的方式显示。折叠所有使用同一前缀的key。 比如2个key,uni:aauni:bb,将显示为根节点为uni的tree,展开后有aa和bb。
  • uni:dcloud:unicloud:为前缀的redis的key,为官方前缀。开发者自己的业务所需的key应避免使用这些前缀。
  • 调用uniCloud.redis()时返回的redis实例对应着一个连接,多次调用时如果存在未断开连接的redis实例则返回此实例。如果不存在redis实例或之前的redis实例已断开连接则返回新的redis实例。
  • redis实例创建时并未建立与redis的连接,而是在第一次调用redis方法时才会与redis建立连接。在实际业务中的表现就是一个云函数实例第一次调用redis方法会慢上几毫秒
  • 为云函数开启redis扩展会影响云函数固定ip功能,详情参考:云函数固定出口IP

# Redis本地运行

HBuilderX 3.4.10 起支持

因为Redis在云函数的内网中,所以只能在云端云函数中访问,而不能在本地云函数中访问。每次调试Redis相关功能需要不断的上传云函数,严重影响开发效率。自HBuilderX 3.4.10起,本地云函数可以通过云端内置代理访问云端Redis。如果在本地调用云端Redis的话会在云函数日志内看到HBuilderX运行调试Redis的代理请求字样。

# 数据类型

Redis中数据被存储为key-value形式,key均为字符串,value有以下几种类型

# 字符串 String

字符串类型,这是最简单Redis类型。需要注意的是Redis并没有number类型,如果存入number类型的数据最终也会转为string类型。

await redis.set('string-key', 1) // 设置string-key的值为字符串"1"
await redis.get('string-key') // 获取string-key的值,"1"

# 列表 List

列表类型,类似JavaScript中的数组,但是有区别。严格来说List是基于链表实现的,和js中数组相比一个显著的差异就是头部插入的效率。如果你测试过往一个长度百万的数组最前面插入一位的话,你会发现这个操作会耗时很久。但是List并没有这个问题,对于List来说在前后插入数据耗时是一样的。

注意

  • list为空时对应的键会被删除,即redis内不存在空List
await redis.lpush('list-key', 1) // 往list-key左侧添加一个元素,不存在则创建

# 哈希表 Hash

Hash类型类似js里面的Object。

await redis.hmset('hash-key', 'key1', 'value1', 'key2', 'value2') // 批量为hash-key添加键值,不存在则创建
await redis.hset('hash-key', 'key1', 'value1') // 为hash-key添加键值,不存在则创建

# 集合 Set

集合是String的无序排列,集合内的元素不可重复

await redis.sadd('set-key', 'value1', 'value2') // 往集合内添加数据,不存在则创建

# 有序集合 SortedSet

有序集合和集合一样也是string类型元素的集合,且不允许重复的成员。不同的是每个元素将有一个double类型的分数(分数不一定是连续的),用于对元素进行排序

await redis.zadd('sorted-set-key', 1, 'value1') // 往有序集合内添加数据并指定分数,不存在则创建
await redis.zadd('sorted-set-key', 2, 'value2')

# 基数统计 HyperLogLog

一个集合(指的是 Object 的聚合,可以包含重复元素)中不重复元素的个数。例如集合 {1,3,5,1,3},它有5个元素,但它的基数为3。

await redis.pfadd('key', 'element1', 'element2')

# 事务 Transaction

Redis 事务可以一次执行多个命令

await redis.multi() // 开启事务
redis.set('key', 'value')
await redis.exec() // 执行事务块内的命令

# 位图 bitMap

是一串连续的二进制数组(0和1),可以通过偏移量(offset)定位元素。BitMap通过最小的单位bit来进行0|1的设置,表示某个元素的值或者状态,时间复杂度为O(1)。

await redis.setbit('key', 'offset', 'value') // 设置指定位的值

# API

此处仅列举常见命令,完整命令支持请查看redis官方文档

# 字符串 String

# get

用于获取字符串类型的数据

接口形式

await redis.get(key: string)

入参说明

参数 说明 必填 说明
key

返回值

此接口返回获取到的数据(字符串类型),返回null表示无此键

示例

await redis.get('string-key') // '1'

# set

用于设置字符串类型数据,新增、修改均可

接口形式

该接口有多种形式

await redis.set(key: string, value: string, flag: string)
await redis.set(key: string, value: string, mode: string, duration: number)
await redis.set(key: string, value: string, mode: string, duration: number, flag: string)

入参说明

参数 说明 必填 说明
key
value
duration 过期时间,到期后自动删除
mode 标识duration的单位 否(duration不为空时必填) EX:单位秒,PX:单位毫秒
flag 区分状态进行SET NX:不存在时才设置,XX:存在时才设置

返回值

此接口返回字符串类型'OK'表示操作成功,返回null表示未更新

示例

await redis.set('string-key', 1)  // redis内存储为字符串"1"
await redis.set('string-key', '1', 'NX')  // string-key不存在时设置为1
await redis.set('string-key', '1', 'EX', 100)  // string-key 100秒后过期
await redis.set('string-key', '1', 'EX', 100, 'NX')  // string-key不存在时设置为1,过期时间设置为100秒

# getrange

返回 key 中字符串值的子字符串

await redis.getrange(key: string, start: number, end: number)

入参说明

参数 说明 必填 说明
key
start 起始位置 (0代表第一个字符,-1代表最后1个字符,-2代表最后第2个字符)
end 结束位置 (0代表第一个字符,-1代表最后1个字符,-2代表最后第2个字符)

返回值

此接口返回截取得到的子字符串表示操作成功,返回空字符串表示未匹配

示例

await redis.getrange('string-key', 0, 10)

# setex

键存在时,设置为指定字符串并指定过期时间

接口形式

await redis.setex(key: string, seconds: number, value: string)

入参说明

参数 说明 必填 说明
key
seconds 过期时间 单位:秒
value

返回值

此接口返回字符串类型'OK'表示操作成功,返回null表示未更新

示例

await redis.setex('string-key', 10, 'value')  // 值设置为value,过期时间10秒

# setnx

键不存在时,设置为指定字符串

接口形式

await redis.setnx(key: string, value: string)

入参说明

参数 说明 必填 说明
key
value

返回值

此接口返回字符串类型'OK'表示操作成功,返回null表示未更新

示例

await redis.setnx('string-key', 'value')  // 键string-key不存在时将值设置为'value'

# mget

批量获取指定键的值

接口形式

await redis.mget(key1: string, key2: string, ...)

入参说明

接收一个键的列表

返回值

此接口按传入顺序返回获取到的数据组成的数组,存在的键返回字符串类型,不存在的键返回null

示例

await redis.mget('key1', 'key2') // '1'

# mset

批量设置键值

接口形式

await redis.mset(key1: string, value1: string, key2: string, value2: string, ...)

入参说明

接收一个键、值的列表

返回值

此接口只会返回OK

示例

await redis.mset('key1', '1', 'key2', '2') // 'OK'

# strlen

返回 key 所储存的字符串值的长度。

接口形式

await redis.strlen(key: string)

入参说明

参数 说明 必填 说明
key

返回值

此接口返回字符串长度,不存在的key会返回0

示例

await redis.strlen('key')

# msetnx

批量设置键值,当且仅当所有给定 key 都不存在。

接口形式

await redis.msetnx(key1: string, value1: string, key2: string, value2: string);

入参说明

参数 说明 必填 说明
key

返回值

此接口返回1表示执行成功

示例

await redis.msetnx('key1''value1', 'key2', 'value2')

# psetex

设置key对应字符串value,并且设置key在给定的milliseconds(毫秒)时间之后超时过期

接口形式

await redis.psetex(key: string, milliseconds: number, value: string);

入参说明

参数 说明 必填 说明
key
milliseconds 毫秒
value

返回值

此接口返回OK表示执行成功

示例

await redis.psetex('key'1666582638076, 'value')

# incr

对指定的键执行加1操作

接口形式

await redis.incr(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回执行加一操作后的值(number类型)

注意

操作的值并非整数形式(例:字符串"1"是整数形式,字符串"a"非整数形式)时会直接抛出错误

示例

await redis.set('string-key', '1')
await redis.incr('string-key') // 2

# incrby

在指定的键上加一个整数

接口形式

await redis.incrby(key: string, increment: number)

入参说明

参数 说明 必填 说明
key
increment 增加的值

返回值

接口返回执行加操作后的值(number类型)

注意

操作的值并非整数形式(例:字符串"1"是整数形式,字符串"a"非整数形式)时会直接抛出错误

示例

await redis.set('string-key', '1')
await redis.incrby('string-key', 2) // 3

# incrbyfloat

在指定的键上加一个浮点数

接口形式

await redis.incrbyfloat(key: string, increment: number)

入参说明

参数 说明 必填 说明
key
increment 增加的值,允许为负值来实现相减功能

返回值

接口返回执行加操作后的值(number类型)

注意

  • 操作的值并非整数形式(例:字符串"1"是整数形式,字符串"a"非整数形式)时会直接抛出错误
  • 浮点数相加和js内表现一致,可能与预期结果不一致,见下方示例

示例

await redis.set('string-key', '1.1')
await redis.incrbyfloat('string-key', 2.2) // 3.30000000000000027
// js内执行 0.1 + 0.2 会得到类似的值 3.3000000000000003

# decr

对指定的键执行减1操作

接口形式

await redis.decr(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回执行减1操作后的值(number类型)

注意

操作的值并非整数形式(例:字符串"1"是整数形式,字符串"a"非整数形式)时会直接抛出错误

示例

await redis.set('string-key', '1')
await redis.decr('string-key') // 0

# decrby

在指定的键上减一个整数

接口形式

await redis.decrby(key: string, decrement: number)

入参说明

参数 说明 必填 说明
key
decrement 减少的值

返回值

接口返回执行加一操作后的值(number类型)

注意

操作的值并非整数形式(例:字符串"1"是整数形式,字符串"a"非整数形式)时会直接抛出错误

示例

await redis.set('string-key', '1')
await redis.decrby('string-key', 2) // -1

# append

如果 key 已经存在并且是一个字符串, APPEND 命令将指定的 value 追加到该 key 原来值(value)的末尾。

接口形式

await redis.decrby(key: string, value: string);

入参说明

参数 说明 必填 说明
key
value 需要追加的值

返回值

此接口返回执行成功返回值的长度

示例

await redis.decrby('key', 10);

# 键 Key

# del

用于删除执行的键

接口形式

await redis.del(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回数字1表示删除成功,数字0表示键不存在删除失败

示例

await redis.del('string-key') // '1'

# dump

用于序列化给定 key ,并返回被序列化的值。

接口形式

await redis.dump(key: string)

入参说明

参数 说明 必填 说明
key

返回值

key不存在返回null,存在返回序列化后的值

示例

await redis.set('key', 'hello')
await redis.dump('key') // '\u0000\u0005hello\t\u0000����1�C�'

# exists

判断一个键是否存在

接口形式

await redis.exists(key: string)

入参说明

参数 说明 必填 说明
key

返回值

如果key存在返回数字1,如果key不存在返回数字0

示例

await redis.exists('string-key') // 0 | 1

# expire

为指定的key设置过期时间

接口形式

await redis.expire(key: string, seconds: number)

入参说明

参数 说明 必填 说明
key
seconds 过期时间 单位:秒

返回值

如果成功设置过期时间返回数字1,如果未成功存在返回数字0

示例

await redis.expire('key', 600) // 设置key为600秒后过期

# expireat

EXPIREAT 的作用和 EXPIRE 类似,都用于为 key 设置过期时间。 不同在于 EXPIREAT 命令接受的时间参数是 UNIX 时间戳(unix timestamp)。

接口形式

await redis.expireat(key: string, timestamp: number)

入参说明

参数 说明 必填 说明
key
seconds UNIX 时间戳 单位:秒

返回值

如果成功设置过期时间返回数字1,如果未成功存在返回数字0

示例

await redis.expireat('key', 1666584328) // 设置key将在2022-10-24 12:05过期

# pexpire

这个命令和 expire 命令的作用类似,但是它以毫秒为单位设置 key 的生存时间,而不像 expire 命令那样,以秒为单位。

接口形式

await redis.pexpire(key: string, milliseconds: number)

入参说明

参数 说明 必填 说明
key
milliseconds 毫秒时间戳

返回值

如果成功设置过期时间返回数字1,如果未成功存在返回数字0

示例

await redis.pexpire('key', 1500) // 设置key为1500毫秒后过期

# pexpireat

设置 key 过期时间的时间戳(unix timestamp) 以毫秒计

接口形式

await redis.pexpireat(key: string, timeatamp: number)

入参说明

参数 说明 必填 说明
key
timeatamp 毫秒时间戳

返回值

如果成功设置过期时间返回数字1,如果未成功存在返回数字0

示例

await redis.pexpireat('key', 1666584328000) // 设置key将在2022-10-24 12:05过期

# keys

查找所有符合给定模式 pattern 的 key 。

接口形式

await redis.keys(patten: string)

入参说明

参数 说明 必填 说明
patten 表达式

返回值

符合给定模式的 key 列表 (类型为Array)。

示例

await redis.mset('one', 1, 'two', 2, 'three', 3, 'four', 4)
await redis.keys('*o*') // ['one', 'two', 'four']
await redis.keys('*') // ['one', 'two', 'three', 'four']

# persist

移除 key 的过期时间,key 将持久保持。

接口形式

await redis.persist(key: string)

入参说明

参数 说明 必填 说明
key

返回值

移除过期时间成功返回1, key不存在或者key没有设置过期时间返回0

示例

await redis.set('key', 'ok')
await redis.expire('key', 10) // 10秒后过期
await redis.persist('key') // 移除 key 过期时间

# pttl

获取过期时间剩余多少毫秒

接口形式

await redis.pttl(key: string)

入参说明

参数 说明 必填 说明
key

返回值

如果没有设置过期时间(永久有效)返回数字-1,如果不存在或者已过期返回数字-2,否则返回剩余秒数

示例

await redis.pttl('key')

# ttl

获取过期时间剩余多少秒

接口形式

await redis.ttl(key: string)

入参说明

参数 说明 必填 说明
key

返回值

如果没有设置过期时间(永久有效)返回数字-1,如果不存在或者已过期返回数字-2,否则返回剩余秒数

示例

await redis.ttl('key')

# randonkey

从当前数据库中随机返回一个 key 。

接口形式

await redis.randonkey()

入参说明

返回值

数据库不为空时返回一个 key, 数据库为空时返回 null

示例

await redis.randonkey()

# rename

将 key 改名为 newkey。

当 key 和 newkey 相同,或者 key 不存在时,返回一个错误。

当 newkey 已经存在时, rename 命令将覆盖旧值。

接口形式

await redis.rename(key: string, newKey: string)

入参说明

参数 说明 必填 说明
key
newKey 新的键名

返回值

修改成功返回 OK,key 不存在时返回一个错误

示例

await redis.rename('key', 'newKey')

# renamenx

仅当 newkey 不存在时,将 key 改名为 newkey 。

当 key 不存在时,返回一个错误。

接口形式

await redis.renamenx(key: string, newKey: string)

入参说明

参数 说明 必填 说明
key
newKey 新的键名

返回值

修改成功返回 1, newKey 存在返回 0

示例

await redis.renamenx('key', 'newKey')

# scan

迭代当前数据库中的数据库键。

接口形式

await redis.scan(cursor: string)

入参说明

参数 说明 必填 说明
cursor 游标

返回值

返回包含两个元素的数据 [下次迭代的新游标,0代表已结束, [所有被迭代的数据]]

示例

await redis.mset('key1', 1, 'key2', '2', 'key3', 3, 'key4', 4, 'key5', 5)
await redis.scan(0) // 返回 [6, ['key1', 'key2', 'key3', 'key4', 'key5']]

# type

返回 key 所储存的值的类型。

接口形式

await redis.type(key: string)

入参说明

参数 说明 必填 说明
key

返回值

  • none (key不存在)
  • string (字符串)
  • list (列表)
  • set (集合)
  • zset (有序集)
  • hash (哈希表)

示例

await redis.set('key1', 1)
await redis.type('key1') // 返回 string

# 列表 List

# rpush

在List类型数据结尾追加数据

接口形式

await redis.rpush(key: string, value: string)

入参说明

参数 说明 必填 说明
key
value 追加的值

返回值

接口返回执行追加操作后List的长度

注意

  • 如果操作的数据类型不为List,则会抛出错误
  • 如果指定的key不存在,则创建一个新的List并将value追加进去

# rpushx

用法同rpush,仅在list存在时才在List结尾追加数据

# rpoplpush

移除列表的最后一个元素,并将该元素添加到另一个列表并返回。

接口形式

await redis.rpoplpush(source: string, destination: string)

入参说明

参数 说明 必填 说明
source
destination 另一个键

返回值

source存在返回被移除的元素,source 不存在返回 null

示例

await redis.lrange('source', 0, -1) // 返回 ['a', 'b', 'c']
await redis.lrange('destination', 0, -1) // 返回 []

await redis.rpoplpush('source', 'destination') // 返回 c
await redis.lrange('source', 0, -1) // 返回 ['a', 'b']
await redis.lrange('destination', 0, -1) // 返回 ['c']

# rpop

从List类型数据结尾删除一条数据,并返回删除的值

注意:redis内List长度为0时会被自动删除

接口形式

await redis.rpop(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回此次操作删除的值,如果key不存在则返回null

注意

  • 如果操作的数据类型不为List,则会抛出错误

# lpush

在List类型数据开头追加数据

接口形式

await redis.lpush(key: string, value: string)

入参说明

参数 说明 必填 说明
key
value 追加的值

返回值

接口返回执行追加操作后List的长度

注意

  • 如果操作的数据类型不为List,则会抛出错误
  • 如果指定的key不存在,则创建一个新的List并将value追加进去

# lpushx

用法同lpush,仅在list存在时才在List开头追加数据

# lpop

从List类型数据开头删除一条数据,并返回删除的值

注意:redis内List长度为0时会被自动删除

接口形式

await redis.lpop(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回此次操作删除的值,如果key不存在则返回null

注意

  • 如果操作的数据类型不为List,则会抛出错误

# linsert

在List内指定元素位置前或后插入元素,未匹配到指定元素时不插入

接口形式

await redis.linsert(key: string, dir: 'BEFORE' | 'AFTER', pivot: string, value: string)

入参说明

参数 说明 必填 说明
key
dir 指定在前还是后插入
pivot 指定要查找的元素
value 指定要插入的值

返回值

接口返回插入后的list长度,未匹配到要查找的值时返回-1,key不存在时此接口返回0

注意

  • 如果操作的数据类型不为List,则会抛出错误

# lindex

获取List内指定下标的元素

接口形式

await redis.lindex(key: string, index: number)

入参说明

参数 说明 必填 说明
key
index 指定下标

返回值

接口返回指定下标在list内对应的值,如果key不存在则返回null

注意

  • 如果操作的数据类型不为List,则会抛出错误

# llen

返回List的长度

接口形式

await redis.llen(key: string)

入参说明

参数 说明 必填 说明
key

返回值

接口返回list的长度,如果key不存在则返回0

注意

  • 如果操作的数据类型不为List,则会抛出错误

# lrange

返回列表 key 中指定区间内的元素,区间以偏移量 start 和 stop 指定。

接口形式

await redis.lrange(key: string, strar: number, end: number)

入参说明

参数 说明 必填 说明
key
start 起始下标
end 结束下标

返回值

返回指定确定的元素,类型为Array

示例

await redis.rpush('key', 'a')
await redis.rpush('key', 'b')
await redis.rpush('key', 'c')

await redis.lrange('key', 0, 1) // 返回 ['a', 'b']

# lrem

根据参数 count 的值,移除列表中与参数 value 相等的元素。

接口形式

await redis.lrem(key: string, count: number, value: string)

入参说明

参数 说明 必填 说明
key
count 移除的数量
value

count说明

count 的值可以是以下几种:

  • count > 0 : 从表头开始向表尾搜索,移除与 value 相等的元素,数量为 count 。
  • count < 0 : 从表尾开始向表头搜索,移除与 value 相等的元素,数量为 count 的绝对值。
  • count = 0 : 移除表中所有与 value 相等的值。

返回值

key 存在时返回被移除的元素的数量,key 不存在时返回 0

示例

await redis.rpush('key', 'a')
await redis.lrem('key', 0, 'a') // 返回 1

# lset

将列表 key 下标为 index 的元素的值设置为 value 。

接口形式

await redis.lset(key: string, index: number, value: string)

入参说明

参数 说明 必填 说明
key
index 列表值的下标
value

返回值

key 存在时成功返回 OK,key 不存在时返回错误

示例

await redis.rpush('key', 'a')
await redis.lset('key', 0, 'b') // 返回 OK

# ltrim

修剪(trim)一个已存在的 list,这样 list 就会只包含指定范围的指定元素

接口形式

await redis.ltrim(key: string, start: number, end: number)

入参说明

参数 说明 必填 说明
key
start 起始位置
end 结束位置

注意 超出范围的下标

超出范围的下标值不会引起错误。

如果 start 下标比列表的最大下标 end ( llen list 减去 1 )还要大,或者 start > stop , ltrim 返回一个空列表(因为 ltrim 已经将整个列表清空)。

如果 stop 下标比 end 下标还要大,Redis将 stop 的值设置为 end 。

返回值

执行成功返回 OK

示例

await redis.ltrim('key', 0, -1) // 返回 OK

# blpop

移出并获取列表的第一个元素, 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。

如果列表为空,返回一个 nil 。 否则,返回一个含有两个元素的列表,第一个元素是被弹出元素所属的 key ,第二个元素是被弹出元素的值。

接口形式

await redis.blpop(key: string, timeout: number)

入参说明

参数 说明 必填 说明
key
timeout 等待超时时间;单位秒

返回值

列表为空返回 null,否则返回含有两个元素的数组[键名, 值]

示例

await redis.rpush('key', 'a')
await redis.blpop('key', 10) // 返回 ['key', 'a']

# brpop

移出并获取列表的最后一个元素, 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。

假如在指定时间内没有任何元素被弹出,则返回一个 nil 和等待时长。 反之,返回一个含有两个元素的列表,第一个元素是被弹出元素所属的 key ,第二个元素是被弹出元素的值。

接口形式

await redis.brpop(key: string, timeout: number)

入参说明

参数 说明 必填 说明
key
timeout 等待超时时间;单位秒

返回值

在指定时间内没有任何元素被弹出,则返回 null 和等待时长,否则返回含有两个元素的数组[键名, 值]

示例

await redis.rpush('key', 'a')
await redis.brpop('key', 10) // 返回 ['key', 'a']

# brpoplpush

从 source 中取出最后一个元素,并插入到 destination 头部;如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。

接口形式

await redis.brpoplpush(source: string, destination: string, timeout: number)

入参说明

参数 说明 必填 说明
source
destination 另一个键
timeout 等待超时时间

返回值

在指定时间内没有任何元素被弹出,则返回 null 和等待时长,否则返回含有两个元素的数组[键名, 值]

示例

await redis.brpoplpush('source', 'destination', 10)

# 哈希表 Hash

# hset

设置 key 中指定 field 的值。

接口形式

await redis.hset(key: string, field: string, value: string)

入参说明

参数 说明 必填 说明
key
field 字段名
value

注意

如果 key 不存在,将会创建一个新的哈希表并进行 hset 操作。

如果 field 已经存在于哈希表中,旧值将被覆盖。

返回值

新创建的 field 返回 1, 覆盖旧值返回 0

示例

await redis.hset('key', 'field', 'value')

# hget

返回 key 中指定 field 的值。

接口形式

await redis.hget(key: string, field: string)

入参说明

参数 说明 必填 说明
key
field 字段名

返回值

field 不存在时返回 null, 存在返回 field 值

示例

await redis.hset('key', 'field', 'value')
await redis.hget('key', 'field') // 返回 value

# hmset

同时在一个 key 中设置多个 field-value

接口形式

await redis.hmset(key: string, field1: string, value1: string, field2: string, value2: string)

入参说明

参数 说明 必填 说明
key
field1 字段名
value1

返回值

key 不是hash类型时返回错误,执行成功返回 OK

示例

await redis.hmset('key', 'field1', 'value1', 'field2', 'value2')

# hmget

返回一个 key 中的多个 field

接口形式

await redis.hmget(key: string, field1: string, field2: string)

入参说明

参数 说明 必填 说明
key
field1 字段名

返回值

返回 获取的字段列表,类型Array

示例

await redis.hmget('key', 'field1', 'field2')

# hgetall

返回 key 的所有 field 与 value

接口形式

await redis.hgetall(key: string)

入参说明

参数 说明 必填 说明
key

返回值

返回 field与value,类型Array

示例

await redis.hset('key', 'field1', 'value1')
await redis.hset('key', 'field2', 'value2')

await redis.hgetall('key') // 返回 ['field1', 'value1', 'field2', 'value2']

# hdel

删除 key 中指定的一个或多个 field

接口形式

await redis.hdel(key: string, field1: string)
await redis.hdel(key: string, field1: string, field2: string)

入参说明

参数 说明 必填 说明
key
field1 字段

返回值

返回被删除字段的数量

示例

await redis.hdel('key') // 返回 0

# hexists

查看 key 中 field 是否存在

接口形式

await redis.hexists(key: string, field: string)

入参说明

参数 说明 必填 说明
key
field 字段

返回值

字段存在返回 1, key 不存在或者字段不存在返回 0

示例

await redis.hexists('key''field') // 返回 0

# hincrby

为 key 中指定的 field 的值加上整数增量 increment

接口形式

await redis.hincrby(key: string, field: string, increment: number)

入参说明

参数 说明 必填 说明
key
field 字段
increment 增量整数;>0 增加,<0 减少

返回值

返回 增量增加后的值

示例

await redis.hincrby('key', 'field', 10) // 返回 10

# hincrbyfloat

为 key 中指定的 field 的值加上浮点数增量 increment

接口形式

await redis.hincrbyfloat(key: string, field: string, increment: number)

入参说明

参数 说明 必填 说明
key
field 字段
increment 增量浮点数;>0 增加,<0 减少

返回值

返回 增量增加后的值

示例

await redis.hincrbyfloat('key', 'field', 2.5) // 返回 2.5

# hkeys

返回 key 中所有 field

接口形式

await redis.hkeys(key: string)

入参说明

参数 说明 必填 说明
key

返回值

返回所有 field;类型Array,key 不存在时返回 空数组

示例

await redis.hkeys('key') // 返回 []

# hlen

返回 key 中 field 数量

接口形式

await redis.hlen(key: string)

入参说明

参数 说明 必填 说明
key

返回值

返回 field 数量,key 不存在时返回 0

示例

await redis.hlen('key') // 返回 0

# hsetnx

当 key 中 field 不存在时设置 value,当 field 已存在,该操作无效。

接口形式

await redis.hsetnx(key: string, field: string, value: string)

入参说明

参数 说明 必填 说明
key
field 字段
value

返回值

设置成功返回 1, field 已存在返回 0

示例

await redis.hsetnx('key', 'field', 'value') // 返回 1

# hvals

返回 key 中所有 field 的 value

接口形式

await redis.hvals(key: string)

入参说明

参数 说明 必填 说明
key

返回值

返回所有 field 的 value,类型Array,key 不存在时返回空数组

示例

await redis.hvals('key') // 返回 []

# hscan

迭代哈希键中的键值对

接口形式

await redis.hscan(key: string, cursor: number)

入参说明

参数 说明 必填 说明
key
cursor 游标

返回值

返回包含两个元素的数据 [下次迭代的新游标,0代表已结束, [所有被迭代的数据]]

示例

await redis.hscan('key', 0) // 返回 []

# 集合 Set

# sadd

将一个或多个 member 加入到集合 key 中,已经在集合中的 member 元素将忽略。

接口形式

await redis.sadd(key: string, member: string)
await redis.sadd(key: string, member1: string, member2: string)

入参说明

参数 说明 必填 说明
key
member 成员

返回值

返回被添加到集合中的新元素的数量,不包括被忽略的元素。

示例

await redis.sadd('key', 'm1', 'm2') // 返回 2

# scard

返回集合存储的key的基数(集合中元素的数量)

接口形式

await redis.scard(key: string)

入参说明

参数 说明 必填 说明
key

返回值

返回集合存储的key的基数,key 不存在时返回 0

示例

await redis.sadd('key', 'a', 'b')
await redis.scard('key') // 返回 2

# sdiff

返回一个集合的全部成员,该集合是所有给定集合之间的差集。

不存在的 key 被视为空集。

接口形式

await redis.sdiff(key1: string, key2: string)
await redis.sdiff(key1: string, key2: string, key3: string)

入参说明

参数 说明 必填 说明
key1 集合的键
key2 集合的键

返回值

返回差集成员的列表。类型Array

示例

await redis.sadd('key1', 'a', 'b', 'c')
await redis.sadd('key2', 'c', 'd', 'f')
await redis.sdiff('key1', 'key2') // 返回 ['b', 'a']

# sdiffstore

这个命令的作用和 sdiff 类似,但它将结果保存到 destination 集合,而不是简单地返回结果集。

如果 destination 集合已经存在,则将其覆盖。

destination 可以是 key 本身。

接口形式

await redis.sdiffstore(destination: string, key1: string, key2: string)
await redis.sdiffstore(destination: string, key1: string, key2: string, key3: string)

入参说明

参数 说明 必填 说明
destination 需要存储的键名
key1 集合的键
key2 集合的键

返回值

返回结果集中的元素数量

示例

await redis.sadd('key1', 'a', 'b', 'c')
await redis.sadd('key2', 'c', 'd', 'f')
await redis.sdiff('destination', 'key1', 'key2') // 返回 2

# sinter

返回一个集合的全部成员,该集合是所有给定集合的交集。

不存在的 key 被视为空集。

当给定集合当中有一个空集时,结果也为空集(根据集合运算定律)。

接口形式

await redis.sinter(key1: string, key2: string)
await redis.sinter(key1: string, key2: string, key3: string)

入参说明

参数 说明 必填 说明
key1 集合的键
key2 集合的键

返回值

返回交集成员的列表,类型为Array

示例

await redis.sadd('key1', 'a', 'b', 'c')
await redis.sadd('key2', 'c', 'd', 'f')
await redis.sinter('key1', 'key2') // 返回 ['c']

# sinterstore

这个命令类似于 sinter 命令,但它将结果保存到 destination 集合,而不是简单地返回结果集。

如果 destination 集合已经存在,则将其覆盖。

destination 可以是 key 本身。

接口形式

await redis.sinterstore(destination: string, key1: string, key2: string)
await redis.sinterstore(destination: string, key1: string, key2: string, key3: string)

入参说明

参数 说明 必填 说明
destination 需要存储的键名
key1 集合的键
key2 集合的键

返回值

返回结果集中的成员数量。

示例

await redis.sadd('key1', 'a', 'b', 'c')
await redis.sadd('key2', 'c', 'd', 'f')
await redis.sinterstore('destination', 'key1', 'key2') // 返回 1

# sismember

判断 member 元素是否是集合 key 成员。

接口形式

await redis.sismember(key: string, member: string)

入参说明

参数 说明 必填 说明
key 集合的键
member 成员

返回值

member 元素是集合的成员返回 1,不是集合成员返回或者 key 不存在返回 0

示例

await redis.sadd('key', 'a', 'b', 'c')
await redis.sismember('key', 'a') // 返回 1

# smembers

返回集合 key 中的所有成员。

接口形式

await redis.smembers(key: string)

入参说明

参数 说明 必填 说明
key 集合的键

返回值

返回集合中的所有成员,类型Array 示例

await redis.sadd('key', 'a', 'b', 'c')
await redis.smembers('key', 'a') // 返回 ['a', 'b', 'c']

# smove

将 member 元素从 source 集合移动到 destination 集合。

接口形式

await redis.smove(source: string, destination: string, member: string)

入参说明

参数 说明 必填 说明
source 集合的键
destination 集合的键
member 要移动的成员

返回值

member 移除成功返回 1,member 不是 source 集合成员,并且没有任何操作对 destination 集合执行,那么返回 0 。

示例

await redis.sadd('source', 'a', 'b', 'c')
await redis.smove('source', 'destination', 'a') // 返回 1

# spop

移除并返回集合中的一个随机元素。

接口形式

await redis.spop(key: string)

入参说明

参数 说明 必填 说明
key 集合的键

返回值

返回被移除的随机元素。key 不存在或 key 是空集时,返回 null 。

示例

await redis.spop('key')

# srandmember

在集合 key 中随机获取一个或者 count 个元素

接口形式

await redis.srandmember(key: string)
await redis.srandmember(key: string, count: number)

入参说明

参数 说明 必填 说明
key 集合的键
count 返回几个元素

count说明

  • 如果 count 为正数,且小于集合基数,那么命令返回一个包含 count 个元素的数组,数组中的元素各不相同。如果 count 大于等于集合基数,那么返回整个集合。
  • 如果 count 为负数,那么命令返回一个数组,数组中的元素可能会重复出现多次,而数组的长度为 count 的绝对值。

返回值

只提供 key 参数时,返回一个元素;如果集合为空,返回 nil 。

如果提供了 count 参数,那么返回一个数组;如果集合为空,返回空数组。

示例

await redis.srandmember('key')

# srem

移除集合 key 中的一个或多个 member 元素,不存在的 member 元素会被忽略。

接口形式

await redis.srem(key: string, member: string)
await redis.srem(key: string, member1: string, member2: string)

入参说明

参数 说明 必填 说明
key 集合的键
member 成员

返回值

返回被成功移除的元素的数量,不包括被忽略的元素。

示例

await redis.srem('key', 'member')

# sunion

返回一个集合的全部成员,该集合是所有给定集合的并集。

接口形式

await redis.sunion(key: string)
await redis.sunion(key1: string, key2: string)

入参说明

参数 说明 必填 说明
key 集合的键
member 成员

返回值

返回并集成员的列表。

示例

await redis.sunion('key1', 'key2')

# sunionstore

这个命令类似于 sunion 命令,但它将结果保存到 destination 集合,而不是简单地返回结果集。

如果 destination 已经存在,则将其覆盖。

destination 可以是 key 本身。

接口形式

await redis.sunionstore(destination: string, key: string)
await redis.sunionstore(destination: string, key1: string, key2: string)

入参说明

参数 说明 必填 说明
destination 集合的键
key 集合的键

返回值

返回结果集中的元素数量。

示例

await redis.sunionstore('destination', 'key')

# sscan

迭代集合键中的元素。

接口形式

await redis.sscan(key: string, cursor: number)

入参说明

参数 说明 必填 说明
key 集合的键
cursor 游标

返回值

返回包含两个元素的数据 [下次迭代的新游标,0代表已结束, [所有被迭代的数据]]

示例

await redis.sscan('key', 0)

# 有序集合 SortedSet

# zadd

将一个或多个 member 元素及其 score 值加入到有序集 key 当中。

如果某个 member 已经是有序集的成员,那么更新这个 member 的 score 值,并通过重新插入这个 member 元素,来保证该 member 在正确的位置上。

接口形式

await redis.zadd(key: string, score: string, member: string)
await redis.zadd(key: string, score1: string, member1: string, score2: string, member2: string)

入参说明

参数 说明 必填 说明
key 集合的键
score 分数; 可以是整数值或双精度浮点数
member 元素

返回值

返回被成功添加的新成员的数量,不包括那些被更新的、已经存在的成员。

示例

await redis.zadd('key', '0', 'a')

# zcard

返回有序集 key 的基数。

接口形式

await redis.zcard(key: string)

入参说明

参数 说明 必填 说明
key 集合的键

返回值

当 key 存在且是有序集类型时,返回有序集的基数。 当 key 不存在时,返回 0 。

示例

await redis.zcard('key')

# zcount

返回有序集 key 中, score 值在 min 和 max 之间(默认包括 score 值等于 min 或 max )的成员的数量。

接口形式

await redis.zcount(key: string, min: number, max: number)

入参说明

参数 说明 必填 说明
key 集合的键
min 最小分数
max 最大分数

返回值

返回 score 值在 min 和 max 之间的成员的数量。

示例

await redis.zcount('key', 0, -1)

# zincrby

为有序集 key 的成员 member 的 score 值加上增量 increment 。

接口形式

await redis.zincrby(key: string, increment: number, member: number)

入参说明

参数 说明 必填 说明
key 集合的键
increment 增量分值
member 成员

返回值

返回 member 成员的新 score 值,以字符串形式表示。

示例

await redis.zincrby('key', 10, 'member')

# zinterstore

计算给定的一个或多个有序集的交集,其中给定 key 的数量必须以 numkeys 参数指定,并将该交集(结果集)储存到 destination 。

接口形式

await redis.zinterstore(destination: string, numkeys: number, key: string)
await redis.zinterstore(destination: string, numkeys: number, key1: string, key2: string)

入参说明

参数 说明 必填 说明
destination 集合的键
numkeys 集合数量
key 集合键名

返回值

返回保存到 destination 的结果集的基数。

示例

await redis.zinterstore('destination', 1, 'key')

# zrange

返回有序集 key 中,指定区间内的成员。

接口形式

await redis.zrange(key: string, start: number, stop: number)
await redis.zrange(key: string, start: number, stop: number, 'WITHSCORES')

入参说明

参数 说明 必填 说明
key 集合键名
start 起始位置
stop 结束位置

返回值

返回指定区间内,带有 score 值(可选)的有序集成员的列表,类型Array

示例

await redis.zrange('key', 0, -1)

# zrank

返回有序集 key 中成员 member 的排名。其中有序集成员按 score 值递增(从小到大)顺序排列。

接口形式

await redis.zrank(key: string, member: string)

入参说明

参数 说明 必填 说明
key 集合键名
member 成员

返回值

如果 member 是有序集 key 的成员,返回 member 的排名。

如果 member 不是有序集 key 的成员,返回 null 。

示例

await redis.zrank('key', 'member')

# zrem

移除有序集 key 中的一个或多个成员,不存在的成员将被忽略。

接口形式

await redis.zrem(key: string, member: string)
await redis.zrem(key: string, member1: string, member2: string)

入参说明

参数 说明 必填 说明
key 集合键名
member 成员

返回值

返回被成功移除的成员的数量,不包括被忽略的成员。

示例

await redis.zrem('key', 'member')

# zrevrange

返回有序集 key 中,指定区间内的成员,其中成员的位置按 score 值递减(从大到小)来排列。

接口形式

await redis.zrevrange(key: string, start: number, stop: number)
await redis.zrevrange(key: string, start: number, stop: number, 'WITHSCORES')

入参说明

参数 说明 必填 说明
key 集合键名
start 起始位置
stop 结束位置

返回值

返回指定区间内,带有 score 值(可选)的有序集成员的列表,类型Array。

示例

await redis.zrevrange('key', 0-1)

# zrevrangebyscore

通过字典区间返回有序集合的成员(具有分页功能)(集合按照分值从小到大排序)

接口形式

await redis.zrevrangebyscore(key: string, min: number, max: number)
await redis.zrevrangebyscore(key: string, min: number, max: number, withscores: string, limit: string, offset: number, count: number)

入参说明

参数 说明 必填 说明
key 集合键名
min 字典中排序位置较小的成员,必须以”[“开头,或者以”(“开头,可使用”-“代替
max 字典中排序位置较大的成员,必须以”[“开头,或者以”(“开头,可使用”+”代替
withscores WITHSCORES
limit 返回结果是否分页,指令中包含LIMIT后offset、count必须输入
offset 返回结果起始位置
count 返回结果数量

返回值

返回指定区间内,带有 score 值(可选)的有序集成员的列表。

示例

await redis.zrevrangebyscore('key', 1000200)

# zrevrank

返回有序集key中成员member的排名,其中有序集成员按score值从高到低排列。

排名从0开始,也就是说,score值最大的成员排名为0。

接口形式

await redis.zrevrank(key: string, member: string)

入参说明

参数 说明 必填 说明
key 集合键名
member 成员

返回值

如果 member 是有序集 key 的成员,返回 member 的排名。 如果 member 不是有序集 key 的成员,返回 null 。

示例

await redis.zrevrank('key', 'member')

# zscore

获取有序集 key 中,成员 member 的 score 值。

接口形式

await redis.zscore(key: string, member: string)

入参说明

参数 说明 必填 说明
key 集合键名
member 成员

返回值

返回member 成员的 score 值,以字符串形式表示,key 不存在或者 member 不是 key 的成员,返回 null 。

示例

await redis.zscore('key', 'member')

# zunionstore

计算给定的一个或多个有序集的并集,其中给定 key 的数量必须以 numkeys 参数指定,并将该并集(结果集)储存到 destination 。

接口形式

await redis.zunionstore(destination: string, numkeys: string, key: string)
await redis.zunionstore(destination: string, numkeys: string, key1: string, key2: string)

入参说明

参数 说明 必填 说明
destination 集合键名
numkeys 集合数量
key 集合键名

返回值

返回保存到 destination 的结果集的基数。

示例

await redis.zunionstore('destination', 1, 'key')

# zscan

迭代有序集合中的元素(包括元素成员和元素分值)

接口形式

await redis.zscan(key: string, cursor: string)

入参说明

参数 说明 必填 说明
key 集合键名
cursor 游标

返回值

返回包含两个元素的数据 [下次迭代的新游标,0代表已结束, [所有被迭代的数据]]

示例

await redis.zscan('key', 0)

# 基数统计 HyperLogLog

# pfadd

添加指定元素到 HyperLogLog 中。

接口形式

await redis.pfadd(key: string, element1: string, element2: string)

入参说明

参数 说明 必填 说明
key 键名
element1 元素1
element2 元素2

返回值

如果至少有个元素被添加返回 1, 否则返回 0。

示例

await redis.pfadd('key', 'element1', 'element2')

# pfcount

返回给定 HyperLogLog 的基数估算值。

接口形式

await redis.pfcount(key: string)

入参说明

参数 说明 必填 说明
key 键名

返回值

返回给定 HyperLogLog 的基数值,如果多个 HyperLogLog 则返回基数估值之和。

示例

await redis.pfadd('key', 'a', 'b', 'c', 'b', 'c')
await redis.pfcount('key') // 返回 3

# pfmerge

将多个 HyperLogLog 合并为一个 HyperLogLog

接口形式

await redis.pfmerge(destkey: string, sourcekey: string)
await redis.pfmerge(destkey: string, sourcekey1: string, sourceKey2: string)

入参说明

参数 说明 必填 说明
destKey 目标键名
sourceKey 键名

返回值

成功返回 OK

示例

await redis.pfadd('dest', 'a', 'b', 'c', 'b', 'c')
await redis.pfadd('source', 'a', 'b', 'c', 'b', 'c')

await redis.pfmerge('key', 'dest''source')

await redis.pfcount('key') // 返回 3

# 事务 Transaction

# multi

将多条指令作为一个原子执行。

示例

const multi = redis.multi()
multi.set('key1', 'value1')
multi.set('key2', 'value2')
multi.set('key3', 'value3')
multi.set('key4', 'value4')
const res = await multi.exec()

// 如果执行成功
res = ['OK','OK','OK','OK']

// 某个操作出现错误
res = ['OK','OK', error, 'OK'] // error为 Error对象的实例

# exec

执行所有事务块内的命令。

接口形式

await redis.exec()

# discard

取消事务,放弃执行事务块内的所有命令。

接口形式

await redis.discard()

# 位图 BitMap

# setbit

针对key存储的字符串值,设置或清除指定偏移量offset上的位(bit)

位的设置或清除取决于value值,即1或0

接口形式

await redis.setbit(key: string, offset: number, value: number)

入参说明

参数 说明 必填 说明
key 键名
offset
value 位的值;0或1

返回值

返回偏移量offset位置的原始值

示例

await redis.setbit('key', 0, 1)

# getbit

返回key对应的字符串,offset 位置的位(bit)

接口形式

await redis.getbit(key: string, offset: number)

入参说明

参数 说明 必填 说明
key 键名
offset

返回值

返回偏移量offset位置的bit值, key 不存在时或当offset大于值的长度时返回 0

示例

await redis.setbit('key', 1, 1)
await redis.getbit('key', 1) // 返回 1

# bitcount

统计给定字符串中,bit为1的数量

接口形式

await redis.bitcount(key: string, start: number, end: number)

入参说明

参数 说明 必填 说明
key 键名
start 开始位
end 结束位

返回值

返回bit值为1的数量,如果key不存在,返回0

示例

await redis.setbit('key', 1, 1)
await redis.bitcount('key', 0-1) // 返回 1

# bitop

对一个或多个保存二进制位的字符串key进行位元操作,并将结果保存到destkey上。

  • operation可以是AND、OR、NOT、XOR这四种操作中的任意一种。
  • bitop AND destkey key [key ...] ,对一个或多个key求逻辑并,并将结果保存到destkey
  • bitop OR destkey key [key ...] ,对一个或多个key求逻辑或,并将结果保存到destkey
  • bitop XOR destkey key [key ...] ,对一个或多个key求逻辑异或,并将结果保存到destkey
  • bitop NOT destkey key ,对给定key求逻辑非,并将结果保存到destkey
  • 除了NOT操作外,其他操作都可以接受一个或多个key作为输入
  • 当bitop处理不同长度的字符串时,较短的那个字符串所缺少的部分会被看做0
  • 空的key也被看作是包含0的字符串序列

接口形式

await redis.bitop(operation: string, destkey: string, key: string)
await redis.bitop(operation: string, destkey: string, key1: string, key2: string)

入参说明

参数 说明 必填
operation 操作; AND、OR、NOT、XOR 其中一个
destkey 键名
key 键名

返回值

返回保存到 destkey 的字符串的长度(和参数给定的key中最长的字符串长度相等)

示例

await redis.bitop('AND', 'andkey', 'key1', 'key2')

# bitpos

返回字符串中,从左到右,第一个比特值为bit(0或1)的偏移量

接口形式

await redis.bitpos(key: string, value: string, start: number, end: number)

入参说明

参数 说明 必填
key 键名
value 值;0或1
start 开始字节,注意1字节=8位
end 结束字节,注意1字节=8位

返回值

返回第一个比特值为指定bit(0或1)的偏移量

示例

await redis.set('key', 'a')
await redis.bitpos('key', 1) // 返回 1

# 执行lua脚本

接口形式

await redis.eval(String script, Number argsCount, String key1, String key2 , ... , String arg1, String arg2, ...)

参数说明

参数 类型 必填 说明
script String lua脚本内容
argsCount Number 参数个数,没有参数则传0
key1、key2... String 从eval的第三个参数开始算起,表示在脚本中所用到的那些 Redis 键(key),这些键名参数可以在 Lua 中通过全局变量 KEYS 数组,用 1 为基址的形式访问( KEYS[1] , KEYS[2] ,以此类推)
arg1、agr2... Number 附加参数,在 Lua 中通过全局变量 ARGV 数组访问,访问的形式和 KEYS 变量类似( ARGV[1] 、 ARGV[2] ,诸如此类)

某些情况下需要使用复杂的原子操作以避免高并发下数据修改混乱的问题,这种需求一般可通过执行lua脚本实现。如以下示例,判断redis中不存在key-test时,将其值设置为1;存在且小于10时进行加一操作;大于等于10时不进行操作直接返回。

{0, 1}是lua内的table类型,返回到云函数时会转为数组对应的值为[0, 1]

const [operationType, currentValue] = await redis.eval(`local val = redis.call('get','key-test')
    local valNum = tonumber(val)
    if (val == nil) then
        redis.call('set', 'key-test', 1)
        return {0, 1}
    end
    if (valNum < 10) then
        redis.call('incrby', 'key-test', 1)
        return {1, valNum + 1}
    else
        return {2, valNum}
    end
    `, 0)

# quit

断开redis连接,会等待redis请求执行完成后才断开连接

接口形式

await redis.quit()

入参说明

返回值

调用成功后返回OK字符串

注意

  • 断开连接后使用uniCloud.redis()返回的redis实例的连接将不再可用,再下次用到redis方法时需要重新调用uniCloud.redis()方法建立连接

# FAQ

  • 云函数与redis的连接

    和传统开发不同,云函数实例之间是不互通的,也就是说每个使用redis的函数实例都会和redis建立一个连接,在云函数实例复用时此连接也会复用。

# 最佳实践

# 高并发下抢购/秒杀/防超卖示例

可以利用redis的原子操作保证在高并发下不会超卖,以下为一个简单示例

在抢购活动开始前可以将商品库存同步到redis内,实际业务中可以通过提前访问一次抢购页面加载所有商品来实现。下面通过一个简单的演示代码来实现

const redis = uniCloud.redis()

const goodsList = [{ // 商品库存信息
  id: 'g1',
  stock: 100
}, {
  id: 'g2',
  stock: 200
}, {
  id: 'g3',
  stock: 400
}]

const stockKeyPrefix = 'stock_'

async function init() { // 抢购活动开始前在redis初始化库存
  for (let i = 0; i < goodsList.length; i++) {
    const {
      id,
      stock
    } = goodsList[i];
    await redis.set(`${stockKeyPrefix}${id}`, stock)
  }
}

init()

抢购的逻辑见以下代码

exports.main = async function (event, context) {
	// 一些判断抢购活动是否开始/结束的逻辑,未开始直接返回
	const cart = [{ // 购物车信息,此处演示购物车抢购的例子,如果抢购每次下单只能购买一件商品,可以适当调整代码
		id: 'g1', // 商品id
		amount: parseInt(Math.random() * 5 + 5) // 购买数量
	}, {
		id: 'g2',
		amount: parseInt(Math.random() * 5 + 5)
	}]

	/**
	* 使用redis的eval方法执行lua脚本判断各个商品库存能否满足购物车购买的数量
	* 如果不满足,返回库存不足的商品id
	* 如果满足,返回一个空数组
	*
	* eval为原子操作可以在高并发下保证不出错
	**/
	let checkAndSetStock = `
	local cart = {${cart.map(item => `{id='${item.id}',amount=${item.amount}}`).join(',')}}
	local amountList = redis.call('mget',${cart.map(item => `'${stockKeyPrefix}${item.id}'`).join(',')})
	local invalidGoods = {}
	for i,cartItem in ipairs(cart) do
		if (cartItem['amount'] > tonumber(amountList[i])) then
		  table.insert(invalidGoods, cartItem['id'])
		  break
		end
	end
	if(#invalidGoods > 0) then
		return invalidGoods
	end
	for i,cartItem in ipairs(cart) do
	redis.call('decrby', '${stockKeyPrefix}'..cartItem['id'], cartItem['amount'])
	end
	return invalidGoods
	`
	const invalidGoods = await redis.eval(checkAndSetStock, 0)
	if (invalidGoods.length > 0) {
	    return {
	        code: -1,
	        message: `以下商品库存不足:${invalidGoods.join(',')}`, // 此处为简化演示代码直接返回商品id给客户端
	        invalidGoods // 返回库存不足的商品列表
	        }
	        }
	        // redis库存已扣除,将库存同步到数据库。为用户创建订单
	        // 此处代码省略...
	        return {
	            code: 0,
	            message: '下单成功,跳转订单页面'
	            }
	            }
	            ```