Redis数据类型

通用操作

## 判断key是否存在 127.0.0.1:6379> EXISTS name (integer) 1 127.0.0.1:6379> EXISTS name1 (integer) 0 ## 修改key名字 127.0.0.1:6379> RENAME name name1 OK ## 查看指定key的数据类型 127.0.0.1:6379> TYPE name1 string ## 删除key 127.0.0.1:6379> del name1 (integer) 1 ## 查看一个key的生存时间 127.0.0.1:6379[15]> ttl age (integer) -1 ## 以秒为单位设置生存时间 127.0.0.1:6379[15]> ttl age (integer) 95 ## 以毫秒为单位设置生存时间 127.0.0.1:6379[15]> PEXPIRE age 4000 ## 取消生存时间 127.0.0.1:6379[15]> PERSIST age

字符串类型操作（strings）

增

## 设置key 127.0.0.1:6379> set name www ## 设置多个key 127.0.0.1:6379> MSET name www name1 wsh name2 qwe ## 查看多个key值 127.0.0.1:6379> MGET name name1 name2 1) "www" 2) "wsh" 3) "qwe" ## 先获取一个key的值，再设置或者修改key值 127.0.0.1:6379> getset xxx 123 (nil) 127.0.0.1:6379> get xxx "123" ## 设置key同时设置生存时间(秒为单位) 127.0.0.1:6379> set book hongloumeng ex 100 OK ## 设置key同时设置生存时间(毫秒为单位) 127.0.0.1:6379> set book hongloumeng px 100 OK ## 字符串自增 127.0.0.1:6379> incr zan (integer) 1 ## 指定增加数量 127.0.0.1:6379> incrby fans 10000 (integer) 10023 ## 自减 127.0.0.1:6379> decr fans (integer) 10012 ## 执行自减数量 127.0.0.1:6379> decrby fans 1000 (integer) 9012 ## 按照小数自增 127.0.0.1:6379> incrbyfloat zls 0.1 "1.4"

删

127.0.0.1:6379> del rty (integer) 1

改

## 字符串追加 127.0.0.1:6379> APPEND name hhh (integer) 6 127.0.0.1:6379> get name "wwwhhh" ## 修改第N个字符 127.0.0.1:6379> SETRANGE name 5 L 127.0.0.1:6379> get name "wwwhhL"

查

## 查看一个key 127.0.0.1:6379> get name1 "wsh" ## 查看多个key 127.0.0.1:6379> MGET name name1 name2 1) "wwwhhL" 2) "wsh" 3) "qwe" ## 查看字符串的长度 127.0.0.1:6379> STRLEN name (integer) 6 127.0.0.1:6379> STRLEN name1 (integer) 3 ## 查看生存时间 127.0.0.1:6379> ttl name1 // 秒 (integer) 93 127.0.0.1:6379> pttl name1 // 毫秒 (integer) 91417 # 字符串截取 127.0.0.1:6379> GETRANGE name 0 3 "wwwh"

hash类型（字典类型）

应用场景：

存储部分变更的数据，如用户信息，商品信息等。 最接近表结构的一种类型。

# 创建key hset keyname field value hset student_id_1 name zls hset student_id_1 name zls age 18 gender m hmset student_id_1 name zls age 18 gender m # 查询 hget keyname field hget student_id_1 name hgetall keyname hgetall student_id_1 hmget student_id_1 name age # 删除 127.0.0.1:6379> hdel student_id_1 age gender (integer) 2 127.0.0.1:6379> hgetall student_id_1 127.0.0.1:6379> del student_id_1 # 改 127.0.0.1:6379> hset student_id_1 name zls age 18 gender m (integer) 3 127.0.0.1:6379> hgetall student_id_1 1) "fans" 2) "8" 3) "zan" 4) "9" 5) "name" 6) "zls" 7) "age" 8) "18" 9) "gender" 10) "m"

list类型（列表类型）

消息队列

在生活中，其实有很多的例子，都类似消息队列。

比如：工厂生产出来的面包，交给超市，商场来出售，客户通过超市，商场来买面包，客户不会针对某一个工厂去选择，只管从超市买出来，工厂也不会管是哪一个客户买了面包，只管生产出来之后，交给超市，商场来处理。

消息队列（Message Queue）是一种应用间的通信方式，消息发送后可以立即返回，有消息系统来确保信息的可靠专递，消息生产者只管把消息发布到MQ中而不管谁来取，消息消费者只管从MQ中取消息而不管谁发布的，这样发布者和使用者都不用知道对方的存在。

