Удалить / Удалить все / один элемент из кэша StackExchange.Redis
Я использую клиент StackExchange.Redis с Azure Redis Cache Service. Вот мой класс,
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
}
}
Обновление: от помощи Марка, вот мой последний класс
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.
5 ответов
Чтобы удалить один элемент:
_cache.KeyDelete(key);
Чтобы удалить все включает FLUSHDB
или же FLUSHALL
команда redis; оба доступны в StackExchange.Redis; но по причинам, обсуждаемым здесь, они не на IDatabase
API (потому что: они влияют на серверы, а не на логические базы данных).
Согласно "Так, как я их использую?" на этой странице:
server.FlushDatabase(); // to wipe a single database, 0 by default
server.FlushAllDatabases(); // to wipe all databases
(вполне возможно после использования GetEndpoints()
на мультиплексоре)
Я не смог очистить базу данных в Azure Redis Cache, получил эту ошибку:
Эта операция недоступна, если не включен режим администратора: 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);
}
Оба ответа @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.
Вы также можете удалить хеш, т.е. если вы хотите удалить определенное значение из любого кэшированного списка. Например, у нас есть список emp и внутри с другим отделом как кэшированным.
public static void DeleteHash(string key, string cacheSubKey)
{
if (string.IsNullOrEmpty(key))
throw new ArgumentNullException("key");
Cache.HashDelete(key, cacheSubKey);
}
так что вы можете передать ключ и имя кеша.
Чтобы удалить элемент из списка в распределенном кэше, используйте функцию ListRemoveAsync(), поддерживаемую библиотекой распределенного кэша , доступ к которой можно получить через интерфейс IDistributedCache .
public async Task RemoveListByIndexAsync(string key, string cacheValue)
{
RedisValue redisValue = cacheValue // value of item in the list to be removed;
await _cache.ListRemoveAsync(key, redisValue);
}
- ключ — ключ cacahe redisValue
- item - элемент в списке, который нужно удалить.
Примечание. Убедитесь, что значение Redis, которое необходимо удалить, должно соответствовать элементу списка, существующего в кеше.