Почему ServiceStack.Redis не использует SET Timeout для получения блокировки? - PullRequest
Новая
       51

Почему ServiceStack.Redis не использует SET Timeout для получения блокировки?

0 голосов
/ 09 декабря 2018

если вы посмотрите на код класса RedisLock.cs , вы увидите, что он читает значение блокировки для проверки самого тайм-аута вне Redis, а также использует Watch и Unwatch для перезаписи значения тайм-аута, если никтокоснулся этого.

Другими словами, каковы точные точки использования наблюдения, отмены и фиксации, когда мы можем использовать внутренние тайм-ауты Redis, которые еще более надежны? 

ExecUtils.RetryUntilTrue(() =>{
    //This pattern is taken from the redis command for SETNX http://redis.io/commands/setnx

    //Calculate a unix time for when the lock should expire
    var realSpan = timeOut ?? new TimeSpan(365, 0, 0, 0); //if nothing is passed in the timeout hold for a year
    var expireTime = DateTime.UtcNow.Add(realSpan);
    var lockString = (expireTime.ToUnixTimeMs() + 1).ToString();

    //Try to set the lock, if it does not exist this will succeed and the lock is obtained
    var nx = redisClient.SetValueIfNotExists(key, lockString);
    if (nx)
        return true;

    //If we've gotten here then a key for the lock is present. This could be because the lock is
    //correctly acquired or it could be because a client that had acquired the lock crashed (or didn't release it properly).
    //Therefore we need to get the value of the lock to see when it should expire

    redisClient.Watch(key);
    var lockExpireString = redisClient.Get<string>(key);
    if (!long.TryParse(lockExpireString, out var lockExpireTime))
    {
        redisClient.UnWatch();  // since the client is scoped externally
        return false;
    }

    //If the expire time is greater than the current time then we can't let the lock go yet
    if (lockExpireTime > DateTime.UtcNow.ToUnixTimeMs())
    {
        redisClient.UnWatch();  // since the client is scoped externally
        return false;
    }

    //If the expire time is less than the current time then it wasn't released properly and we can attempt to 
    //acquire the lock. The above call to Watch(_lockKey) enrolled the key in monitoring, so if it changes
    //before we call Commit() below, the Commit will fail and return false, which means that another thread 
    //was able to acquire the lock before we finished processing.
    using (var trans = redisClient.CreateTransaction()) // we started the "Watch" above; this tx will succeed if the value has not moved 
    {
        trans.QueueCommand(r => r.Set(key, lockString));
        return trans.Commit(); //returns false if Transaction failed
    }
},timeOut);

Потому что библиотека StackExchange.Redisэквивалентно использовать только возможности string.set.несмотря на то, что механизм блокировки ServiceStackRedis является более продвинутым и будет ждать и повторять попытки, пока не получит блокировку, но все еще не использует тайм-ауты самой команды REDIS SET, это не оправдано. 

public bool LockTake(RedisKey key, RedisValue value, TimeSpan expiry, CommandFlags flags = CommandFlags.None)            {
    if (value.IsNull) throw new ArgumentNullException(nameof(value));
    return StringSet(key, value, expiry, When.NotExists, flags);
}
...