Reids 数据类型指的是 value 的类型，key 都是字符串
redis-server:启动 redis 服务
redis-cli:进入 redis 交互式终端
常用的 key 的操作
redis 的命令和参数不区分大小写 ，key 和 value 区分
1、查看当前库所有的 key
2、判断某个 key 是否存在
3、查看 key 是什么类型
4、删除指定的 key
5、非阻塞删除，仅将 key 从 keyspace 元数据中删除,真正的删除会在后续异步中操作
6、查看 key 还有多少秒到期,-1 表示永不过期，-2 表示已经过去,未过期则显示对应的秒数
7、设置过期时间-秒
8、将当前数据库的 key 移动到指定的库中，0~15，redis 默认 16 个库，默认使用的 0 号库
9、切换数据库，0-15，默认是 0
10、查看当前数据库的 key 的数量
11、清空当前库
12、清空全部库
13、获取指定类型的帮助信息
字符串 String
string 是 redis 最基本的类型，一个 key 对应一个 value，一个 value 最多可以是 512M,string 类型是二进制安全的，可以包含任何数据，包括 jpg 图片或者序列化对象
基本使用
使用set设置 string 类型的 key 和 value
set key value [NX|XX] [GET] [EX seconds|PX milliseconds|EXAT unix-time-seconds|PXAT unix-time-milliseconds|KEEPTTL]
复制代码
除了 key 和 value，其他为可选参数
1、[NX|XX]
# NX:键不存在的时候设置键和值127.0.0.1:6379> set k1 v1 nxOK127.0.0.1:6379> set k1 v1 nx(nil)
复制代码
# XX:键存在的时候设置值127.0.0.1:6379> set k1 val1 xxOK127.0.0.1:6379> set k2 val1 xx(nil)
复制代码
2、[GET]
# 先返回旧的值，然后设置新的值,如果key不存在，则返回的时候是nil127.0.0.1:6379> set k1 v1OK127.0.0.1:6379> set k1 v2 get"v1"127.0.0.1:6379> get k1"v2"
复制代码
3、[EX seconds|PX milliseconds|EXAT unix-time-seconds|PXAT unix-time-milliseconds|KEEPTTL]
# EX seconds 以秒为单位设置过期时间set k1 v1 ex 10
复制代码
# PX milliseconds:以毫秒为单位设置过期时间set k1 v1 px 10000
复制代码
# EXAT timestamp:设置以秒为单位的UNIX时间戳所对应的时间为过期时间set k1 v1 exat 1734686421 #秒级的过期时间戳
复制代码
# PXAT milliseconds-timestamp:设置以毫秒为单位的UNIX时间戳所对应的时间为过期时间set k1 v1 pxat 1734686421000 #毫秒级的过期时间戳
复制代码
# KEEPTTL:保留设置前指定键的生存时间# 一个已存在的key只要进行set，就会覆盖掉之前设置的过期时间，KEEPTTL可以继续继承之前的过期时间127.0.0.1:6379> set k1 v1 ex 100OK127.0.0.1:6379> ttl k1(integer) 98127.0.0.1:6379> set k1 v2 keepttlOK127.0.0.1:6379> ttl k1(integer) 83
复制代码
批量操作
1、MSET批量进行 key-value 的设置
127.0.0.1:6379> mset k1 v1 k2 v2 k3 v3OK
复制代码
2、MGET 批量进行获取操作
127.0.0.1:6379> mget k1 k2 k31) "v1"2) "v2"3) "v3"
复制代码
3、MSETNX:批量进行 key-value 的设置，只有 key 都不存在时数据会设置成功
127.0.0.1:6379> mset k1 v1 k2 v2OK127.0.0.1:6379> msetnx k2 v2 k3 v3(integer) 0127.0.0.1:6379> msetnx k3 v3 k4 v4(integer) 1
复制代码
获取和修改指定区间范围内的值
1、getrange key start end：获取指定 key 的值的指定下标范围的数据，如果下标范围是 0 和-1，就是获取全部
127.0.0.1:6379> set k1 k123456OK127.0.0.1:6379> getrange k1 0 3"k123"
复制代码
2、setrange key offset value:用指定的字符串覆盖指定 key 中字符串值的一部分，`offset 表示从哪个位置开始覆盖
127.0.0.1:6379> set k1 v12345678OK127.0.0.1:6379> setrange k1 3 a # 根据新的value覆盖指定value位置的数据(integer) 9127.0.0.1:6379> get k1"v12a45678"127.0.0.1:6379> setrange k1 3 hhhhhhhhh # 根据新的value覆盖指定value位置的数据(integer) 12127.0.0.1:6379> get k1"v12hhhhhhhhh"
复制代码
数值增减
只有 value 是纯数字的时候才可以操作增减
1、INCR:自增，每次自增 1
127.0.0.1:6379> set k1 10OK127.0.0.1:6379> incr k1(integer) 11127.0.0.1:6379> incr k1(integer) 12127.0.0.1:6379> get k1"12"
复制代码
2、incrby key increment：增加指定的数值
127.0.0.1:6379> set k1 10OK127.0.0.1:6379> incrby k1 100 # 给k1加100(integer) 110127.0.0.1:6379> get k1"110"
复制代码
3、DECR:自减
127.0.0.1:6379> set k1 10OK127.0.0.1:6379> decr k1(integer) 9
复制代码
4、DECRBY key decrement：减少指定的数值
127.0.0.1:6379> set k1 10OK127.0.0.1:6379> decrby k1 5(integer) 5
复制代码
获取字符串长度和内容追加
STRLEN获取字符串长度，APPEND用于在字符串后面追加数
127.0.0.1:6379> set k1 a12345OK127.0.0.1:6379> strlen k1 #获取长度(integer) 6127.0.0.1:6379> append k1 6 #追加(integer) 7127.0.0.1:6379> get k1"a123456"
复制代码
setnx 和 setex
下面两个命令的重要使用场景就是分布式锁的实现，这里只有基本使用，不涉及分布式锁的实现
1、setnx key value：当 key 不存在的时候，设置 key-value，相当于 set 后面设置 nx 选项参数
2、setex key seconds value:设置键值对并且同时设置过期时间的命令，相当于 set 后面设置 ex 选项参数
getset
先获取旧值，再设置新值，相当于 set 命令后加 get 选项参数
127.0.0.1:6379> set k1 100OK127.0.0.1:6379> getset k1 aaa"100"127.0.0.1:6379> get k1"aaa"
复制代码
列表 List
列表是在简单的字符串列表，按照插入顺序排序，可以添加元素到列表头部或者尾部，最多可以保存 2^32-1 个元素(超 40 亿)，单 key 多 value，且 value 可以重复
1、lpush:从左侧插入元素
2、rpush：从右侧插入元素
3、lrange key start stop:从左侧开始根据下标取值
4、lpop：弹出最左侧的元素,弹出的元素从原列表消失
5、rpop:弹出最右侧的元素,弹出的元素从原列表消失
6、lindex key index:按照索引下标(从左到右)根据获取元素
7、llen:获取列表中元素的个数
8、lrem key count element：从左到右删除对应列表中指定数量的指定 value 的元素
127.0.0.1:6379> lpush list1 v1 v2 v1 v3 v4 v5(integer) 6127.0.0.1:6379> lrem list1 2 v1 #从左到右，删除元素是v1的两个值(integer) 2
复制代码
127.0.0.1:6379> lpush list2 v1 v1 v1 v2 v3(integer) 5127.0.0.1:6379> lrem list2 0 v1 # 0 代表删除元全部指定的值(integer) 3
复制代码
9、ltrim key start stop：截取指定范围的值后再赋值原列表
127.0.0.1:6379> rpush list3 1 2 3 4 5(integer) 5127.0.0.1:6379> ltrim list3 0 2OK127.0.0.1:6379> lrange list3 0 -11) "1"2) "2"3) "3"
复制代码
10、rpoplpush source destination:移除列表(source)最后一个元素，将该元素添加到另一个列表(destination)并返回
127.0.0.1:6379> lpush i1 1 2 3 4 5 6 7(integer) 7127.0.0.1:6379> lpush i2 a b c(integer) 3127.0.0.1:6379> rpoplpush i1 i2"1"127.0.0.1:6379> lrange i1 0 -11) "7"2) "6"3) "5"4) "4"5) "3"6) "2"127.0.0.1:6379> lrange i2 0 -11) "1"2) "c"3) "b"4) "a"
复制代码
11、lset key index element：将指定数组集合的下标位置值替换成新值
127.0.0.1:6379> lrange i1 0 -11) "7"2) "6"3) "5"4) "4"5) "3"6) "2"127.0.0.1:6379> lset i1 3 nOK127.0.0.1:6379> lrange i1 0 -11) "7"2) "6"3) "5"4) "n"5) "3"6) "2"
复制代码
12、linsert key BEFORE|AFTER pivot element:从左侧开始在指定下标之前/之后插入新的值
127.0.0.1:6379> lrange list 0 -11) "5"2) "4"3) "3"4) "2"5) "1"127.0.0.1:6379> linsert list before 2 a #从左侧开始，在指定下标之前插入新的值(integer) 6127.0.0.1:6379> lrange list 0 -11) "5"2) "4"3) "3"4) "a"5) "2"6) "1"127.0.0.1:6379> linsert list after 2 b(integer) 7127.0.0.1:6379> lrange list 0 -1 # 从左侧开始，在指定下标之后插入新的值1) "5"2) "4"3) "3"4) "a"5) "2"6) "b"7) "1"
复制代码
哈希表 Hash
hash 是一个 string 类型的 field(字段)和 value(值)的映射表，kv 模式不变，但是 V 是一个键值对，特别适用于存储对象，每个 hash 可以存储 2^32-1 个元素(超 40 亿)键值对
127.0.0.1:6379> hset user:1 id 1 name 23 age 26 # 设置key为user:1的哈希结构(integer) 3127.0.0.1:6379> hget user:1 id # 获取key为user:1 的 里面id字段的值"1"127.0.0.1:6379> hget user:1 name # 获取key为user:1 的 里面name字段的值"23"
复制代码
# 当前版本hmset和hset功能一样 # 老版本应该是hset设置value只能一次设置一个字段，hmset设置多个字段127.0.0.1:6379> hmset user:2 name 2 age 3OK127.0.0.1:6379> hmget user:2 name age # 批量获取1) "2"2) "3"
复制代码
127.0.0.1:6379> hgetall user:1 #获取指定key的全部字段和值1) "id"2) "1"3) "name"4) "23"5) "age"6) "26"127.0.0.1:6379> hdel user:1 name # 删除指定key里面的指定数据(integer) 1
复制代码
127.0.0.1:6379> hexists user:1 id # 判断指定key里面某个字段是否存在(integer) 1127.0.0.1:6379> hkeys user:1 # 获取指定key所有字段1) "id"2) "age"127.0.0.1:6379> hvalues user:1 # 获取指定key所有字段的值1) "1"2) "26"
复制代码
127.0.0.1:6379> hset user:5 age 20 score 99.5(integer) 2127.0.0.1:6379> hincrby user:5 age 2 # 对整数的值+2(integer) 22127.0.0.1:6379> hincrbyfloat user:5 score 0.5 # 对小数的值进行增加0.5"100"127.0.0.1:6379> hsetnx user5 k1 v1 # 当指定key里面指定字段不存在的时候生效(integer) 1
复制代码
集合 Set
Set 是 String 类型的无序集合。集合成员是唯一的，这就意味着集合中不能出现重复的数据，集合对象的编码可以是 intset 或者 hashtable,集合是通过哈希表实现的，所以添加，删除，查找的复杂度都是 O(1),集合中最大的成员数为 2^32 - 1 (4294967295, 每个集合可存储 40 多亿个成员)，单 key 多 value，且 value 不能重复
127.0.0.1:6379> sadd set1 1 2 3 2 4 5 6 # 向key为set1的集合添加对应元素，如果有重复的值不会添加(integer) 6127.0.0.1:6379> SMEMBERS set1 # 遍历集合中的所有元素1) "1"2) "2"3) "3"4) "4"5) "5"6) "6"
复制代码
127.0.0.1:6379> sismember set1 3 # 查看集合中是否存在3 存在是1 不存在是0(integer) 1127.0.0.1:6379> sismember set1 10(integer) 0
复制代码
127.0.0.1:6379> srem set1 2 # 删除集合里值是2的元素(integer) 1
复制代码
127.0.0.1:6379> scard set1 # 获取集合元素个数(integer) 5
复制代码
127.0.0.1:6379> srandmember set1 2 # 从集合里随机弹出2个元素，元素不会删除1) "5"2) "1"127.0.0.1:6379> spop set1 2 # 从集合里随机弹出2个元素，元素会删除1) "4"2) "5"
复制代码
127.0.0.1:6379> sadd set2 1 2 3 4 5 6(integer) 6127.0.0.1:6379> sadd set3 7 8 9(integer) 3127.0.0.1:6379> smove set2 set3 6 # 将set2里面值是6的元素赋值给set3(integer) 1127.0.0.1:6379> smembers set31) "6"2) "7"3) "8"4) "9"127.0.0.1:6379> smembers set21) "1"2) "2"3) "3"4) "4"5) "5"
复制代码
#差集运算-属于A集合但是不属于B集合的元素构成的集合127.0.0.1:6379> sadd set3 1 2 3 a b(integer) 5127.0.0.1:6379> sadd set4 2 3 4 b c(integer) 5127.0.0.1:6379> sdiff set3 set41) "1"2) "a"
复制代码
#并集运算-属于A或者属于B的元素构成的集合127.0.0.1:6379> sunion set3 set41) "1"2) "2"3) "3"4) "a"5) "b"6) "4"7) "c"
复制代码
#交集运算-属于A同时也属于B的共同拥有的元素构成的集合127.0.0.1:6379> sadd set1 1 2 3 a b c(integer) 6127.0.0.1:6379> sadd set2 2 3 4 b c d(integer) 6127.0.0.1:6379> sinter set1 set21) "2"2) "3"3) "b"4) "c"
复制代码
#交集运算-不返回结果集,返回结果的基数,返回由所有给定集合的交集产生的集合的基数# 两个key set1 和set2 交集去重后的结果数127.0.0.1:6379> sintercard 2 set1 set2(integer) 4
复制代码
有序集合 Zset
zset 和 set 一样也是 string 类型元素的集合,且不允许重复的成员,不同的是每个元素都会关联一个 double 类型的分数，redis 正是通过分数来为集合中的成员进行从小到大的排序,zset 的成员是唯一的,但分数(score)却可以重复,zset 集合是通过哈希表实现的，所以添加，删除，查找的复杂度都是 O(1)。 集合中最大的成员数为 2^32 - 1
zadd key [NX|XX] [GT|LT] [CH] [INCR] score member [score member ...]
127.0.0.1:6379> zadd zset1 100 k1 200 k2 300 k3 # zadd key 分数 key 分数 key(integer) 3127.0.0.1:6379> zrange zset1 0 -1 # 不带分数遍历所有元素1) "k1"2) "k2"3) "k3"127.0.0.1:6379> zrange zset1 0 -1 withscores #带分数遍历所有元素1) "k1"2) "100"3) "k2"4) "200"5) "k3"6) "300"
复制代码
zrevrange key start stop [WITHSCORES]
# 反转集合，按照元素分数从大到小的顺序返回索引从start到stop之间的所有元素127.0.0.1:6379> zrevrange zset1 0 -1 withscores1) "k3"2) "300"3) "k2"4) "200"5) "k1"6) "100"127.0.0.1:6379> zrevrange zset1 0 -11) "k3"2) "k2"3) "k1"
复制代码
zrangebyscore key min max [WITHSCORES] [LIMIT offset count]
#获取指定分数范围的元素127.0.0.1:6379> zrangebyscore zset1 100 200 withscores1) "k1"2) "100"3) "k2"4) "200"127.0.0.1:6379> zrangebyscore zset1 (100 200 withscores # (表示不包含，相当于大于100 小于等于2001) "k2"2) "200"127.0.0.1:6379> zrangebyscore zset1 (100 300 withscores limit 0 1 #limit限制范围1) "k2"2) "200"
复制代码
127.0.0.1:6379> zscore zset1 k1 #获取指定元素的分数"100
复制代码
127.0.0.1:6379> zcard zset1 # 获取元素的数量(integer) 3
复制代码
# zrem key member [member ...]127.0.0.1:6379> zrem zset1 k1 #删除指定元素(integer) 1
复制代码
# zincrby key increment member 增加某个元素的分数127.0.0.1:6379> zincrby zset1 3 k2"203"
复制代码
# zcount key min max 获取指定分数范围内的元素个数127.0.0.1:6379> zcount zset1 100 300(integer) 2
复制代码
# zmpop numkeys key [key ...] MIN|MAX [COUNT count]# 从键名列表中的第一个和非空排序集中弹出一个或多个元素，成员分数对127.0.0.1:6379> zadd set1 100 one 200 two 300 three(integer) 3# key的数量 1个，从set1中，弹出最小的一个(也可以是多个),弹出后从zset移除127.0.0.1:6379> zmpop 1 set1 min count 11) "set1"2) 1) 1) "one" 2) "100" # key的数量 1个，从set1中，弹出最大的一个，弹出后从zset移除127.0.0.1:6379> zmpop 1 set1 max count 11) "set1"2) 1) 1) "three" 2) "300"
复制代码
# zrank key member [WITHSCORE] 通过元素名获取下标值127.0.0.1:6379> zrank zset1 k3(integer) 1
复制代码
# zrevrank key member [WITHSCORE] 通过元素名逆序获得下标值127.0.0.1:6379> zrevrank zset1 k3(integer) 0
复制代码
位图 bitmap
由 0 和 1 状态表现的二进制位的 bit 数组
# setbit key offset value 设置位图对应偏移量位置的值(只能是0和1)127.0.0.1:6379> setbit k1 0 1(integer) 0127.0.0.1:6379> setbit k1 1 1(integer) 0127.0.0.1:6379> setbit k1 2 0(integer) 0127.0.0.1:6379> type k1 # bitmap的底层是string类型string
复制代码
# getbit key offset 获取指定偏移量的值127.0.0.1:6379> getbit k1 0(integer) 1
复制代码
# 统计占用多少字节数，不是字符串长度而是占据几个字节，超过8位后自己按照8位一组一byte再扩容127.0.0.1:6379> strlen k1 (integer) 1
复制代码
# bitcount key [start end [BYTE|BIT]] 全部key里包含1的有多少个127.0.0.1:6379> bitcount u1 0 -1(integer) 2
复制代码
# bitop AND|OR|XOR|NOT destkey key [key ...] # 可以对一个或多个二进制位序列进行位运算操作。这些位运算包括AND、OR、XOR（异或）和NOT
# 偏移量对应用户id127.0.0.1:6379> setbit login_one 1 1(integer) 0127.0.0.1:6379> setbit login_one 2 1(integer) 0127.0.0.1:6379> setbit login_one 3 1(integer) 0127.0.0.1:6379> setbit login_one 4 0127.0.0.1:6379> setbit login_t 1 1(integer) 0127.0.0.1:6379> setbit login_t 2 0(integer) 0127.0.0.1:6379> setbit login_t 3 1(integer) 0127.0.0.1:6379># 筛选两天都登录的用户127.0.0.1:6379> bitop AND login_sum login_one login_t # login_sum是计算后的数据位图(integer) 1127.0.0.1:6379> getbit login_sum 1 # 查看用户1是否两天都登录(integer) 1127.0.0.1:6379> getbit login_sum 2 # 查看用户2是否两天都登录(integer) 0
复制代码
基数统计 HyperLogLog
HyperLogLog 是用来做基数统计的算法，HyperLogLog 的优点是，在输入元素的数量或者体积非常非常大时，计算基数所需的空间总是固定且是很小的。
在 Redis 里面，每个 HyperLogLog 键只需要花费 12 KB 内存，就可以计算接近 2^64 个不同元素的基 数。这和计算基数时，元素越多耗费内存就越多的集合形成鲜明对比。
因为 HyperLogLog 只会根据输入元素来计算基数，而不会储存输入元素本身，所以 HyperLogLog 不能像集合那样，返回输入的各个元素
HyperLogLog 的优点是，在输入元素的数量或者体积非常非常大时，计算基数所需的空间总是固定的、并且是很小的。在 Redis 里面，每个 HyperLogLog 键只需要花费 12KB 内存，就可以计算接近 2^64 个不同元素的基数。这和计算基数时，元素越多耗费内存就越多的集合形成鲜明对比。但是，因为 HyperLogLog 只会根据输入元素来计算基数，而不会储存输入元素本身，所以 HyperLogLog 不能像集合那样，返回输入的各个元素
127.0.0.1:6379> pfadd h1101 1 2 2 3 4 5 6 7 # 添加元素(integer) 1127.0.0.1:6379> pfadd h1102 3 4 5 6 7 8 9 10(integer) 1127.0.0.1:6379> pfcount h1101 # 去重后的元素个数(integer) 7127.0.0.1:6379> pfmerge result h1101 h1102 #将多个HyperLogLog合并成一个OK127.0.0.1:6379> pfcount result # 合并去重后的元素个数(integer) 10
复制代码
地理空间 GEO
主要用于存储地理位置信息，并对存储的信息进行操作，包括添加地理位置的坐标、获取地理位置的坐标、计算两个位置之间的距离，根据用户给定的经纬度坐标来获取指定范围内的地理位置集合
# geoadd key [NX|XX] [CH] longitude latitude member [longitude latitude member ...]# geoadd用于存储指定的地理空间位置，可以存储一个或多个经度(longitude)纬度(latitude) 位置名称(member)127.0.0.1:6379> geoadd beijing 116.333585 0.008944 "清华" 116.317547 39.99887 "北大"(integer) 2
复制代码
127.0.0.1:6379> type beijing # 底层是zset结构zset127.0.0.1:6379> zrange beijing 0 -1 #遍历所有1) "\xe6\xb8\x85\xe5\x8d\x8e"2) "\xe5\x8c\x97\xe5\xa4\xa7" # 中文乱码问题:启动的时候 使用 redis-cli -a 111111 --raw解决中文乱码问题127.0.0.1:6379> zrange beijing 0 -1 withscores清华3976420988276928北大4069880723579868
复制代码
# geopos key [member [member ...]] 返回经纬度坐标127.0.0.1:6379> geopos beijing "清华" "北大"116.333587467670440670.00894376361072347116.3175478577613830639.99886942521209932127.0.0.1:6379>
复制代码
# geodist key member1 member2 [M | KM | FT | MI ] 计算两个位置之间的距离127.0.0.1:6379> geodist beijing "清华" "北大"4447931.7663 # 默认是米，根据选项参数设定单位
复制代码
# georadius key longitude latitude radius M|KM|FT|MI [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count [ANY]] [ASC|DESC] [STORE key|STOREDIST key]
# 以给定的经纬度为中心，返回与中心的距离不超过给定最大距离的所有元素位置，WITHDIST: 在返回位置元素的同时， 将位置元素与中心之间的距离也一并返回。 距离的单位和用户给定的范围单位保持一致。 WITHCOORD: 将位置元素的经度和维度也一并返回。 WITHHASH:以 52 位有符号整数的形式， 返回位置元素经过原始 geohash 编码的有序集合分值。 这个选项主要用于底层应用或者调试，实际中的作用并不大 COUNT 限定返回的记录数
127.0.0.1:6379> georadius beijing 116.319769 39.976546 100 km withcoord withhash count 10 desc北大4069880723579868116.3175478577613830639.99886942521209932
复制代码
# georadiusbymember key member radius M|KM|FT|MI [WITHCOORD] [WITHDIST] [WITHHASH] [COUNT count [ANY]] [ASC|DESC] [STORE key|STOREDIST key]# 和georadius类似，区别是不需要提供具体的经纬度，而是提供成员127.0.0.1:6379> georadiusbymember beijing "清华" 100 km withcoord withhash count 10 desc清华3976420988276928116.333587467670440670.00894376361072347
复制代码
流 Stream
基本理论
主要用于消息队列（MQ，Message Queue），Redis 本身是有一个 Redis 发布订阅 (pub/sub) 来实现消息队列的功能，但它有个缺点就是消息无法持久化，如果出现网络断开、Redis 宕机等，消息就会被丢弃。
简单来说发布订阅 (pub/sub) 可以分发消息，但无法记录历史消息。而 Redis Stream 提供了消息的持久化和主备复制功能，可以让任何客户端访问任何时刻的数据，并且能记住每一个客户端的访问位置，还能保证消息不丢失
Redis5.0 版本新增了一个更强大的数据结构---Strea,Stream 流就是 Redis 版的 MQ 消息中间件+阻塞队列，支持消息的持久化，支持自动生成全局唯一 id，支持 ack 确认消息的模式、消防组模式等等，让消息队列更加稳定和可靠
队列相关
xadd key [NOMKSTREAM][MAXLEN|MINID [=|~] threshold[LIMIT count]] *|id field value [field value ...]
# xadd用于向Stream队列中添加消息，如果队列不存在，则会新建一个Stream队列# 添加消息到队列末尾,消息id必须要比上个id大# 默认用星号（*）表示自动生成id127.0.0.1:6379> xadd mystream * k1 v1 k2 v21735024146774-0 # 生成的消息id 毫秒级时间戳-该毫秒内产生的第1条消息
复制代码
xrange key start end [COUNT count]
# 获取消息列表，可以指定范围，忽略删除的消息# start是开始知，-代表最小值，end是结束值，+代表最大值，count表示最多获取多少个值127.0.0.1:6379> xrange mystream - +1735024146774-0k1v1k2v21735024367169-0k1v1k2v21735024368361-0k1v1k2v21735024370474-0k1v1k2v2
复制代码
xrevrange key end start [COUNT count]
# 按反转顺数输出127.0.0.1:6379> xrevrange mystream + 11735024370474-0k1v1k2v21735024368361-0k1v1k2v21735024367169-0k1v1k2v21735024146774-0k1v1k2v2
复制代码
xdel key id [id ...]
# 删除指定消息127.0.0.1:6379> xdel mystream 1735024146774-01
复制代码
xlen key
# 获取消息队列长度127.0.0.1:6379> xlen mystream3
复制代码
xtrim key MAXLEN|MINID [=|~] threshold [LIMIT count]
# 对Stream的长度进行截图，如果超长会进行截取# maxlen 允许的最大长度可对流进行修剪限制长度# minid 允许的最小id，从某个id值开始，比它小的值将会被抛弃127.0.0.1:6379> xtrim mystream maxlen 21127.0.0.1:6379> xtrim mystream minid 1735024367169-00
复制代码
xread [COUNT count] [BLOCK milliseconds] STREAMS key [key ...] id [id ...]
# 用于获取消息(阻塞/非阻塞),只会返回大于指定id的消息# coutbn最多读取多少条消息# block是否以阻塞的方式读取，默认不阻塞，如果milliseconds是0，则表示永远阻塞
# 非阻塞127.0.0.1:6379> xread count 2 streams st 0-0st1735025452891-0k1v11735025456072-0k2v2
# 使用block阻塞指定时间，直到读取到满足$的id127.0.0.1:6379> xread count 2 block 10011 streams st $
复制代码
消费组相关
xgroup create key group id|$ [MKSTREAM] [ENTRIESREAD entries-read]
# 创建消费组
# 根据mystream创建消费组127.0.0.1:6379> xgroup create mystream group1 $ # $表示从尾部开始消费OK127.0.0.1:6379> xgroup create mystream group2 0 # 0表示从头部开始消费
复制代码
xreadgroup GROUP group consumer [COUNT count] [BLOCK milliseconds] [NOACK] STREAMS key [key ...] id [id ...]读取消费组
# > 表示从第一条尚未被消费的消息开始读取127.0.0.1:6379> xreadgroup group group2 consumer1 streams mystream >mystream1735027370532-0k1v1k2v21735027377812-0k2v2k3v3
复制代码
不同组的消费者可以消费同一条消息
ack 机制
xpending key group [[IDLE min-idle-time] start end count [consumer]]
# 获取消息组已经读取但是没确认的消息127.0.0.1:6379> xpending mystream group221735027370532-01735027377812-0consumer12# 读了两条消息，消费者是consumer1
复制代码
# 查看指定消费者读取的消息127.0.0.1:6379> xpending mystream group2 - + 10 consumer11735027370532-0consumer176747811735027377812-0consumer17674781
复制代码
xack key group id [id ...]
# 向消息队列确认消息处理已完成127.0.0.1:6379> xack mystream group2 1735028533963-01
复制代码
xinfo stream key [FULL [COUNT count]]
# 用于打印Stream\Consumer\Group的详细信息127.0.0.1:6379> xinfo stream mystreamlength3radix-tree-keys1radix-tree-nodes2last-generated-id1735028533963-0max-deleted-entry-id0-0entries-added3recorded-first-entry-id1735027370532-0groups2first-entry1735027370532-0k1v1k2v2last-entry1735028533963-0kkvv
复制代码
位域 bitfield
通过 bitfield 命令可以一次性操作多个比特位域(指的是连续的多个比特位)，它会执行一系列操作并返回一个响应数组，这个数组中的元素对应参数列表中的相应操作的执行结果，说白了就是通过 bitfield 命令我们可以一次性对多个比特位域进行操作
将一个 redis 字符串看作是一个由二进制位组成的数组并能对变长位宽和任意没有字节对齐的指定整型位域进行寻址和修改
Ascii 码表：https://ascii.org.cn
127.0.0.1:6379> set fieldkey helloOK127.0.0.1:6379> bitfield fieldkey get i8 0104 # ASCII码表 10进制104 就是字母h
复制代码
# set 设置指定位域的值并返回它的原值127.0.0.1:6379> bitfield fieldkey set i8 8 120 101127.0.0.1:6379> get fieldkeyhxllo
复制代码
BITFIELD key [INCRBY type offset increment]
如果偏移量后面的值发生溢出（大于 127），redis 对此也有对应的溢出控制，默认情况下，INCRBY 使用 WRAP 参数
溢出控制:OVERFLOW [WRAP|SAT|FAIL]
WRAP:使用回绕(wrap around)方法处理有符号整数和无符号整数溢出情况
SAT:使用饱和计算(saturation arithmetic)方法处理溢出，下溢计算的结果为最小的整数值，而上溢计算的结果为最大的整数值
fail:命令将拒绝执行那些会导致上溢或者下溢情况出现的计算，并向用户返回空值表示计算未被执行
文章转载自：木子七
原文链接：https://www.cnblogs.com/Mickey-7/p/18628152
体验地址：http://www.jnpfsoft.com/?from=infoq
评论