ServiceStack.Redis 数据操作

简单的字符串类型数据写. Poco在redis中会被序列化成Json字符串.

 　 using (var redis = new RedisClient(connString))
    {
    　　if (redis.Db != 7)
       　　((RedisClient)redis).ChangeDb(7);
 
    　　var client = redis.As<Poco>();
       var list = new List<Poco>();
        
       foreach(var key in keys)
       {
           list.Add(client.GetValue(key.ToString(CultureInfo.InvariantCulture)));
       }

    　　return list;
    }

Redis以快著称, 以上写法不是最快的.因为上边循环中每次都是进行了一个独立的Redis访问, 即进行了一次Query, 返回了一个Response

[req1]
     [====waiting=====]
                      [resp1]
                            [req2]
                                 [====waiting=====]
                                                  [resp2]

更快的写法是使用pipeline mode. Pipeline mode不会等待上一次Query的结果, 会立刻发送下一个Query. 每当有一条Response返回时, 它会对Response进行对应的Callback处理.

以下是代码实现:

此段代码摘自ServiceStack.Redis的测试类

    [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);
            pipeline.Flush();
        }

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