首先安装StackExchange.Redis包,然后通过ConnectionMultiplexer建立连接并实现字符串、哈希、列表等操作及发布订阅功能。

在 C# 中连接并操作 Redis 是现代开发中常见的需求,尤其适用于缓存、会话存储和消息队列等场景。本文将详细介绍如何使用 StackExchange.Redis(最常用的 .NET Redis 客户端)实现 C# 与 Redis 的连接及常用操作。
安装 StackExchange.Redis
要在项目中使用 Redis,首先需要安装 StackExchange.Redis NuGet 包:
- 通过 NuGet 包管理器命令:
Install-Package StackExchange.Redis
- 或使用 .NET CLI:
dotnet add package StackExchange.Redis
建立 Redis 连接
StackExchange.Redis 使用 ConnectionMultiplexer 类来管理连接。这个类是线程安全的,建议在整个应用生命周期中只创建一个实例。
示例代码:
using StackExchange.Redis;
class RedisHelper
{
private static ConnectionMultiplexer _connection;
private static string _redisConnectionString = "localhost:6379"; // 修改为你的 Redis 地址
public static ConnectionMultiplexer GetConnection()
{
if (_connection == null || !_connection.IsConnected)
{
_connection = ConnectionMultiplexer.Connect(_redisConnectionString);
// 可选:订阅连接事件用于日志监控
_connection.ConnectionFailed += (sender, e) =>
Console.WriteLine($"Redis 连接失败: {e.Exception}");
}
return _connection;
}
}
执行基本数据操作
获取数据库对象后,可以进行字符串、哈希、列表等操作。
1. 字符串操作(SET/GET)
var db = RedisHelper.GetConnection().GetDatabase();
// 设置值
db.StringSet("name", "Alice");
// 获取值
var name = db.StringGet("name");
Console.WriteLine(name); // 输出: Alice
2. 设置过期时间
db.StringSet("token", "abc123", TimeSpan.FromMinutes(10)); // 10分钟后过期
3. 哈希操作(Hash)
db.HashSet("user:1001", "name", "Bob");
db.HashSet("user:1001", "age", "25");
var userName = db.HashGet("user:1001", "name");
var userAge = db.HashGet("user:1001", "age");
Console.WriteLine($"{userName}, {userAge}");
4. 列表操作(List)
db.ListLeftPush("tasks", "task1");
db.ListLeftPush("tasks", "task2");
var task = db.ListRightPop("tasks"); // 出队
Console.WriteLine(task); // 输出: task1
5. 检查键是否存在
bool exists = db.KeyExists("name");
Console.WriteLine(exists); // True
发布与订阅(Pub/Sub)
Redis 支持消息发布与订阅模式,适合用于解耦系统模块。
订阅消息:
var sub = RedisHelper.GetConnection().GetSubscriber();
sub.Subscribe("chat", (channel, message) =>
Console.WriteLine($"收到消息: {message}");
sub.Publish("chat", "Hello Redis!");
注意事项与最佳实践
- ConnectionMultiplexer 是单例:不要频繁创建和释放连接,应全局复用。
- 处理连接中断:可通过订阅 ConnectionFailed 和 ConnectionRestored 事件进行监控。
- 异步操作支持:所有方法都有异步版本,如 StringSetAsync、StringGetAsync,推荐在 Web 应用中使用。
- 序列化复杂对象:Redis 只存储字符串或字节,对象需先序列化(如使用 JSON):
var json = JsonConvert.SerializeObject(person);
db.StringSet("person:1", json);
var person = JsonConvert.DeserializeObject
基本上就这些。掌握以上内容,你就可以在 C# 项目中熟练使用 Redis 实现高性能数据读写和通信了。










