Redis 使用 Lua 模糊查詢所有key 及 相對應的集合總數
.Net 4.5.1
需要引入: StackExchange.Redis (測試用的 1.2.4.0)
方法一:
優點:原子操作,對於大數據操作快,lua 語法難寫。
var Prefix = "Cache"; //Key 前綴,關鍵詞 var dic = new Dictionary<string, long>(); //轉換為鍵值隊 var db = new Multiplexer(name).GetMultiplexer().GetDatabase(); //redis 連接 var pattern = Prefix + "*"; // 模糊查詢 //lua 語法,詳情可查看官方文檔 var lua = @"local glob = @keypattern local t = { } local keys = redis.call('keys', glob) for iter, value in ipairs(keys) do table.insert(t, { value, redis.call('llen', value) }) end return t";
var redisResult = db.ScriptEvaluate(LuaScript.Prepare(lua), new { @keypattern = pattern });
if (!redisResult.IsNull) { //將key 及value 插入 鍵值隊 var result = (RedisResult[])redisResult; foreach (var item in result) { var kvs = (RedisResult[])item; var key = ((RedisValue)kvs.First()).ToString(); var value = (long)(RedisValue)kvs.Last(); dic.Add(key, value); } }
方法二:
優點:小量數據查詢使用方便,需要多次與 Redis 交互統計。
因為不是原子操作,存在統計出來的數據量不准確;
var dic = new Dictionary<string, int>(); var _connMultiplexer = new Multiplexer(name).GetMultiplexer(); var _server = _connMultiplexer.GetServer(_connMultiplexer.GetEndPoints()[0]); //默認一個服務器 var pattern = this.Prefix + "*"; var keys = _server.Keys(database: this.database, pattern: pattern); var db = this.GetDatabase(); foreach (var item in keys) { dic.Add(item.ToString().Replace(this.Prefix, ""), db.ListLength(item)); }