从ServiceStack.Redis管道读取值

Question

如何从ServiceStack.Redis管道读取值？我在GitHub上看到了一些例子，但如果同时有许多QueueCommands (例如，10000 )，我不确定代码是否能正确工作。

QueueCommand的回调似乎是一个异步操作。每个QueueCommand都可以有一个回调。当调用Pipeline.Flush()时，所有的QueueCommands都将以管道模式发送到Redis，当执行其中一个QueueCommands时，将调用它的回调。

我的问题是:当Pipeline.Flush()完成时，库是否保证执行所有回调？

下面是ServiceStack.Redis on GitHub的代码

    [Test]
    public void Can_call_single_operation_with_callback_3_Times_in_pipeline()
    {
        var results = new List<long>();
        Assert.That(Redis.GetValue(Key), Is.Null);
        using (var pipeline = Redis.CreatePipeline())
        {
            pipeline.QueueCommand(r => r.IncrementValue(Key), results.Add);
            pipeline.QueueCommand(r => r.IncrementValue(Key), results.Add);
            pipeline.QueueCommand(r => r.IncrementValue(Key), results.Add);
            //Can I assume that when Flush() finishes, 
            //all 3 callbacks (results.Add) would have finished?
            pipeline.Flush();
        }

        Assert.That(Redis.GetValue(Key), Is.EqualTo("3"));
        Assert.That(results, Is.EquivalentTo(new List<long> { 1, 2, 3 }));
    }

Answer 1

您可以在以下文件中找到Redis管道API的一些测试：

• RedisPipelineTests.cs
• RedisPipelineCommonTests.cs
• RedisTypedPipelineTests.cs

是的，当您在Redis管道上调用.Flush()时，将所有缓冲命令刷新为redis。会执行所有排队的回调。