redis - 阻塞直到完成计数

Question

我正在使用 Redis 流，需要阻止我的客户端，直到流中至少有 X 条消息并在达到 X 计数时返回。有没有办法实现这一点？

EG：XREADGROUP GROUP G1 C2 COUNT 10 BLOCK 0 STREAMS L >直到所有 10 条消息都到达流键

Answer 1

COUNT指定每个流返回的最大元素数（如果有）。如果流为空（并且BLOCK使用了该选项），则消费者阻塞。一旦有单条传入消息，阻塞就会随该消息一起释放。所以不，你不能阻止，直到COUNT消息被阅读。但是您可能可以在应用程序级别对消息进行分组。

有关XREAD更多详细信息，请参阅。