xgroup 命令

该命令用于管理流数据结构关联的消费者组。使用 XGROUP 你可以：

• 创建与流关联的新消费者组。
• 销毁一个消费者组。
• 从消费者组中移除指定的消费者。
• 将消费者组的 最后交付ID 设置为其他内容。

语法

XGROUP [CREATE key groupname id-or-$][SETID key groupname id-or-$][DESTROY key groupname][DELCONSUMER key groupname consumername]

• [CREATE key groupname id-or-$]：创建消息消费组，id表示设置组的初始id（记录最后消费id，从该id之后开始读取消息），id为0表示组从stream的第一条数据开始读，id为$表示组从新的消息开始读取。
• [SETID key id-or-$]：设置消息组最后消费的id，用于读取该id之后的消息。
• [DESTROY key groupname]：销毁消息组。
• [DELCONSUMER keyroupname consumername]：清理消息组的消费者（组消费者从xreadgroup直接指定）。

• key：队列名称，如果不存在就创建。
• groupname：组名。
• $：表示从尾部开始消费，只接受新消息，当前 Stream 消息会全部忽略。

创建消费者组

要创建一个新的消费者组，请使用以下格式：

XGROUP CREATE mystream consumer-group-name $

最后一个参数是要考虑已传递的流中最后一项的ID。在上面的例子中，我们使用了特殊的ID ‘ $ ’（这表示：流中最后一项的ID）。在这种情况下，从该消费者组获取数据的消费者只能看到到达流的新元素。

但如果你希望消费者组获取整个流的历史记录，使用0作为消费者组的开始ID：

XGROUP CREATE mystream consumer-group-name 0

当然，可以使用任何其他有效的ID。如果指定的消费者组已经存在，则该命令将返回 -BUSYGROUP 错误。否则将执行该操作并返回OK。你可以为给定的流关联无限多的消费者组，没有硬性限制。

销毁消费者

可以使用以下形式完全销毁消费者：

XGROUP DESTROY mystream some-consumer-group

即使存在活动的消费者和待处理消息，消费者组也将被销毁，因此请确保仅在真正需要时才调用此命令。

要仅从消费者组中移除给定的消费者，使用以下命令格式：

XGROUP DELCONSUMER mystream consumergrouo myconsumer123

每当某个命令提到新的消费者名称时，就会自动创建消费者组中的消费者。但有时候删除旧的消费者可能会有用，因为他们已经不再使用。以上格式的命令返回消费者在被删除之前所拥有的待处理消息数量。

设置要传递的下一条消息

使用 SETID 子命令设置要传递的下一条消息。通常情况下，在消费者创建时设置下一个ID，作为 XGROUP CREATE 的最后一个参数。但是使用这种形式，可以在以后修改下一个ID，而无需再次删除和创建使用者组。例如，如果你希望消费者组中的消费者重新处理流中的所有消息，你可能希望将其下一个ID设置为0：

XGROUP SETID mystream my-consumer-group 0

最后，如果您不记得语法，请使用HELP子命令：

XGROUP HELP