Redis的高级特性

£神魔★判官ぃ 2022-09-05 06:11 439阅读 0赞

目录

      • 高级数据类型
      • 支持事务
      • 支持Lua脚本
      • 支持pipeline 管道|流水线
      • 支持发布/订阅
      • 可实现异步队列 | 消息队列

高级数据类型

1、Bitmap 位图

按 bit 位存储信息,常用于实现布隆过滤器

2、HyperLogLog 基数统计

提供去重计数功能,根据输入元素来计算基数,不储存输入元素本身。

优点是在数量量很大时,计算基数所需的空间总是固定 的且很小的。和Bitmap一样,不精确、有一定的错误率。

基数:一个数据集中不重复的元素个数(剔除重复元素后的元素数量)

3、Geospatial 地址空间

用于保存地理位置,可以做距离计算、根据半径范围查找等,比如计算最优地图路径、查找附近范围内的人。

支持事务

redis支持事务,可以将多个命令作为打包为事务来执行。

redis的事务只是把多个命令打包,放在一个队列中执行,只是保证了事务中指令的串行执行,并没有给事务添加原子性的保障机制,redis的事务具有隔离性但不具备原子性,执行失败时不会回滚。

  1. #标记事务开始
  2. multi
  3. #多个命令,依次入队
  4. #...
  5. #执行|提交事务
  6. exec
  7. #取消事务
  8. discard
  • 如果在exec执行事务之前发生了错误,比如某个要入队的命令语法不对,会自动取消这个事务。
  • 如果exec执行事务时,中途某个命令执行出错,并不会回滚已执行的命令,而是跳过出错的命令继续往下执行,可以在执行结果中看到各个命令的执行结果。

#

支持Lua脚本

Lua脚本可以用于打包执行一些列指令

  • 关键特点:与redis事务都是打包命令,但lua脚本中的一系列操作、指令具有原子性
  • 复用方便

如果业务逻辑比较复杂或者多个指令需要具有原子性,可以将这些指令封装在lua脚本中发送给redis执行。

支持pipeline 管道|流水线

在这里插入图片描述
管道可以打包一批指令,一次性发送给redis服务器执行,redis服务器会一次性返回这批命令的所有执行结果,减少了与redis服务器频繁交互的网络通信的时间开销。

与redis事务相比

  • 相同点:都是将多个指令打包发送给redis服务器执行,整个操作都不具备原子性,某个指令执行失败时会继续执行后续指令,不会回滚之前的操作。
  • 不同点:redis事务是作为一个整体执行的,具有隔离性,redis服务器执行事务期间不会穿插执行其它客户端的指令;管道中的命令不是作为一个整体执行的,而是逐个指令执行,虽然事务、管道都能保证所包含命令执行的顺序性,但执行管道中命令的期间可能会穿插执行其它客户端的指令,最终执行结果可能会被影响,所以管道只适合对顺序性要求不高的场景。

原生的mset、mget实质是批量执行set、get指令,但具有原子性。

使用示例

  1. @Autowired
  2. private StringRedisTemplate redisTemplate;
  3. public void test() {
  4. //...
  5. //返回值list,元素对应各条命令的执行结果
  6. List<Object> resultList = redisTemplate.executePipelined(new RedisCallback<Object>() {
  7. @Override
  8. public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {
  9. //打开一个pipeline
  10. redisConnection.openPipeline();
  11. redisConnection.set("name".getBytes(), "chy".getBytes());
  12. redisConnection.set("tel".getBytes(), "188xxxxxx".getBytes());
  13. redisConnection.set("email".getBytes(), "xxxxxxx@qq.com".getBytes());
  14. //不要调用redisConnection的closePipeline()关闭pipeline,也不要关闭连接欸,不然拿不到返回的执行结果
  15. //返回null即可
  16. return null;
  17. }
  18. });
  19. //...
  20. }

不要一次性组装发送太多指令,或者发送big key这种大key,可能导致网络拥塞,可以将大量指令拆分到小的pipeline中分批完成。

支持发布/订阅

发布/订阅(publish/subscribe)是一种消息通信模式,redis客户端订阅redis服务器上的一个或多个channel(管道、频道),客户端发布消息到redis服务器中的某个channel后,redis服务器会将消息推送给所有订阅了此channel的redis客户端。

发布/订阅常用命令

  1. subscribe channel1 channel2 #订阅一个或多个频道
  2. psubscribe CCTV1 #p即pattern,用正则表达式指定要订阅的频道,会订阅所有匹配的频道
  3. psubscribe CCTV* #订阅所有以CCTV开头的频道
  4. psubscribe *TV #订阅所有以TV结尾的频道
  5. psubscribe CCTV* CNTV* #可以指定多个匹配模式,订阅以CCTV开头的所有频道、订阅所有以CNTV开头的所有频道
  6. unsubscribe channel1 channel2 #退订一个或多个频道
  7. punsubscribe CCTV* CNTV* #退订以CCTV开头的所有频道、退订以CNTV开头的所有频道
  8. publish channel1 "hello" #往某个频道里推送消息

说明

  • channel不需要手动创建
  • redis客户端无需订阅channel就可以直接往任意channel中发布消息
  • 客户端订阅的channel列表是作为session存储在redis服务器上的,订阅只在本次会话期间有效,断开与redis服务器的连接后订阅失效,所以客户端每次启动连接到redis服务器时都需要重新订阅。
  • redis发布/订阅的消息类似于广播,是在线即时消息,只有在线的订阅者(已连接到redis服务器的客户端)才会收到推送。若客户端当时不在线,后续连接到服务器时,服务器也不会再次推送之前的消息。

redis的发布订阅不能提供可靠的消息投递,一般只用于日志、流水等对消息投递可靠性要求不高的场景。

可实现异步队列 | 消息队列

redis实现异步|消息队列有2种方式

1、使用发布/订阅模式实现

  • 可以让多个消费者同时消费消息。消费者集群部署时,消息会被每个消费者节点进行消费,存在重复消费
  • 无法保证消息送达(不可靠)

2、使用list实现

  • 生产者用rpush实现消息入队,消费者用blpop阻塞获取list中的元素实现消息出队
  • list有序,可以实现顺序消息
  • 消息只会被一个消费者进行消费

3、使用zset实现延时队列

  • 把消息内容作为key,消息发送的时间转换为时间戳作为score,使用zadd指令实现消息入队
  • 消费者间隔指定时间用 zrangebyscore 指令获取当前时间范围内的key进行处理。

实现消息队列尽量用rabbitmq、kafka等更专业的消息中间件,功能更加强大。

发表评论

表情:
评论列表 (有 0 条评论,439人围观)

还没有评论,来说两句吧...

相关阅读

    相关 Redis 详解及高级特性

    Redis 是一个基于内存的高性能键值数据库,它支持多种数据结构,包括字符串、列表、集合、有序集合和哈希表等。Redis 将数据存储在内存中,因此拥有非常高的读取和写入性能,适

    相关 Redis高级特性【慢查询】

    什么是慢查询 许多存储系统(例如 MySQL)提供慢查询日志帮助开发和运维人员定位系统存在的慢操作。所谓慢查询日志就是系统在命令执行前后计算每条命令的执行时间,当超过预设