代码之家 › 专栏 › 技术社区 › SoT

Redis流式传输如何路由消息

redis-streams redis

0

SoT · 技术社区 · 3 年前

redis流中是否存在类似kafka路由密钥的概念? 我们有许多微服务实例(比如说10个),我们打算创建一个消费者组,每个消费者都是一个实例。我们希望只有当实例n读取/订阅流时(基于消息本身内部的一些标准),才会读取/检索实例n的消息。有可能吗?

0 回复 | 直到 3 年前

1

Efran Cobisi 3 年前

无法在Redis中保留消息或将消息路由到特定的消费者: XREADGROUP command 则返回的消息将绑定到指定的使用者——必须预先指定使用者。

话虽如此,Redis允许通过 XCLAIM command ,一旦读取。正因为如此,您可以在某种程度上模仿预订/路由,让一个专门的调度器消费者只持续读取未送达的消息(通过 外部参照组 命令连同特殊ID > )并通过 [希腊语]赞美 命令根据他们的内容向预期的目标消费者提供。每个 有规律的 消费者读取消息 已交付但仍未确认 顺便提一下 外部参照组 命令连同起始ID 0 ,根据业务逻辑处理每条消息,最后 XACK 将其从PEL中移除。

根据参考文件:

特辑>ID,这意味着消费者只希望接收从未发送给任何其他消费者的消息。这只是意味着,给我新的信息。

另一方面,目标消费者只会用 外部参照组 命令。