C# 怎么连接 Redis 并进行操作_C# Redis 连接与操作完整指南

来源:这里教程网 时间:2026-02-21 17:29:35 作者:

在 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(db.StringGet("person:1"));

基本上就这些。掌握以上内容,你就可以在 C# 项目中熟练使用 Redis 实现高性能数据读写和通信了。

相关推荐