我在messenger中使用redis作为传输,我认为在处理流之后,删除是自动的,但不是。我不知道在处理成功后如何删除重复流。我使用symfony4.4.latest和redisserver6.0谢谢
jum4pzuy1#
方法是使用xtrim命令。您可以调用process来处理两条消息,您可以修剪流以仅保留未处理的消息。通过调用xlen,可以得到流的大小,如果减去处理的消息量,就应该为xtrim留下正确的参数。
1条答案
按热度按时间jum4pzuy1#
方法是使用xtrim命令。
您可以调用process来处理两条消息,您可以修剪流以仅保留未处理的消息。通过调用xlen,可以得到流的大小,如果减去处理的消息量,就应该为xtrim留下正确的参数。