Redis Expire не работает - PullRequest
Новая
       17

Redis Expire не работает

5 голосов
/ 17 марта 2011

Я использую 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. Не имеет значения, какое значение я присваиваю validityPeriodInMinutes.

Я пытался также 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);
                }
            }
        }
    }

1 Ответ

15 голосов
/ 18 марта 2011

Извините, но я не могу очень хорошо прочитать ваш код, чтобы узнать, что вы делаете неправильно.

У меня есть довольно много тестов для операций Expire, ExpireAt, вот некоторые из них нижекоторый может лучше продемонстрировать, как его использовать:

https://github.com/ServiceStack/ServiceStack.Redis/blob/master/tests/ServiceStack.Redis.Tests/RedisClientTests.cs

[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);

Таким образом, есть пара способов получить ключ urn , который используется в 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 Client (v2.07)которую вы можете скачать здесь: https://github.com/ServiceStack/ServiceStack.Redis/downloads

С тестами, использующими ваш CacheRecord .

Кстати: клиент Redis фактически не нуждается в атрибуте [Serializer].

...