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));
}
