Redis KEYS查询大批量数据替代方案

2025-01-01 03:50

本文主要是介绍Redis KEYS查询大批量数据替代方案,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《RedisKEYS查询大批量数据替代方案》在使用Redis时,KEYS命令虽然简单直接,但其全表扫描的特性在处理大规模数据时会导致性能问题,甚至可能阻塞Redis服务,本文将介绍SCAN命令、有序...

前言

在使用 Redis 时,KEYS 命令虽然简单直接,但其全表扫描的特性在处理大规模数据时会导致性能问题,甚至可能阻塞 Redis 服务。本文将介绍SCAN命令、有序集合、哈希表和RediSearch模块四种替代 KEYS 的高效方案,以应对大批量数据的查询和管理。根据本人实际使用情况,查询Redis大批量数据的情况下推荐使用SCAN命令较好。

KEYS命令问题背景

KEYS 命令会遍历整个键空间,对于包含大量键的 Redis 实例,这可能导致以下问题:
高延迟:执行时间较长,影响其他命令的响应速度。
阻塞 Redis:在单线程模型下,KEYS 会阻塞 Redis 服务器,导致其他操作无法及时处理。
内存消耗:返回所有匹配的键可能会占用大量内存。
因此,在生产环境中应尽量避免使用 KEYS 命令。

替代方案

1.使用 SCAN 命令

理论介绍

SCAN 是一个增量迭代器,可以分批逐步遍历键空间,避免一次性加载所有键。它支持游标(cursor)机制,允许用户通过多次调用来完成完整的遍历。

优点

非阻塞:不会阻塞 Redis 服务器,适合在线环境。
低资源消耗:每次只返回少量键,减少内存压力。

缺点

结果集不固定:SCAN 的结果集不是固定的,可能会有重复或遗漏的键,特别是在键频繁变化的情况下。
额外参数:需要合理设置 COUNT 参数以平衡遍历速度和资源消耗。

示例代码

/**
 * scan命令测试
 * @author senfel
 * @date 2024/12/26 11:34
 * @return void
 */
@Test
public void scan() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        String cursor = "0";
        ScanParams scanParams = new ScanParams().match("sys_dict:*").count(100);
        do {
            ScanResult<String> scanResult = jedis.scan(cursor, scanParams);
            for (String key : scanResult.getResult()) {
                System.out.println("Found key: " + key);
            }
       python     cursor = scanResult.getCursor();
        } while (!cursor.equals("0"));
    }
}

2. 使用有序集合(Sorted Set)

理论介绍

如果需要对键进行排序或范围查询,可以考虑将键存储在有序集合中,并为每个键分配一个唯一的分数(score)。这样可以通过 ZRANGE 或 ZREVRANGE 等命令高效地获取指定范围内的键。

优点

高效查询:支持快速的范围查询和排序。
灵活性:可以根据业务需求调整分数规则。

缺点

额外开销:需要维护有序集合,增加了写入操作的复杂度。

示例代码

/**
 * sortSet
 * @author senfel
 * @date 2024/12/26 11:51
 * @return void
 */
@Test
public void sortSet() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        // 添加键到有序集合
        for (int i = 0; i < 100; i++) {
            jedis.zadd("sorted_keys", System.currentTimeMillis(), "senfel"+i);
        }
        // 获取前 10 个键
        Set<String> keys = jedis.zrange("sorted_keys", 0, 9);
        for (String key : keys) {
            System.out.println("Key from sorted set: " + key);
        }
    }
}

3. 使用哈希(Hash)

理论介绍

如果键具有相似的结构或属于同一类目,可以将它们存储在一个哈希表中,每个字段代表一个键。这样可以通过 HGETALL 或 HSCAN 来批量获取相关键。

优点

集中管理:便于批量操作和维护。
高效访问:哈希表提供了 O(1) 的查找性能。

缺点

适用范围有限:适用于键具有相同前缀或分类的情况。

示例代码

/**
 * useHash
 * @author senfel
 * @date 2024/12/26 11:55
 * @return void
 */
@Test
public void useHash() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        for (int i = 0; i < 100; i++) {
            // 添加键到哈希表
            jedis.hset("user_data", "name"+i, "senfel"+i);
        }
        // 获取所有键值对
        Map<String, String> userData = jedis.hgetAll("user_data");
        for (Map.Entry<String, String> entry : userData.entrySet()) {
            System.out.println("User data: " + entry.getKey() + " -> " + entry.getValue());
        }
    }
}

4. 使用 Redis 模块(如 RediSearch)

理论介绍

Redis 模块扩展了 Redis 的功能,其中 RediSearch 提供了全文搜索和索引功能,能够高效地管理和查询大量数据。它支持复杂的查询语法和过滤条件。

RediSearch安装推荐使用docker

docker run --name redisearch -p 16379:6379 -v redis-data:/data redis/redis-stack-server:latest

优点

强大查询能力:支持全文搜索、模糊匹配等高级查询。
高性能:优化的索引结构保证了高效的查询性能。

缺点

依赖外部模块:需要安装和配置 Redis 模块。
学习成本:API 和配置相对复杂,需要一定的时间熟悉。

maven依赖

<dependency>
    <groupId>com.redislabs<IGOky/groupId>
    <artifactId>jredisearch</artifactId>
    <version>2.0.0</version>
</dependency>

示例代码

/**
 * useRediSearch 未安装RediSearch未测试
 * @author senfel
 * @date 2024/12/26 12:26 
 * @return void
 */
