将数据从字典批量设置为Redis

Question

我正在使用StackExchange Redis DB插入键值对的字典，Batch如下所示：

private static StackExchange.Redis.IDatabase _database;
public void SetAll<T>(Dictionary<string, T> data, int cacheTime)
{
    lock (_database)
    {
        TimeSpan expiration = new TimeSpan(0, cacheTime, 0);
        var list = new List<Task<bool>>();
        var batch = _database.CreateBatch();               
        foreach (var item in data)
        {
            string serializedObject = JsonConvert.SerializeObject(item.Value, Formatting.Indented,
        new JsonSerializerSettings { ContractResolver = new SerializeAllContractResolver(), ReferenceLoopHandling = ReferenceLoopHandling.Ignore });

            var task = batch.StringSetAsync(item.Key, serializedObject, expiration);
            list.Add(task);
            serializedObject = null;
        }
        batch.Execute();

        Task.WhenAll(list.ToArray());
    }
}

我的问题： 仅设置350项字典需要 7秒钟 左右。

我的问题： 这是将批量商品设置为Redis的正确方法，还是有一种更快的方法？任何帮助表示赞赏。谢谢。

Answer 1

“公正”是一个非常相对的术语，没有更多的上下文就没有任何意义，尤其是：这些有效载荷有多大？

但是，请澄清一些要点，以帮助您进行调查：

• IDatabase除非纯粹出于您的目的，否则无需锁定an ；SE.Redis内部处理线程安全，旨在供竞争线程使用
• 目前，您的时间将包括所有序列化代码（JsonConvert.SerializeObject）；这将加起来， 尤其是 当您的对象很大时；得到一个体面的措施，我强烈建议你的时间序列化和Redis的时间 分别
• 该batch.Execute()方法使用管道API，并且不等待调用之间的响应，因此：您所看到的时间 不是 延迟的累积影响；只剩下本地CPU（用于序列化），网络带宽和服务器CPU；客户端库工具不会影响任何这些事情
• 有一个StringSet接受的重载KeyValuePair<RedisKey, RedisValue>[]; 您 可以 选择使用它而不是批处理，但是这里唯一的区别是，它是方尖的MSET而不是多重的SET；无论哪种方式，您都将在此时间内阻止其他调用者的连接（因为批处理的目的是使命令连续）
• 您 实际上 不需要在CreateBatch这里使用， 尤其是 因为您正在锁定数据库（但是我仍然建议您不需要这样做）；的目的CreateBatch是使一系列命令 顺序化 ，但是我看不到您在这里需要这个；您可以只_database.StringSetAsync依次使用每个命令，这 还 具有与发送前一条命令 并行 运行序列化的优势-它可以让您重叠序列化（绑定CPU）和redis ops（绑定IO）除删除CreateBatch呼叫外无任何工作；这也意味着您不会垄断其他呼叫者的连接

所以; 我要做的 第一 件事是 删除 一些代码：

private static StackExchange.Redis.IDatabase _database;
static JsonSerializerSettings _redisJsonSettings = new JsonSerializerSettings {
    ContractResolver = new SerializeAllContractResolver(),
    ReferenceLoopHandling = ReferenceLoopHandling.Ignore };

public void SetAll<T>(Dictionary<string, T> data, int cacheTime)
{
    TimeSpan expiration = new TimeSpan(0, cacheTime, 0);
    var list = new List<Task<bool>>();
    foreach (var item in data)
    {
        string serializedObject = JsonConvert.SerializeObject(
            item.Value, Formatting.Indented, _redisJsonSettings);

        list.Add(_database.StringSetAsync(item.Key, serializedObject, expiration));
    }
    Task.WhenAll(list.ToArray());
}

我要做的第二件事是将序列化与redis的工作分开计时。

我要做的第三件事是看我是否可以序列化为MemoryStream一个我可以重复使用的，理想情况下可以避免重复使用-
避免string分配和UTF-8编码：

using(var ms = new MemoryStream())
{
    foreach (var item in data)
    {
        ms.Position = 0;
        ms.SetLength(0); // erase existing data
        JsonConvert.SerializeObject(ms,
            item.Value, Formatting.Indented, _redisJsonSettings);

        list.Add(_database.StringSetAsync(item.Key, ms.ToArray(), expiration));
    }
}