Redis C# Driver
- StackExchange.Redis StackOverflow 出品
- ServiceStack.Redis 需要商業(yè)授權(quán)疯趟,免費(fèi)版本限制每小時(shí)的查詢次數(shù)
以下是StackExchange.Redis的基本使用方式
- ConnectionMultiplexer
是StackExchange.Redis中的核心類畸裳,字面意思是連接多路復(fù)用器,表示Redis服務(wù)器集群,也可以是單實(shí)例,支持同步或異步的方式進(jìn)行連接,可使用配置文件岩睁,可重用并且線程安全。
- IDatabase
幾乎所有StackExchange.Redis中操作Redis的方法都在IDatabase中锐极,從ConnectionMultiplexer對(duì)象中獲取
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
Redis中的五種基本數(shù)據(jù)類型的操作
類型 | 釋義 |
---|---|
string | 字符串 |
hash | 哈希 |
list | 列表 |
set | 集合 |
zset | 有序集合 |
- string 字符串
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
var value = "abcdefg";
db.StringSet("stringKey", value);
Console.WriteLine(db.StringGet("stringKey"));
- hash 哈希
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
// StackExchange.Redis 類庫(kù)中的數(shù)據(jù)類型k-v形式
var hash = new HashEntry[]
{
new HashEntry("1", "a"),
new HashEntry("2", "b"),
new HashEntry("3", "c")
};
db.HashSet("hashKey", hash);
var values = db.HashGet("hashKey", "1");
Console.WriteLine(values);
- list 列表
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
db.KeyDelete("listKey");
// RightPush表示在尾部插入笙僚, LeftPush表示在頭部插入
db.ListRightPush("listKey", "abcdefghi".Select(x => (RedisValue)x.ToString()).ToArray());
db.ListLeftPush("listKey", "jk".Select(x => (RedisValue)x.ToString()).ToArray());
var values = db.ListRange("listKey");
for (int i = 0; i < values.Length; i++)
{
Console.WriteLine(values[i]);
}
// 輸出結(jié)果為 : kjabcdefghi
- set 集合
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
int totalUnfiltered = 0;
int totalFiltered = 0;
for (int i = 0; i < 1000; i++)
{
db.SetAdd("setKey", i);
totalUnfiltered += i;
if (i.ToString().Contains("3"))
{
totalFiltered += i;
}
}
var unfilteredActual = db.SetScan("setKey").Select(x => (int)x).Sum();
Console.WriteLine($"totalUnfiltered:{totalUnfiltered} - unfilteredActual:{unfilteredActual}");
var filteredActual = db.SetScan("setKey", "*3*").Select(x => (int)x).Sum();
Console.WriteLine($"totalFiltered:{totalFiltered} - filteredActual:{filteredActual}");
- zset 有序集合
var redis = ConnectionMultiplexer.Connect("localhost");
IDatabase db = redis.GetDatabase();
db.SortedSetAdd("zsetKey", "a", 1);
db.SortedSetAdd("zsetKey", "b", 2);
db.SortedSetAdd("zsetKey", "c", 3);
var arr = db.SortedSetScan("zsetKey").ToArray();
Console.WriteLine(arr.Any(x => x.Element == "a" && x.Score == 1));
Console.WriteLine(arr.Any(x => x.Element == "b" && x.Score == 2));
Console.WriteLine(arr.Any(x => x.Element == "c" && x.Score == 3));