Redis 发布/订阅确认/确认

Question

Redis Pub/Sub 中有确认的概念吗？

例如，当使用 RabbitMQ 时，我可以让两个工作人员在不同的机器上运行，当我将消息发布到队列时，只有一个工作人员会确认/确认并处理消息。

但是我发现使用 Redis Pub/Sub，两个工作人员都会处理消息。

考虑这个简单的例子，我在两台不同的机器/客户端上运行了这个 go 例程：

go func() {

    for {

        switch n := pubSubClient.Receive().(type) {

        case redis.Message:

            process(n.Data)

        case redis.Subscription:

            if n.Count == 0 {

                return

            }

        case error:

            log.Print(n)

        }

    }

}()

当我发布消息时：

conn.Do("PUBLISH", "tasks", "task A")

两个 go 例程都会接收它并运行 process 函数。

有没有办法实现与 RabbitMQ 类似的行为？例如，第一个确认消息的工作人员将是唯一一个接收并处理它的工作人员。

Answer 1

Redis PubSub 更像是一种广播机制。如果你想要队列，你可以使用BLPOP和RPUSH来获得相同的交互。请记住，RabbitMQ 会执行 Redis 中没有的各种其他功能。但是，如果您正在寻找简单的作业调度/请求处理风格，这将工作得很好。

Answer 2

不，Redis 的 PubSub 不保证交付，也不限制可能收到消息的订阅者的数量。