c# - 尝试在 Redis 的 2 组中插入 750 个项目时出现 StackExchange TimeoutException

Question

最初我试图将一些项目集合插入到 2 个 redis 集合中(也许这根本不是个好主意，但是......)。我尝试一次添加的条目数:750+

目前，我在尝试使用 StackExchange.redis 客户端执行此操作时收到超时异常，有趣的是我能够使用“旧版”booksleeve 完成类似操作 我之前调查过的客户。

所以，我肯定在某些地方错了(甚至可能在我最初的 bookSleeve 实现中)，只是想找出到底错在哪里。以下是我与 redis 客户端一起使用的代码示例:书套:

using (var tran = connection.CreateTransaction())
{
Task lastOpTask = null;
tran.SuspendFlush();
try
{
    // perform required configurations/ actions
    tran.Sets.Add(_redisConfiguration.DbNumber, CurrentIdsSetDbKey, stringIds);
    tran.Sets.Add(_redisConfiguration.DbNumber, CurrentDetailsSetDbKey, stringDetails);
    lastOpTask = tran.Execute();
    isOperationSuccessful = true;
}
catch (TaskCanceledException ex)
{
    ...
}
catch (TimeoutException ex1)
{
    ...
}
finally
{
    tran.ResumeFlush();
}

if (lastOpTask != null)
{
    connection.Wait(lastOpTask);
    ...
}
}

StackExchange.redis 实现相同代码:

var tran = db.CreateTransaction();

// todo: do we need to add here any condition or PipeLining? any watch/unwatch verifications?
tran.SetAddAsync(CurrentIdsSetDbKey, stringIds);
tran.SetAddAsync(CurrentDetailsSetDbKey, stringDetails);

try
{
    isOperationSuccessful = tran.Execute();
}
catch (TaskCanceledException ex)
{
    ...
}
catch (TimeoutException ex1)
{
    ...
}

开始单元测试后，我收到 StackExchange 客户端的下一个错误:

消息:执行 EXEC 超时，inst:3，queue:3，qu=0，qs=3，qc=0，wr=0/0

来源:在 StackExchange.Redis.ConnectionMultiplexer.ExecuteSyncImpl[T](Message 消息，ResultProcessor1 处理器，ServerEndPoint 服务器) 在 c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\ConnectionMultiplexer .cs:1693行
在 StackExchange.Redis.RedisBase.ExecuteSync[T](Message message, ResultProcessor1 processor, ServerEndPoint server) 在 c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\RedisBase.cs:line 92
在 StackExchange.Redis.RedisTransaction.Execute(CommandFlags 标志)在 c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\RedisTransaction.cs:line 51
在 DFS.Cache.CacheManager.RedisStackExchange.RedisContestCacheManager.RegisterAvailableContests(IList1 比赛) 在 d:\Projects\DFS\Code\DFS\DFS.Cache.CacheManager.RedisStackExchange\RedisContestCacheManager.cs:line 131

只是想知道我到底做错了什么。预先感谢您提出任何建议!

附言对于 stackEchange.redis 配置，我使用的是来自 github 的 Marc 提供的配置示例(可在此处获取:StackExchange/StackExchange.Redis/blob/master/Docs/Configuration.md)

附言请查看当前的 StackExchange 客户端配置文件:

var config = new ConfigurationOptions
{
    EndPoints =
        {
            {"MasterIP", 6379},
            {"SlaveIP", 6380}
        },
    CommandMap = CommandMap.Create(new HashSet<string>
        {
            // EXCLUDE a few commands (to work with data-flow-related mode only)
            "INFO",
            "CONFIG",
            "CLUSTER",
            "PING",
            "ECHO",
            "CLIENT"
        }, available: false),
    KeepAlive = 60, // 60 sec to ensure connection is alive
    ConnectTimeout = 5000, // 5 sec
    SyncTimeout = 5000, // 5 sec
    ServiceName = "mymaster", // sentinel service name
    DefaultVersion = new Version(2, 8, 8),
    Password = "password"
};

标准条目(成套使用)看起来像:

{
    "Id":"08e5ffdbced046cb8f55c50e4bab822d",
    "Entries":0,
    "State":"i",
    "Name":"very dummy entry name value: autoGet 299",
    "Summary": "entry summary details, some long string 299, some common info, some data: true, 8200"
    "IsMultiple":true,
    "IsPublic":true,
    "MaxEntries":8200,
    "IsEntryVisible":true,
    "StartDate":"9/10/2014 12:00:00 AM"
}

附言在 Marc 的回应之后，我进行了几次测试并在单元测试中遇到了一些其他错误，例如

{"Timeout performing SISMEMBER set:raw:Ids, inst: 1, queue: 6, qu=0, qs=6, qc=0, wr=0/0"} when set contains not more than 300 items. 

所以我同意这是连接问题，与当前切换到 StackExchange.redis 客户端无关。

Answer 1

以下通过得很好，并在本地报告 10 毫秒。如果您能稍微填写一下空白，我将非常感兴趣，这样我就可以做一个重现该问题的代表性测试。请注意，qu=0, qs=3 告诉我，在超时时，我们正在等待 Redis 服务器响应。显然本地带宽和延迟会很有趣，但从根本上说，它应该可以工作。我也对您的同步超时设置感兴趣。

using System.Diagnostics;
using System.Linq;
using NUnit.Framework;

namespace StackExchange.Redis.Tests.Issues
{
    [TestFixture]
    public class SO22786599 : TestBase
    {
        [Test]
        public void Execute()
        {
            string CurrentIdsSetDbKey = Me() + ".x";
            string CurrentDetailsSetDbKey = Me() + ".y";

            RedisValue[] stringIds = Enumerable.Range(1, 750).Select(i => (RedisValue)(i + " id")).ToArray();
            RedisValue[] stringDetails = Enumerable.Range(1, 750).Select(i => (RedisValue)(i + " detail")).ToArray();

            using (var conn = Create())
            {
                var db = conn.GetDatabase();
                var tran = db.CreateTransaction();

                tran.SetAddAsync(CurrentIdsSetDbKey, stringIds);
                tran.SetAddAsync(CurrentDetailsSetDbKey, stringDetails);

                var watch = Stopwatch.StartNew();
                var isOperationSuccessful = tran.Execute();
                watch.Stop();
                System.Console.WriteLine("{0}ms", watch.ElapsedMilliseconds);
                Assert.IsTrue(isOperationSuccessful);                
            }
        }
    }
}