XACK

语法
XACK key group id [id ...]
可用版本
5.0.0
时间复杂度
每个处理的消息 ID 的时间复杂度为 O(1)。
ACL 类别
@write, @stream, @fast,

XACK 命令从流消费者组的待处理条目列表 (PEL) 中移除一个或多个消息。当消息被传递给某个消费者时,该消息将被视为待处理消息并存储在 PEL 中,通常是调用 XREADGROUP 的副作用,或者当消费者调用 XCLAIM 获取消息的所有权时。待处理消息被传递给某个消费者,但服务器尚未确定它是否至少被处理过一次。因此,对 XREADGROUP 的新调用以获取消费者的消息历史记录(例如,使用 ID 0),将返回此类消息。类似地,待处理消息将被 XPENDING 命令列出,该命令检查 PEL。

消费者在成功处理消息后,应调用 XACK,以便此类消息不再被处理,作为副作用,有关此消息的 PEL 条目也将被清除,从而释放 Redis 服务器的内存。

示例

redis> XACK mystream mygroup 1526569495631-0
(integer) 1

RESP2/RESP3 回复

整数回复: 该命令返回成功确认的消息数量。某些消息 ID 可能不再是 PEL 的一部分(例如,因为它们已经被确认),而 XACK 不会将它们计入成功确认的消息。
RATE THIS PAGE
Back to top ↑