生产者 -> 消息队列 -> 消费者 kafka

为什么使用消息队列

首先，我们可以知道，消息队列是一种异步的工作机制，比如说日志收集系统，为了避免数据在传输过程中丢失，还有订单系统，下单后，会生成对应的单据，库存的扣减，消费信息的发送，一个下单，产生这么多的消息，都是通过一个操作的触发，然后将其他的消息放入消息队列中，依次产生。再就是很多网站的，秒杀活动之类的，前多少名用户会便宜，都是通过消息队列来实现的。

这些例子，都是通过消息队列，来实现，业务的解耦，最终数据的一致性，广播，错峰流控等等，从而完成业务的逻辑。

消息队列的产品

• RabbitMQ（最早金融公司，OpenStack）
• ZeroMQ（SaltStack）
• RocketMQ
• Kafka（Java）
• Redis（消息队列）

kafka 在kafka中可以创建topic会话 topic会话组，可以重复消费，消费者取数据根据topic的偏移量来取 公司的OA系统使用Jira 公司的文档系统使用 confluence 127.0.0.1:6379> lpush access_log '10.0.0.1 - - [03/Sep/2022:03:38:41 +0800] "POST /index.php HTTP/1.1" 200 1500 "-" "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.0.0 Safari/537.36" "-"' 127.0.0.1:6379> lpush access_log '10.0.0.1 - - [03/Sep/2022:03:54:09 +0800] "POST /index.php HTTP/1.1" 200 1500 "-" "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/104.0.0.0 Safari/537.36" "-"' # 将数据添加在可以的最右边 127.0.0.1:6379> rpush name1 hl (integer) 1 127.0.0.1:6379> rpush name1 wyk (integer) 2 127.0.0.1:6379> rpush name1 zls (integer) 3 # 如果数据不存在则不创建 lpushx name2 hl # 将数据插入到key的任意位置 127.0.0.1:6379> linsert name2 after hl hjx after：在...之后 before：在...之前 # 查看key中的指定范围数据 127.0.0.1:6379> lrange name 0 2 (empty array) 127.0.0.1:6379> lrange name1 0 2 1) "hl" 2) "wyk" 3) "zls" # 从key的最左边取出数据 127.0.0.1:6379> lpop name1 "hl" 127.0.0.1:6379> lpop name1 "wyk" 127.0.0.1:6379> lpop name1 "zls" # 查看key的长度 127.0.0.1:6379> llen name1 lpush：左边写入 rpush：右边写入 lpop：左边取出 rpop：右边取出 # 将name1右边的数据取出，写入name2左边 127.0.0.1:6379> lrange name1 0 2 1) "wyk" 2) "hjx" 3) "xwq" 127.0.0.1:6379> lrange name2 0 2 1) "hl" 2) "hjx" 3) "zls" 127.0.0.1:6379> rpoplpush name1 name2 "xwq" 127.0.0.1:6379> lrange name2 0 2 1) "xwq" 2) "hl" 3) "hjx" 127.0.0.1:6379> lrange name2 0 3 1) "xwq" 2) "hl" 3) "hjx" 4) "zls" ## 删除 # 从左边开始删除指定个数元素 lrem 127.0.0.1:6379> lrange name2 0 100 1) "hl" 2) "hl" 3) "hl" 4) "hl" 5) "hl" 6) "hl" 7) "xwq" 8) "hl" 9) "hjx" 10) "zls" 11) "hl" 12) "hl" 13) "hl" 14) "hl" 127.0.0.1:6379> lrem name2 7 hl (integer) 7 127.0.0.1:6379> lrange name2 0 100 1) "xwq" 2) "hjx" 3) "zls" 4) "hl" 5) "hl" 6) "hl" 7) "hl" # 保留指定下标的元素，其余的都删除 127.0.0.1:6379> lrange name2 0 100 1) "xwq" 2) "hjx" 3) "zls" 4) "hl" 5) "hl" 6) "hl" 7) "hl" 127.0.0.1:6379> ltrim name2 0 1 OK 127.0.0.1:6379> lrange name2 0 100 1) "xwq" 2) "hjx" ## 改 127.0.0.1:6379> lrange name1 0 100 1) "wyk" 2) "hjx" 127.0.0.1:6379> lset name1 0 xwq OK 127.0.0.1:6379> lrange name1 0 100 1) "xwq" 2) "hjx" ## 查 # 按照索引查询 127.0.0.1:6379> lindex name1 1 "hjx" 127.0.0.1:6379> lindex name1 0 "xwq" 127.0.0.1:6379> lindex name1 2 (nil) 127.0.0.1:6379> lindex name1 -1 //最后一个元素 "hjx" ## 发朋友圈 127.0.0.1:6379> lpush wechat 'monday hl sb' (integer) 1 127.0.0.1:6379> lpush wechat 'tiusiday hl yiran sb' (integer) 2 127.0.0.1:6379> lpush wechat 'wensiday hl always sb' (integer) 3 ## 查看朋友圈 127.0.0.1:6379> lrange wechat 0 -1 1) "wensiday hl always sb" 2) "tiusiday hl yiran sb" 3) "monday hl sb"

