Redis истекает не работает
-
27-10-2019 - |
Вопрос
Я использую serviceStack.redis (строить из последних источников: https://github.com/servicestack/servicestack.redis/tree/master/src).
Я делаю что -то вроде этого:
CacheRecord foundKey = cacheRecords.GetById(p_sParentKey);
...
CacheRecord cacheRecord = cacheRecords.Store(foundKey);
...
redisClient.Expire(p_sParentKey, validityPeriodInMinutes * 60);
Я пытался отлаживать с помощьюConsole.WriteLine(cacheRecords.GetTimeToLive(p_sParentKey));
который возвращается -00:00:01
Анкет Не имеет значения, какое значение я присваиваю валидности.
Я старался Expire
, ExpireAt
, ExpireEntryAt
, ExpireEntryIn
. Анкет Я также пробовал что -то вроде этого:
int epoch = (int)(DateTime.UtcNow.AddSeconds(validityPeriodInMinutes) - new DateTime(1970, 1, 1)).TotalSeconds;
redisClient.ExpireAt(p_sParentKey, epoch);
Есть идеи?
[Serializable]
public class CacheRecord
{
public CacheRecord()
{
this.Children = new List<CacheRecordChild>();
}
public string Id { get; set; }
public List<CacheRecordChild> Children { get; set; }
}
#endregion
#region public class CacheRecordChild
[Serializable]
public class CacheRecordChild
{
public string Id { get; set; }
public string Data { get; set; }
}
public void AddKey(string p_sParentKey, string p_sChildKey, string p_sData, int validityPeriodInMinutes)
{
using (ServiceStack.Redis.RedisClient redisClient = new ServiceStack.Redis.RedisClient())
{
using (var cacheRecords = redisClient.GetTypedClient<CacheRecord>())
{
CacheRecord foundKey = cacheRecords.GetById(p_sParentKey);
if (foundKey == null)
{
foundKey = new CacheRecord();
foundKey.Id = p_sParentKey;
CacheRecordChild child = new CacheRecordChild();
child.Id = p_sChildKey;
child.Data = p_sData;
foundKey.Children.Add(child);
CacheRecord cacheRecord = cacheRecords.Store(foundKey);
//redisClient.Expire(p_sParentKey, validityPeriodInMinutes);
redisClient.Expire(p_sParentKey, validityPeriodInMinutes * 60);
}
else
{
CacheRecordChild child = new CacheRecordChild();
child.Id = p_sChildKey;
child.Data = p_sData;
foundKey.Children.Add(child);
CacheRecord cacheRecord = cacheRecords.Store(foundKey);
// redisClient.Expire(p_sParentKey, validityPeriodInMinutes);
// redisClient.Expire(p_sParentKey, validityPeriodInMinutes * 60);
// int epoch = (int)(DateTime.UtcNow.AddSeconds(validityPeriodInMinutes) - new DateTime(1970, 1, 1)).TotalSeconds;
redisClient.Expire(p_sParentKey, validityPeriodInMinutes * 60);
}
}
}
}
Решение
Извините, но я не могу очень хорошо прочитать ваш код, чтобы узнать, что вы делаете не так.
У меня есть довольно несколько тестов на срок действия истечения с истекания, вот некоторые ниже, которые могут лучше продемонстрировать, как его использовать:
[Test]
public void Can_Expire()
{
Redis.SetEntry("key", "val");
Redis.Expire("key", 1);
Assert.That(Redis.ContainsKey("key"), Is.True);
Thread.Sleep(2000);
Assert.That(Redis.ContainsKey("key"), Is.False);
}
[Test]
public void Can_ExpireAt()
{
Redis.SetEntry("key", "val");
var unixNow = DateTime.Now.ToUnixTime();
var in1Sec = unixNow + 1;
Redis.ExpireAt("key", in1Sec);
Assert.That(Redis.ContainsKey("key"), Is.True);
Thread.Sleep(2000);
Assert.That(Redis.ContainsKey("key"), Is.False);
}
Если у вас все еще есть проблема, не могли бы вы опубликовать запускаемый фрагмент кода или суть, чтобы я мог лучше прочитать ваш код.
РЕДАКТИРОВАТЬ: Ответ на пример кода
Когда вы используете напечатанный клиент, ключ, который в конечном итоге хранится в Redis, выглядит как:
'urn:CacheRecord:' + p_sParentKey
Который отличается от того, что вы используете в своем примере:
redisClient.Expire(p_sParentKey, validityPeriodInMinutes * 60);
Итак, есть несколько способов получить урн ключ Это используется в Redis. Если у вас есть сущность, вы можете использовать метод расширения Tourn (), например,
var cacheKey = foundKey.ToUrn();
В противном случае, если у вас просто есть «ID», вы можете создать урн ключ как:
var cacheKey = IdUtils.CreateUrn<CacheRecord>(p_sParentKey);
Оттуда вы можете истечь из своей записи:
redisClient.Expire(cacheKey, validityPeriodInMinutes * 60);
Хотя я понимаю, как это не интуитивно понятно, поэтому я буду добавлять RedistypedClient.expiryin Метод в будущей версии, которая сделает это автоматически для вас. Это должно позволить вам сделать что -то вроде:
cacheRecords.ExpireIn(p_sParentKey, TimeSpan.FromMinutes(validityPeriodInMinutes));
РЕДАКТИРОВАТЬ: Добавлены перегрузки метода:
Я добавил приведенный выше метод в последней версии клиента Redis (v2.07), который вы можете скачать здесь:https://github.com/servicestack/servicestack.redis/downloads
С тестами с использованием вашей CachereCord.
Кстати: клиент Redis на самом деле не нуждается в атрибуте [Serializer].