如何确保消息平均发送到所有消费者

Question

我们公司在Go中建立了push服务，为了保证传输速度，我们在四台机器上安装了push服务，当我们需要发送通知时，我们将消息发送给rabbitMQ，然后push服务从队列中获取消息，但有时我们发现只有一台机器获取消息。

msgs, err := ch.Consume(
    q.Name,      // queue
    consumerTag, // consumer
    true,        // auto-ack
    false,       // exclusive
    false,       // no-local
    false,       // no-wait
    nil,         // args
)

我应该如何设置配置以确保每个消费者获得相同数量的消息？

Answer 1

RabbitMQ只是将消息发送给订阅者，而不检查未确认的消息。要获得公平和循环分发，可以执行以下操作

>

首先在消费者通道中设置QoS

    err = ch.Qos(
        1,     // prefetch count
        0,     // prefetch size
        false, // global
)

接下来，在使用者中将自动确认设置为false

    msgs, err := ch.Consume(
        q.Name, // queue
        "",     // consumer
        false,  // auto-ack
        false,  // exclusive
        false,  // no-local
        false,  // no-wait
        nil,    // args
)

msg.ack(false)

这种模式被称为工作队列，这也避免了消息的丢失，如果使用者在发送ack之前出现故障，那么这些消息将被重新排队并交付给另一个使用者进行处理。更多信息，您可以查看此链接