set（集合类型）

组1：1 2 3 4 5 组2: 1 3 5 7 9 交集：1 3 5 并集：1 2 3 4 5 7 9 差集：2 4 7 9 # 创建集合 127.0.0.1:6379> sadd zls_fans wyk hl (integer) 2 127.0.0.1:6379> sadd tly_fans mls gaofei wyk (integer) 3 # 查 ## 查询集合中的元素，有就返回1 没有就返回0 127.0.0.1:6379> sismember zls_fans hl (integer) 1 127.0.0.1:6379> sismember zls_fans cls (integer) 0 ## 查询集合中的所有元素 127.0.0.1:6379> SMEMBERS zls_fans 1) "hl" 2) "wyk" ## 查询集合中元素数量 127.0.0.1:6379> scard zls_fans (integer) 2 127.0.0.1:6379> scard tly_fans (integer) 3 ## 比较集合中的差异，取前面集合的不同之处 127.0.0.1:6379> sdiff hl_fans tly_fans zls_fans 1) "xiaoxuesheng" 127.0.0.1:6379> SMEMBERS hl_fans 1) "hl" 2) "mls" 3) "xiaoxuesheng" 127.0.0.1:6379> SMEMBERS tly_fans 1) "wyk" 2) "mls" 3) "gaofei" 127.0.0.1:6379> SMEMBERS zls_fans 1) "hl" 2) "wyk" 127.0.0.1:6379> sdiff hl_fans tly_fans 1) "hl" 2) "xiaoxuesheng" 127.0.0.1:6379> sdiff tly_fans hl_fans 1) "wyk" 2) "gaofei" 127.0.0.1:6379> sdiff tly_fans hl_fans zls_fans 1) "gaofei" ## 比较之后的差异，存放到新的集合中 127.0.0.1:6379> sdiffstore resault tly_fans hl_fans (integer) 2 127.0.0.1:6379> KEYS * 1) "hl_fans" 2) "resault" 3) "name2" 4) "tly_fans" 5) "name1" 6) "wechat" 7) "zls_fans" 127.0.0.1:6379> type resault set 127.0.0.1:6379> scard resault (integer) 2 127.0.0.1:6379> 127.0.0.1:6379> SMEMBERS resault 1) "wyk" 2) "gaofei" ## 交集（共同好友） 127.0.0.1:6379> SMEMBERS hl_fans 1) "hl" 2) "mls" 3) "xiaoxuesheng" 127.0.0.1:6379> SMEMBERS zls_fans 1) "hl" 2) "wyk" 127.0.0.1:6379> sinter hl_fans zls_fans 1) "hl" ## 并集 127.0.0.1:6379> sunion hl_fans zls_fans 1) "hl" 2) "wyk" 3) "mls" 4) "xiaoxuesheng" ## 将交集存入新集合 127.0.0.1:6379> sinterstore new_set hl_fans zls_fans (integer) 1 127.0.0.1:6379> SMEMBERS new_set 1) "hl" ## 将并集存入新集合 127.0.0.1:6379> sunionstore new_set2 hl_fans zls_fans (integer) 4 127.0.0.1:6379> SMEMBERS new_set2 1) "hl" 2) "wyk" 3) "mls" 4) "xiaoxuesheng" ## 取随机值 127.0.0.1:6379> srandmember zls_fans "mls" ## 改 ## 将集合的元素存入另一个集合 SMOVE 127.0.0.1:6379> SMEMBERS hl_fans 1) "hl" 2) "mls" 3) "xiaoxuesheng" 127.0.0.1:6379> SMEMBERS zls_fans 1) "hl" 2) "wyk" 127.0.0.1:6379> SMOVE hl_fans zls_fans mls (integer) 1 127.0.0.1:6379> SMEMBERS hl_fans 1) "hl" 2) "xiaoxuesheng" 127.0.0.1:6379> SMEMBERS zls_fans 1) "hl" 2) "wyk" 3) "mls" ## 删 127.0.0.1:6379> spop hl_fans "hl" 127.0.0.1:6379> SMEMBERS hl_fans 1) "xiaoxuesheng" ## 删除指定元素，返回删除元素的个数 127.0.0.1:6379> srem zls_fans hl (integer) 1 127.0.0.1:6379> SMEMBERS zls_fans 1) "wyk" 2) "mls" 127.0.0.1:6379> srem zls_fans xxx (integer) 0 #### 无序的 127.0.0.1:6379> sadd zls_fans 111 222 333 444 555 666 (integer) 6 127.0.0.1:6379> SMEMBERS zls_fans 1) "abc" 2) "111" 3) "mls" 4) "123" 5) "def" 6) "333" 7) "222" 8) "456" 9) "444" 10) "555" 11) "666" 12) "wyk"

