前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >.NET Core 实现 Redis 批量查询指定格式的Key

.NET Core 实现 Redis 批量查询指定格式的Key

原创
作者头像
晓晨
修改2018-09-05 22:02:17
2.5K0
修改2018-09-05 22:02:17
举报
文章被收录于专栏:晓晨的专栏

一. 问题场景

Redis 作为当前最流行的内存型 NoSQL 数据库,被许多公司所使用,作为分布式缓存。我们在实际使用中一般都会为 key 带上指定的前缀或者其他定义的格式。当由于我们程序出现bug,造成 redis 里面的存储的值,与我们预期的不一致时,我们可以通过查询指定格式的 key,来定位到我们具体的出现问题的key,从而方便我们解决问题。

二. 解决办法

1.Keys 命令

Keys 命令用于查找所有符合给定模式 pattern 的 key 。要求 Redis 版本大于 1.0.0。keys在查询大数量key时,会长时间阻塞Redis,由于Redis是单线程的,这就是一个突出的问题,需要注意。

2.Scan 命令

Scan 命令相对于 Keys 命令来说,优点就是不会阻塞服务器。要求 Redis 版本大于 2.8。

三. 代码实现

这里采用的Redis驱动是 StackExchange.Redis。

在 StackExchange.Redis 里封装 Redis 命令时分为了两种,一种是针对于集群的命令,一种是针对于单个Redis服务器的命令,Keys 和 Scan 命令便是后者,我们在使用的时候必须在单独的服务器上执行。

Keys 和 Scan 命令都支持模糊查询,这里介绍三种匹配符:

  1. \* 表示可以匹配**多个**任意字符
  2. ? 表示可以匹配**单个**任意字符
  3. [] 表示可以匹配**指定范围**内的字符

因为我们的key可能分布在集群内多个Redis服务器上,所以我们需要在每台服务器上都执行命令。我们可以通过 ConnectionMultiplexer.GetEndPoints() 方法来获取所有的终结点信息。

在 StackExchange.Redis 对于 keys 和 scan 命令统一封装为了 IServer.Keys()方法,它会自动根据Redis服务器版本来决定使用keys命令还是scan命令。

为了方便测试,我在 Redis 里面准备了四个以 test 为前缀的key,放在序号为1的db里面:

1535608206837
1535608206837
  1. 遍历所有前缀为 test 的key 代码如下:
代码语言:txt
复制
static async Task Main(string[] args)

{

    //创建连接

    var conn = await ConnectionMultiplexer.ConnectAsync("192.168.10.110");

    //获取db

    var db = conn.GetDatabase(1);

    //遍历集群内服务器

    foreach (var endPoint in conn.GetEndPoints())

    {

        //获取指定服务器

        var server = conn.GetServer(endPoint);

        //在指定服务器上使用 keys 或者 scan 命令来遍历key

        foreach (var key in server.Keys(1,"test.\*"))

        {

            //获取key对于的值

            var val = db.StringGet(key);

            Console.WriteLine($"key: {key}, value: {val}");

        }

    }

}

执行结果:

1535608290825
1535608290825
  1. []的用法

假设我要遍历 key为 test.1-test.3 的数据,可以这样写:

代码语言:txt
复制
static async Task Main(string[] args)

{

    //创建连接

    var conn = await ConnectionMultiplexer.ConnectAsync("192.168.10.110");

    //获取db

    var db = conn.GetDatabase(1);

    //遍历集群内服务器

    foreach (var endPoint in conn.GetEndPoints())

    {

        //获取指定服务器

        var server = conn.GetServer(endPoint);

        //在指定服务器上使用 keys 或者 scan 命令来遍历key

        foreach (var key in server.Keys(1,"test.[1-3]"))

        {

            //获取key对于的值

            var val = db.StringGet(key);

            Console.WriteLine($"key: {key}, value: {val}");

        }

    }

}

执行结果:

1535608429827
1535608429827

假设我要遍历 key为 test.1和test.4 的数据,可以这样写:

代码语言:txt
复制
static async Task Main(string[] args)

{

    //创建连接

    var conn = await ConnectionMultiplexer.ConnectAsync("192.168.10.110");

    //获取db

    var db = conn.GetDatabase(1);

    //遍历集群内服务器

    foreach (var endPoint in conn.GetEndPoints())

    {

        //获取指定服务器

        var server = conn.GetServer(endPoint);

        //在指定服务器上使用 keys 或者 scan 命令来遍历key

        foreach (var key in server.Keys(1,"test.[1,4]"))

        {

            //获取key对于的值

            var val = db.StringGet(key);

            Console.WriteLine($"key: {key}, value: {val}");

        }

    }

}

执行结果:

1535608506604
1535608506604

好了,关于 Redis 查询指定格式的 key 的方法就介绍到这里了。

四. 参考资料

Where are KEYS, SCAN, FLUSHDB etc? by StackExchange.Redis

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 一. 问题场景
  • 二. 解决办法
    • 1.Keys 命令
      • 2.Scan 命令
      • 三. 代码实现
      • 四. 参考资料
      相关产品与服务
      云数据库 Redis
      腾讯云数据库 Redis(TencentDB for Redis)是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备,提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档