@Test
public void useRediSearch() {
    Client client = Client.create("localhost", 6379).connect();
    // 创建索引并添加文档
    client.ftCreate("idx", Schema.newBuilder()
            .addField(new TexChina编程tField("title"))
            .addField(new TextField("content"))
            .build());
    client.ftAdd("idx", "doc1", 1.0, Document.newDocument()
            .addField("title", "Redis Search")
            .addField("content", "Learn how to use Redis Search"));
    // 查询文档
    SearchResult result = client.ftSearch("idx", new Query("Redis"));
    for (Document doc : result.documents()) {
        System.out.println("Found document: " + doc.getId());
    }
    client.close();
}

总结

综上所述,Redis 大批量数据解决方案目前有SCAN命令、有序集合、哈希表、RediSearch扩展模块。一般对于Redis 大批量键遍历可以使用非阻塞低资源消耗的SCAN 命令,对于需要排序或范围查询的场景则使用有序集合,python对于键具有相同前缀或分类的情况可以使用哈希表,如果需要全文搜索或复杂查询则可以使用高性能强大查询能力的RediSearch。

以上就是Redis KEYS查询大批量数据替代方案的详细内容,更多关于Redis KEYS数据替代方案的资料请关注php编程China编程(www.chinasem.cn)其它相关文章!

这篇关于Redis KEYS查询大批量数据替代方案的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1152879

相关文章

如何提高Redis服务器的最大打开文件数限制

《如何提高Redis服务器的最大打开文件数限制》文章讨论了如何提高Redis服务器的最大打开文件数限制,以支持高并发服务,本文给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧... 目录如何提高Redis服务器的最大打开文件数限制问题诊断解决步骤1. 修改系统级别的限制2. 为Redis进程特别设置限制

Java解析JSON的六种方案

《Java解析JSON的六种方案》这篇文章介绍了6种JSON解析方案,包括Jackson、Gson、FastJSON、JsonPath、、手动解析,分别阐述了它们的功能特点、代码示例、高级功能、优缺点... 目录前言1. 使用 Jackson:业界标配功能特点代码示例高级功能优缺点2. 使用 Gson:轻量

Java如何接收并解析HL7协议数据

《Java如何接收并解析HL7协议数据》文章主要介绍了HL7协议及其在医疗行业中的应用,详细描述了如何配置环境、接收和解析数据,以及与前端进行交互的实现方法,文章还分享了使用7Edit工具进行调试的经... 目录一、前言二、正文1、环境配置2、数据接收:HL7Monitor3、数据解析:HL7Busines

Mybatis拦截器如何实现数据权限过滤

《Mybatis拦截器如何实现数据权限过滤》本文介绍了MyBatis拦截器的使用,通过实现Interceptor接口对SQL进行处理,实现数据权限过滤功能,通过在本地线程变量中存储数据权限相关信息,并... 目录背景基础知识MyBATis 拦截器介绍代码实战总结背景现在的项目负责人去年年底离职,导致前期规

基于Redis有序集合实现滑动窗口限流的步骤

《基于Redis有序集合实现滑动窗口限流的步骤》滑动窗口算法是一种基于时间窗口的限流算法,通过动态地滑动窗口,可以动态调整限流的速率,Redis有序集合可以用来实现滑动窗口限流,本文介绍基于Redis... 滑动窗口算法是一种基于时间窗口的限流算法,它将时间划分为若干个固定大小的窗口,每个窗口内记录了该时间

SpringBoot整合Canal+RabbitMQ监听数据变更详解

《SpringBoot整合Canal+RabbitMQ监听数据变更详解》在现代分布式系统中,实时获取数据库的变更信息是一个常见的需求,本文将介绍SpringBoot如何通过整合Canal和Rabbit... 目录需求步骤环境搭建整合SpringBoot与Canal实现客户端Canal整合RabbitMQSp

MyBatis框架实现一个简单的数据查询操作

《MyBatis框架实现一个简单的数据查询操作》本文介绍了MyBatis框架下进行数据查询操作的详细步骤,括创建实体类、编写SQL标签、配置Mapper、开启驼峰命名映射以及执行SQL语句等,感兴趣的... 基于在前面几章我们已经学习了对MyBATis进行环境配置,并利用SqlSessionFactory核

MyBatis延迟加载的处理方案

《MyBatis延迟加载的处理方案》MyBatis支持延迟加载(LazyLoading),允许在需要数据时才从数据库加载,而不是在查询结果第一次返回时就立即加载所有数据,延迟加载的核心思想是,将关联对... 目录MyBATis如何处理延迟加载?延迟加载的原理1. 开启延迟加载2. 延迟加载的配置2.1 使用

Android WebView的加载超时处理方案

《AndroidWebView的加载超时处理方案》在Android开发中,WebView是一个常用的组件,用于在应用中嵌入网页,然而,当网络状况不佳或页面加载过慢时,用户可能会遇到加载超时的问题,本... 目录引言一、WebView加载超时的原因二、加载超时处理方案1. 使用Handler和Timer进行超

Nacos集群数据同步方式

《Nacos集群数据同步方式》文章主要介绍了Nacos集群中服务注册信息的同步机制,涉及到负责节点和非负责节点之间的数据同步过程,以及DistroProtocol协议在同步中的应用... 目录引言负责节点(发起同步)DistroProtocolDistroSyncChangeTask获取同步数据getDis