sorted-set（有序集合）

应用场景：

排行榜应用，取TOP N操作 这个需求与上面需求的不同之处在于，前面操作以时间为权重，这个是以某个条件为权重，比如按顶的次数排序，这时候就需要我们的sorted set出马了，将你要排序的值设置成sorted set的score，将具体的数据设置成相应的value，每次只需要执行一条ZADD命令即可。

# 增 127.0.0.1:6379> zadd myzset 1 "one" 2 "two" 3 "three" # 查 ## 只查询成员 127.0.0.1:6379> zrange chengji 0 -1 1) "wyk" 2) "hl" 3) "zls" ## 查询成员和分数 127.0.0.1:6379> zrange chengji 0 -1 WITHSCORES 1) "wyk" 2) "1" 3) "hl" 4) "38" 5) "zls" 6) "100" ## 查询成员的索引 127.0.0.1:6379> zrank chengji wyk (integer) 0 127.0.0.1:6379> zrank chengji zls (integer) 2 ## 查询成员数量 127.0.0.1:6379> zcard chengji (integer) 3 ## 查看分数是指定范围的成员个数 30 <= score <=40 127.0.0.1:6379> zcount chengji 30 40 (integer) 1 127.0.0.1:6379> zcount chengji 30 101 (integer) 2 ## 获取指定成员分数 127.0.0.1:6379> ZSCORE chengji wyk "1" 127.0.0.1:6379> ZSCORE chengji zls "100" ## 查看分数是指定范围的成员名 127.0.0.1:6379> zcount chengji 30 40 (integer) 1 127.0.0.1:6379> zrangebyscore chengji 30 40 1) "hl" ## +inf表示最后一个成员，-inf表示第一个成员，意思是：检索所有数据，然后从下标为2的数据开始再往后输出3：(N-1)个数据 127.0.0.1:6379> zrangebyscore chengji -inf +inf limit 2 3 1) "hjx" 2) "xwq" 3) "zls" 127.0.0.1:6379> zrangebyscore chengji -inf +inf limit 2 2 1) "hjx" 2) "xwq" 127.0.0.1:6379> zrangebyscore chengji -inf +inf limit 2 1 1) "hjx" 127.0.0.1:6379> zrangebyscore chengji -inf +inf limit 2 4 1) "hjx" 2) "xwq" 3) "zls" # 删 ## 删除指定分数范围的成员，并返回删除的个数 127.0.0.1:6379> zrangebyscore chengji 30 40 1) "hl" 127.0.0.1:6379> zremrangebyscore chengji 30 40 (integer) 1 ## 按指定索引范围删除，返回删除个数 127.0.0.1:6379> zremrangebyrank chengji 0 2 (integer) 3 ## 倒序排名 127.0.0.1:6379> zrevrange chengji 0 -1 WITHSCORES 1) "zls" 2) "100" 3) "hjx" 4) "60" 5) "xwq" 6) "50" 7) "hl" 8) "38" 9) "wyk" 10) "1" ## 按照分数段查找成员，并倒序排序 127.0.0.1:6379> zrevrangebyscore chengji 101 30 WITHSCORES 1) "zls" 2) "100" 3) "hjx" 4) "60" 5) "xwq" 6) "50" 7) "hl" 8) "38" ## 按照分数查找成员，并倒序排序，然后按照索引号，取出指定的数据 127.0.0.1:6379> zrevrangebyscore chengji 101 30 WITHSCORES limit 1 2 1) "hjx" 2) "60" 3) "xwq" 4) "50" 127.0.0.1:6379> zrevrangebyscore chengji 101 30 WITHSCORES limit 1 3 1) "hjx" 2) "60" 3) "xwq" 4) "50" 5) "hl" 6) "38"