在 RedisTypedClient 上使用 BlockingDequeue 时,我得到了看起来像超时异常的情况。
调用代码看起来像
using (var client = ClientPool.GetClient())
return client.As<TMessage>().Lists[_channel].BlockingDequeue(timeout);
其中超时设置为 0,ClientPool 是 PooledRedisClientManager。
堆栈跟踪看起来像
ServiceStack.Redis.RedisResponseException: No more data, sPort: 51100, LastCommand:
at ServiceStack.Redis.RedisNativeClient.CreateResponseError(String error)
at ServiceStack.Redis.RedisNativeClient.ReadMultiData()
at ServiceStack.Redis.RedisNativeClient.SendExpectMultiData(Byte[][] cmdWithBinaryArgs)
at ServiceStack.Redis.RedisNativeClient.BRPop(String listId, Int32 timeOutSecs)
at ServiceStack.Redis.Generic.RedisTypedClient`1.BlockingDequeueItemFromList(IRedisList`1 fromList, Nullable`1 timeOut)
at ServiceStack.Redis.Generic.RedisClientList`1.BlockingDequeue(Nullable`1 timeOut)
据我所知,这是客户端保持打开连接的问题。我认为这应该通过使用 PooledRedisClientManager 来解决,但它似乎仍然会发生。这个问题很容易重现。只需调用 BlockingDequeue 方法并等待大约 2-3 分钟,就会抛出异常。