如何防止Redis流内存无限增加？

Question

我刚刚意识到，当只有一个消费群体存在时，XACK不会自动删除消息。

我以为当所有的消费者组都收到相同的消息时，消息会被Redis-server删除，但似乎不是这样。

因此，Redis流内存无限增加，因为没有消息会被删除。

也许防止这种情况的唯一方法是手动发送XDEL消息？但我怎么知道所有的消费者群体都接受了这个信息呢？

需要一些帮助，谢谢！

Answer 1

Redis streams主要是一种仅附加的数据结构。可以使用XDEL命令删除条目，但这并不一定会释放条目使用的内存：

> XDEL mystream 1538561700640-0
(integer) 1

您还可以使用MAXLEN选项对XADD设置任意阈值，或者显式使用XTRIM命令：

> XADD mystream MAXLEN 1000 * value 1
1526654998691-0
...
> XLEN mystream
(integer) 1000

但我怎么知道所有的消费者群体都接受了这个信息呢？

您可以使用XPENDING命令检查每个消费者组的挂起消息列表：

> XPENDING mystream mygroup
1) (integer) 1
2) 1526984818136-0
3) 1526984818136-0
4) 1) 1) "consumer-1"
      2) "1"