linzhiqiang / aix.redisstreammessagebus Goto Github PK

使用linq2db，做简单的单表插入记录 ，使用1个线程没有问题，多个线程肯定会有很多失败，错误信息The connection does not support MultipleActiveResultSets ，

MyMultithreadTaskExecutor里面有什么需要注意的吗

await _processExecuter.AddProcess(new ErrorWorkerProcess(_serviceProvider), "redis失败任务处理");
注释掉了？

RedisMessageBus消费失败,topic:redis:messagebus:BusinessMessageDemo1，groupName:default-group
StackExchange.Redis.RedisCommandException: Multi-key operations must involve a single slot; keys can use 'hash tags' to help this, i.e. '{/users/12345}/account' and '{/users/12345}/contacts' will always be in the same slot
at StackExchange.Redis.ServerSelectionStrategy.Select(Message message) in //src/StackExchange.Redis/ServerSelectionStrategy.cs:line 109
at StackExchange.Redis.ConnectionMultiplexer.PrepareToPushMessageToBridge[T](Message message, ResultProcessor1 processor, IResultBox1 resultBox, ServerEndPoint& server) in //src/StackExchange.Redis/ConnectionMultiplexer.cs:line 2206
at StackExchange.Redis.ConnectionMultiplexer.TryPushMessageToBridgeAsync[T](Message message, ResultProcessor1 processor, IResultBox1 resultBox, ServerEndPoint& server) in //src/StackExchange.Redis/ConnectionMultiplexer.cs:line 2209
at StackExchange.Redis.ConnectionMultiplexer.ExecuteAsyncImpl[T](Message message, ResultProcessor1 processor, Object state, ServerEndPoint server) in /_/src/StackExchange.Redis/ConnectionMultiplexer.cs:line 2711 at StackExchange.Redis.RedisBase.ExecuteAsync[T](Message message, ResultProcessor1 processor, ServerEndPoint server) in //src/StackExchange.Redis/RedisBase.cs:line 47
at StackExchange.Redis.RedisTransaction.ExecuteAsync(CommandFlags flags) in /_/src/StackExchange.Redis/RedisTransaction.cs:line 59
at Aix.RedisStreamMessageBus.RedisImpl.RedisStorage.EnqueueDealy(JobData jobData, TimeSpan delay) in F:\jovi\gitProjects\Aix.RedisStreamMessageBus\src\Aix.RedisStreamMessageBus\RedisImpl\RedisStorage.cs:line 109
at Aix.RedisStreamMessageBus.BackgroundProcess.WorkerProcess.Handle(StreamEntry streamEntry, JobData jobData) in F:\jovi\gitProjects\Aix.RedisStreamMessageBus\src\Aix.RedisStreamMessageBus\BackgroundProcess\WorkerProcess.cs:line 162
at Aix.RedisStreamMessageBus.BackgroundProcess.WorkerProcess.HandleWrap(StreamEntry streamEntry, JobData jobData) in F:\jovi\gitProjects\Aix.RedisStreamMessageBus\src\Aix.RedisStreamMessageBus\BackgroundProcess\WorkerProcess.cs:line 134