最初,我尝试 将一些项目集合插入2个redis集 (也许这根本不是个好主意,但是…)。我尝试一次添加 的条目数 : 750+
现在,当我 尝试使用StackExchange.redis 客户端 执行此操作时, 确实 会收到超时异常 ,这很有趣,我 能够使用 之前研究过的 “旧版”书架 客户端 完成类似的操作 。
因此,我肯定在某些方面(甚至在我的ine bookSleeve实现中)错了,只是想弄清楚到底是什么错。以下是我用于redis客户端的代码示例: BookSleeve:
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客户端的下一个错误:
Message: Timeout performing EXEC, inst: 3, queue: 3, qu=0, qs=3, qc=0, wr=0/0
Source: in StackExchange.Redis.ConnectionMultiplexer.ExecuteSyncImpl[T](Message message, ResultProcessor1 processor, ServerEndPoint server) in c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\ConnectionMultiplexer.cs:line 1693 in StackExchange.Redis.RedisBase.ExecuteSync[T](Message message, ResultProcessor1 processor, ServerEndPoint server) in c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\RedisBase.cs:line 92 in StackExchange.Redis.RedisTransaction.Execute(CommandFlags flags) in c:\TeamCity\buildAgent\work\18a91a3757cef937\StackExchange.Redis\StackExchange\Redis\RedisTransaction.cs:line 51 in DFS.Cache.CacheManager.RedisStackExchange.RedisContestCacheManager.RegisterAvailableContests(IList1 contests) in d:\Projects\DFS\Code\DFS\DFS.Cache.CacheManager.RedisStackExchange\RedisContestCacheManager.cs:line 131
只是想知道,我到底在做什么错。 预先感谢您的任何建议!
PS对于stackEchange.redis配置,我正在使用Marc从github提供的配置示例(可在此处找到:StackExchange / StackExchange.Redis / blob / master / Docs / Configuration.md)
PS请参阅当前的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" }
PS在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客户端无关。
以下通过就好了,并在本地报告10ms。如果您能填补空白,我将非常感兴趣,这样我就可以进行代表性测试来重现该问题。请注意,这qu=0, qs=3告诉我,在超时时,我们正在等待redis服务器响应。显然,本地带宽和延迟会很有趣,但是从根本上讲, 它应该可以工作 。我也会对您的同步超时设置感兴趣。
qu=0, qs=3
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); } } } }