我在这里看到一个有趣的提示:
The timeout was reached before the message could be written to the output buffer
我认为,基本上,redis告诉你清除传入的消息,因为它是
消防炮
你的数据。很可能你已经创建了一个范围相当广的订阅。
我也经历过同样的经历,结果只是把数据塞进了内存缓存(又名
ConcurrentQueue<T>
)在订阅lambda上,并在一个单独的、受限制的线程中处理消息结果,该线程将检查队列并处理内容,这是典型的生产者-消费者队列方法。这时超时错误消失了。
