1.8 bitmap(位图)操作命令
SETBIT 设置
格式:setbit 参数1 参数2 参数3
参数1:bitmap名称
参数2:索引
参数3:值( 1 | 0 )
示例:
将bitmap1的第一个位置的值设为1
setbit bitmap1 1 1
GETBIT 检索
格式:getbit 参数1 参数2
参数1:bitmap名称
参数2:索引
示例:
检索bitmap1索引为2的值
getbit bitmap1 2
STRLEN 统计字节数
格式:strlen 参数1
参数1:bitmap名称
示例:
统计bitmap1占用的字节数(每8位占1字节)
strlen bitmap1
BITCOUNT 统计1
格式:bitcount参数1 [参数2]
参数1:bitmap名称
参数2:范围(起始字节 终止字节)
示例:
统计bitmap1值为1的数量
bitcount bitmap1
统计bitmap1中0到1字节范围内值为1的数量
bitcount bitmap1 0 1
BITOP 位运算
格式:bittop 参数1 参数2 参数3
参数1:AND(与) | OR(或) | XOR(异或) | NOT(非)
参数2:存放的bitmap
参数3:参与运算的bitmap(空格分隔)
示例:
将bitmap1和bitmap2进行与运算并将结果存放在newbitmap
bitop and newbitmap bitmap1 bitmap2
将bitmap3进行非运算并将结果存放在newbitmap(非运算只能有一个bitmap)
bitop not newbitmap bitmap1
1.9 HyperLogLog(基数统计)操作命令
PFADD 添加
格式:pfadd 参数1 参数2
参数1:hyperLogLog名称
参数2:元素(可以多个,使用空格分隔)
示例:
将zs、ls添加到k1中
pfadd k1 zs ls
PFCOUNT 统计
格式:pfcount 参数1
参数1:hyperLogLog名称(可以多个,使用空格分隔)
示例:
统计k1、k2中的基数个数
pfcount k1 k2
PFMERGE 合并
格式:pfmerge 参数1 参数2
参数1:接收结果hyperLogLog名称
参数2:hyperLogLog名称(使用空格分隔)
示例:
将k1、k2、k3合并到newkey中
pfmerge newkey k1 k2 k3
1.10 GEO(地理空间)操作命令
GEOADD 添加
格式:geo 参数1 参数2 参数3
参数1:geo名称
参数2:经度
参数3:纬度
参数4:描述
示例:
在city里面添加天安门、故宫的经纬度坐标
GEOADD city 116.403963 39.915119 "天安门" 116.403414 39.924091 "故宫"
GEOPOS 返回经纬度
格式:geopos 参数1 参数2 参数3
参数1:geo名称
参数2:描述(可以多个,使用空格分隔)
示例:
返回故宫、天安门的经纬度
geopos city "故宫" "天安门"
GEOHASH hash表示返回经纬度
格式:geohash参数1
参数1:geo名称
参数2:描述(可以多个,使用空格分隔)
示例:
hash表示返回故宫、天安门的经纬度
geohash city "故宫" "天安门"
GEODIST 距离计算
格式:geodist 参数1 参数2 参数3
参数1:geo名称
参数2:描述1
参数3:描述2
参数3:单位( M | KM | FT | MI )
示例:
计算天安门和故宫相距多少KM
geodist city "天安门" "故宫" KM
GEORADIUS 半径查找
格式:georadius 参数1 参数2 参数3 参数4 [参数5] [参数6] [参数7] [参数8] [参数9]
参数1:geo名称
参数2:经度
参数3:维度
参数4:距离
参数5:withcoord(返回坐标)
参数6:withdist(返回距离信息)
参数7:排序( ASC | DESC )
参数8:最大返回数(count 数量)
参数9:withhash(返回hash值)
示例:
返回city中距离(116.403963,39.915119)坐标10km之内的元素并正序排序,最大限度不超过10条,同时返回坐标、距离信息、哈希值
georadius city 116.403963 39.915119 60km withcoord withdist asc count 10 withhash
GEORADIUSBYMEMBER
格式:georadiusbymember 参数1 参数2 参数3 [参数4] [参数5] [参数6] [参数7]
参数1:geo名称
参数2:描述
参数3:距离
参数4:withcoord(返回坐标)
参数5:withdist(返回距离信息)
参数6:排序( ASC | DESC )
参数7:最大返回数(count 数量)
参数8:withhash(返回hash值)
示例:
返回city中距离天安门10km之内的元素并正序排序,最大限度不超过10条,同时返回坐标、距离信息、哈希值
georadius city 天安门 60km withcoord withdist asc count 10 withhash
1.11 Stream(流)操作命令
1.11.1 队列相关命令
XADD 添加
格式:cadd 参数1 参数2 参数3
参数1:队列名称
参数2:消息ID
参数3:键值对参数(可以多个,使用空格分隔)
示例:
在stream1添加键值对(name:zs)、(age:18),消息ID自动生成
xadd stream1 * name zs age 18
XTRIM 截取
格式:xtrim 参数1 参数2 参数3
参数1:队列名称
参数2:maxlen | minid
参数3:根据参数2变化( maxlen 允许的最大长度 | minid 允许最小id )
示例:
将mystream中超过阈值2的消息进行修剪
xtrim mystream maxlen 2
将mystream中小于1683373939844-0的消息进行修剪
xtrim mystream minid 1683373939844-0
XDEL 删除
格式:cdel 参数1 参数2
参数1:队列名称
参数2:消息ID(可以多个,使用空格分隔)
示例:
删除mystream中消息id为 1683373679898-0 的消息
xdel mystream 1683373679898-0
XLEN 统计
格式:xlen 参数1
参数1:队列名称
示例:
统计mystream中的消息数
xlen mystream
XRANGE
格式:xrange 参数1 参数2 参数3
参数1:队列名称
参数2:范围(max -> min)
参数3:最大展示数量
示例:
获取最小值到最大值中最多5条消息
xrange stream - + count 1
XREVRANGE 反转获取
格式:xrevrange 参数1 参数2 参数3
参数1:队列名称
参数2:范围(min -> max)
参数3:最大展示数量
示例:
获取最大值到最小值中最多5条消息
xrevrange stream + - count 1
XREAD 消息读取
格式:xread [参数1] [参数2] streams 参数3 参数4
参数1:数量
参数2:BLOCK (BLOCK以阻塞方式读取消息)
参数3:队列名称
参数4:返回范围
示例:
在mystream中从头开始读取两条数据
xread count 2 streams mystream 0-0
以阻塞方式在mystream中读取一条新数据
xread count 1 block 0 streams mystream $
1.11.2 消费组相关指令
XGROUP CREATE 创建消费者组
格式:xgroup create 参数1 参数2 参数3
参数1:队列名称
参数2:分组名称
参数3:$ | 0 ($从尾部开始消费,0从头部开始消费)
示例:
基于mystream创建一个分组groupA,规则从尾部开始消费
xgroup create mystream groupA $
XREADGROUP GROUP
格式:xreadgroup group 参数1 参数2 streams 参数3 参数4
参数1:消费组名称
参数2:消费组名称
参数3:数量
参数4:队列名称
参数5:读取消息的起始位置
示例:
在groupA创建一个消费者consumer1从 Stream 的最新位置开始读取读取mystream的2条消息
xreadgroup group groupA consumer1 count 2 streams mystream >
XACK 确认
格式:xack 参数1 参数2 参数3
参数1:队列名称
参数2:分组消息
参数3:消息ID
示例:
确认一条mystream中groupA的消息,消息ID为1683375790000-0
xack mystream groupA 1683375790000-0
XPENDING 查询读取
格式:xpending 参数1 参数2 [参数3] [参数4]
参数1:队列名称
参数2:消费组名
参数3:范围
参数4:消费者名称
示例:
查询mystream中groupA分组在整个消息队列中已读取未确认的消息最大不超过10条
xpending mystream groupA - + 10
查询mystream中groupA分组的消费者consumer1已读取未确认的消息,范围是整个消息队列最大不超过10条
xpending mystream groupD - + 10 consumer1
XINFO
格式:xinfo stream 参数1
参数1:队列名称
示例:
打印mystream的stream、消费组、消费用户信息
xinfo stream mystream
1.11.3 特殊符号
-:最小可能出现的id;
+:最大可能出现的id;
$:表示只消费新的消息,当前流中最大的 id,可用于将要到来的信息;
>:用于XREADGROUP命令,表示迄今还没有发送给组中使用者的信息,会更新消费者组的最后ID;
*:用于XADD命令中,让系统自动生成 id;
1.12 bitdield(位域)操作命令
BITFIELD GET 获取
格式:bitfield 参数1 get 参数2 参数3
参数1:字符串变量
参数2:类型( i | u )
参数3:位数
示例:
返回strTemp的17位开始获取偏移8位的数据的有符号整型量
bitfield strTemp get i8 16
BITFIELD SET 设置
格式:bitfield 参数1 set 参数2 参数3
参数1:字符串变量
参数2:类型( i | u )
参数3:位数
参数4:替换量
示例:
从strTemp的第9位开始将接下来的8位替换为120(字母x)
bitfield strTemp set i8 8 120
BITFIELD INCRBY 增加
格式:bitfield 参数1 incrby 参数2 参数3
参数1:字符串变量
参数2:类型( i | u )
参数3:位数
参数4:增加量
示例:
对strTemp的第3个位开始,对接下来的4位无符号数加1
bitfield strTemp incrby u4 2 1
BITFIELD OVERFLOW 溢出控制
格式:bitfield 参数1 overflow 参数2 参数3 参数4 参数5
参数1:字符串变量
参数2:溢出控制选项( warp | sat | dail )
参数3:操作
参数4:类型( i | u )
参数5:位数
参数6:增加量
溢出控制选项名词解释:
WRAP:当位值溢出时,将自动从另一端开始重新计数,相当于将位值视为循环的。
SAT:当位值溢出时,将自动截断为最大或最小的可表示值。
FAIL:当位值溢出时,命令将返回一个错误。
示例:
对strTemp的第3个位开始,对接下来的4位无符号数加888,溢出控制设置为sat
bitfield strTemp overflow sat incrby u4 2 888