50

我正在使用带有 Azure Redis 缓存服务的 StackExchange.Redis 客户端。这是我的课，

public class RedisCacheService : ICacheService
{
    private readonly ISettings _settings;
    private readonly IDatabase _cache;

    public RedisCacheService(ISettings settings)
    {
        _settings = settings;
        var connectionMultiplexer = ConnectionMultiplexer.Connect(settings.RedisConnection);
        _cache = connectionMultiplexer.GetDatabase();
    }

    public bool Exists(string key)
    {
        return _cache.KeyExists(key);
    }

    public void Save(string key, string value)
    {
        var ts = TimeSpan.FromMinutes(_settings.CacheTimeout);
        _cache.StringSet(key, value, ts);
    }

    public string Get(string key)
    {
        return _cache.StringGet(key);
    }

    public void Remove(string key)
    {
        // How to remove one
    }

    public void Clear()
    {
        // How to remove all
    }
}

更新：在 Marc 的帮助下，这是我的最后一堂课

public class RedisCacheService : ICacheService
{
    private readonly ISettings _settings;
    private readonly IDatabase _cache;
    private static ConnectionMultiplexer _connectionMultiplexer;

    static RedisCacheService()
    {
        var connection = ConfigurationManager.AppSettings["RedisConnection"];
        _connectionMultiplexer = ConnectionMultiplexer.Connect(connection);
    }

    public RedisCacheService(ISettings settings)
    {
        _settings = settings;
        _cache = _connectionMultiplexer.GetDatabase();
    }

    public bool Exists(string key)
    {
        return _cache.KeyExists(key);
    }

    public void Save(string key, string value)
    {
        var ts = TimeSpan.FromMinutes(_settings.CacheTimeout);
        _cache.StringSet(key, value, ts);
    }

    public string Get(string key)
    {
        return _cache.StringGet(key);
    }

    public void Remove(string key)
    {
        _cache.KeyDelete(key);
    }

    public void Clear()
    {
        var endpoints = _connectionMultiplexer.GetEndPoints(true);
        foreach (var endpoint in endpoints)
        {
            var server = _connectionMultiplexer.GetServer(endpoint);
            server.FlushAllDatabases();    
        }
    }
}

现在我不知道如何从 redis 缓存中删除所有项目或单个项目。

4

4 回答 4

70

要删除单个项目：

_cache.KeyDelete(key);

删除所有涉及到的FLUSHDBor FLUSHALLredis 命令；两者都在 StackExchange.Redis 中可用；但是，由于这里讨论的原因，它们不在IDatabaseAPI 上（因为：它们影响服务器，而不是逻辑数据库）。

根据“那么我该如何使用它们？” 在该页面上：

server.FlushDatabase(); // to wipe a single database, 0 by default
server.FlushAllDatabases(); // to wipe all databases

（很可能在GetEndpoints()多路复用器上使用后）

于 2014-07-02T13:09:51.207 回答
26

我无法在 Azure Redis 缓存中刷新数据库，出现此错误：

除非启用管理员模式，否则此操作不可用： FLUSHDB

而是遍历所有键以删除：

var endpoints = connectionMultiplexer.GetEndPoints();
var server = connectionMultiplexer.GetServer(endpoints.First());
//FlushDatabase didn't work for me: got error admin mode not enabled error
//server.FlushDatabase();
var keys = server.Keys();
foreach (var key in keys)
{
  Console.WriteLine("Removing Key {0} from cache", key.ToString());
  _cache.KeyDelete(key);
}
于 2014-07-07T11:46:23.260 回答
8

@Rasi 和 @Marc Gravell 的两个答案都包含所需的代码。基于上述，假设只有 1 台服务器，这是工作片段：

您需要使用 连接到 redis allowAdmin=true，获得此类选项的一种方法是将 AllowAdmin 分配给已解析的字符串：

var options = ConfigurationOptions.Parse("server:6379");
options.AllowAdmin = true;
var redis = ConnectionMultiplexer.Connect(options);

然后刷新所有数据库：

var endpoints = redis.GetEndPoints();
var server = redis.GetServer(endpoints[0]);
server.FlushAllDatabases();

以上将适用于任何 redis 部署，而不仅仅是 Azure。

于 2017-11-17T14:29:51.567 回答
1

您也可以删除哈希，即如果您想从任何缓存列表中清除特定值。例如，我们有一个 emp 列表，其中缓存了不同的部门。

public static void DeleteHash(string key, string cacheSubKey)
        {
            if (string.IsNullOrEmpty(key))
                throw new ArgumentNullException("key");

            Cache.HashDelete(key, cacheSubKey);
        }

因此您也可以传递密钥名称和缓存子密钥。

于 2019-02-24T22:41:27.637 回答