StackExchange Redis的分区密钥空间

我IDatabase现在创建了一个提供密钥空间分区的包装器.

包装器是使用扩展方法创建的 IDatabase

    ConnectionMultiplexer multiplexer = ConnectionMultiplexer.Connect("localhost");
    IDatabase fullDatabase = multiplexer.GetDatabase();
    IDatabase partitioned = fullDatabase.GetKeyspacePartition("my-partition");

几乎所有分区包装器中的方法都具有相同的结构:

public bool SetAdd(RedisKey key, RedisValue value, CommandFlags flags = CommandFlags.None)
{
    return this.Inner.SetAdd(this.ToInner(key), value, flags);
}

它们只是将调用转发到内部数据库,并RedisKey在传递它们之前将键空间前缀添加到任何参数.

的CreateBatch和CreateTransaction的方法简单地创建用于这些接口包装,但具有相同的基包装类(如最包裹方法由定义IDatabaseAsync).

在KeyRandomAsync与KeyRandom不支持的方法.调用将抛出一个NotSupportedException.对我来说这不是一个问题,引用@Marc Gravell:

我无法想到实现这一目标的任何理智方式,但我怀疑NotSupportedException("指定键前缀时不支持RANDOMKEY")完全合理(这不是常用的命令)

我还没有实现ScriptEvaluate,ScriptEvaluateAsync因为我不清楚如何处理RedisResult返回值.这些方法的输入参数接受RedisKey哪些应该加前缀,但脚本本身可以返回键,在这种情况下,我认为(最有意义的是)取消修正这些键.目前,这些方法将抛出NotImplementedException......

排序方式(Sort,SortAsync,SortAndStore和SortAndStoreAsync)有特殊处理by和get参数.这些都是正常的前缀,除非它们具有以下特殊值之一:nosortfor by和#for get.

最后,为了允许前缀ITransaction.AddCondition我必须使用一点反射:

internal static class ConditionHelper
{
    public static Condition Rewrite(this Condition outer, Func<RedisKey, RedisKey> rewriteFunc)
    {
        ThrowIf.ArgNull(outer, "outer");
        ThrowIf.ArgNull(rewriteFunc, "rewriteFunc");

        Type conditionType = outer.GetType();
        object inner = FormatterServices.GetUninitializedObject(conditionType);

        foreach (FieldInfo field in conditionType.GetFields(BindingFlags.NonPublic | BindingFlags.Instance))
        {
            if (field.FieldType == typeof(RedisKey))
            {
                field.SetValue(inner, rewriteFunc((RedisKey)field.GetValue(outer)));
            }
            else
            {
                field.SetValue(inner, field.GetValue(outer));
            }
        }

        return (Condition)inner;
    }
}

包装器使用这个帮助器,如下所示:

internal Condition ToInner(Condition outer)
{
    if (outer == null)
    {
        return outer;
    }
    else
    {
        return outer.Rewrite(this.ToInner);
    }
}

有几种其他ToInner方法可以包含不同类型的参数,RedisKey但它们或多或少都会最终调用:

internal RedisKey ToInner(RedisKey outer)
{
    return this.Prefix + outer;
}

我现在已经为此创建了一个pull请求:

https://github.com/StackExchange/StackExchange.Redis/pull/92

现在调用扩展方法,WithKeyPrefix并且不再需要用于重写条件的反射黑客,因为新代码可以访问Condition类的内部.