Redis 是一款高性能、开源的键值对存储系统。它支持多种数据结构,比如字符串、列表、哈希、集合等,可以在内存中存储数据,并提供持久化功能以便在断电等情况下保持数据不丢失。Redis 提供了丰富的命令和 API,可用于快速地读取、写入和操作数据。
本文介绍 3 款 .NET 流行的 Redis 客户端库。
1. StackExchange.Redis
StackExchange.Redis 是一个.NET 平台上的高性能、异步的 Redis 客户端库,由 StackExchange 团队开发。
StackExchange.Redis 通过使用异步方法和 IO 多路复用等技术,提高了 Redis 访问的性能和并发性。它还提供了丰富的功能和选项,如连接池、管道、事务、发布/订阅、Lua 脚本等,支持多种序列化和压缩方式,可以轻松地与其他.NET 应用程序集成。
StackExchange.Redis 还支持 Redis Sentinel 和 Redis Cluster 等高可用性和集群方案,使得应用程序可以更容易地管理和扩展 Redis 实例。因此,它是.NET 平台上访问 Redis 的首选客户端库之一。
下面是一个简单的使用示例:
首先,需要在项目中安装 StackExchange.Redis 包,可以通过 NuGet 管理器来安装,也可以手动下载安装。
然后,在代码中创建 ConnectionMultiplexer 对象,这个对象代表与 Redis 服务器的连接。通常来说,应该只创建一个 ConnectionMultiplexer 对象,然后在需要访问 Redis 数据库时使用它。
using StackExchange.Redis;
// 创建 ConnectionMultiplexer 对象
ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
接下来,可以使用 ConnectionMultiplexer 对象创建一个或多个 IDatabase 对象,这些对象用来执行实际的 Redis 命令。
// 获取 IDatabase 对象
IDatabase db = redis.GetDatabase();
现在可以使用 IDatabase 对象来执行各种 Redis 命令,比如设置和获取字符串值:
// 设置哈希表字段值
db.HashSet("myhash", new HashEntry[] { new HashEntry("field1", "value1"), new HashEntry("field2", "value2") });
// 获取哈希表字段值
HashEntry[] entries = db.HashGetAll("myhash");
foreach (var entry in entries)
{
Console.WriteLine(entry.Name + ": " + entry.Value);
}
除了字符串之外,StackExchange.Redis 还支持许多其他 Redis 数据类型,比如哈希表、列表、集合和有序集合。可以使用相应的 API 来执行相关的操作,比如:
// 设置哈希表字段值
db.HashSet("myhash", new HashEntry[] { new HashEntry("field1", "value1"), new HashEntry("field2", "value2") });
// 获取哈希表字段值
HashEntry[] entries = db.HashGetAll("myhash");
foreach (var entry in entries)
{
Console.WriteLine(entry.Name + ": " + entry.Value);
}
2. FreeRedis
基于 .NET 的 Redis 客户端,支持 .NET Core 2.1+、.NET Framework 4.0+ 以及 Xamarin。
功能特性:
-
• 🌈 所有方法名与 redis-cli 保持一致
-
• 🌌 支持 Redis 集群(服务端要求 3.2 及以上版本)
-
• ⛳ 支持 Redis 哨兵模式
-
• 🎣 支持主从分离(Master-Slave)
-
• 📡 支持发布订阅(Pub-Sub)
-
• 📃 支持 Redis Lua 脚本
-
• 💻 支持管道(Pipeline)
-
• 📰 支持事务
-
• 🌴 支持 GEO 命令(服务端要求 3.2 及以上版本)
-
• 🌲 支持 STREAM 类型命令(服务端要求 5.0 及以上版本)
-
• ⚡ 支持本地缓存(Client-side-cahing,服务端要求 6.0 及以上版本)
-
• 🌳 支持 Redis 6 的 RESP3 协议
🚀 快速入门
public static RedisClient cli = new RedisClient("127.0.0.1:6379,password=123,defaultDatabase=13");
//cli.Serialize = obj => JsonConvert.SerializeObject(obj);
//cli.Deserialize = (json, type) => JsonConvert.DeserializeObject(json, type);
cli.Notice += (s, e) => Console.WriteLine(e.Log); //打印命令日志
cli.Set("key1", "value1");
cli.MSet("key1", "value1", "key2", "value2");
string value1 = cli.Get("key1");
string[] vals = cli.MGet("key1", "key2");
🎣 Master-Slave (读写分离)
public static RedisClient cli = new RedisClient(
"127.0.0.1:6379,password=123,defaultDatabase=13",
"127.0.0.1:6380,password=123,defaultDatabase=13",
"127.0.0.1:6381,password=123,defaultDatabase=13"
);
var value = cli.Get("key1");
💻 Pipeline (管道)
using (var pipe = cli.StartPipe())
{
pipe.IncrBy("key1", 10);
pipe.Set("key2", Null);
pipe.Get("key1");
object[] ret = pipe.EndPipe();
Console.WriteLine(ret[0] + ", " + ret[2]);
}
🌌 Redis Cluster (集群)
假如你有一个 Redis Cluster 集群,其中有三个主节点(7001-7003)、三个从节点(7004-7006),则连接此集群的代码:
public static RedisClient cli = new RedisClient(
new ConnectionStringBuilder[] { "192.168.0.2:7001", "192.168.0.2:7002", "192.168.0.2:7003" }
);
3. NewLife.Redis
NewLife.Redis 是一个 Redis 客户端组件,以高性能处理大数据实时计算为目标。Redis 协议基础实现 Redis/RedisClient 位于 X 组件,本库为扩展实现,主要增加列表结构、哈希结构、队列等高级功能。
功能特性:
-
• 在 ZTO 大数据实时计算广泛应用,200 多个 Redis 实例稳定工作一年多,每天处理近 1 亿包裹数据,日均调用量 80 亿次
-
• 低延迟,Get/Set 操作平均耗时 200~600us(含往返网络通信)
-
• 大吞吐,自带连接池,最大支持 1000 并发
-
• 高性能,支持二进制序列化
基本操作
在基本操作之前,我们先做一些准备工作:
-
• 新建控制台项目,并在入口函数开头加上 XTrace.UseConsole(); ,这是为了方便查看调试日志
-
• 具体测试代码之前,需要加上前面 MemoryCache 或 Redis 的实例化代码
-
• 准备一个模型类 User
class User
{
public String Name { get; set; }
public DateTime CreateTime { get; set; }
}
添删改查:
var rds = new FullRedis("127.0.0.1", null, 7);
var user = new User { Name = "NewLife", CreateTime = DateTime.Now };
rds.Set("user", user, 3600);
var user2 = rds.Get("user");
XTrace.WriteLine("Json: {0}", user2.ToJson());
XTrace.WriteLine("Json: {0}", rds.Get("user"));
if (rds.ContainsKey("user")) XTrace.WriteLine("存在!");
rds.Remove("user");