Чтобы гарантировать, что сообщение из очереди обработается ровно один раз при наличии нескольких воркеров, нужно использовать механизмы, обеспечивающие атомарность и контроль обработки:

Использование транзакций и подтверждений (acknowledgements): Воркеры должны подтверждать обработку сообщения только после успешного завершения работы. Если воркер упал до подтверждения, сообщение возвращается в очередь.
Блокировка сообщений: Очередь должна поддерживать механизм блокировки сообщения на время обработки, чтобы другие воркеры не могли его взять.
Идемпотентность обработки: Даже при повторной доставке обработка должна быть безопасной и не приводить к дублированию эффектов.
Использование специализированных очередей: Например, RabbitMQ с подтверждениями, Kafka с контролем смещений (offsets) и commit, или Redis Streams с consumer groups.

Пример с RabbitMQ на Go (используя библиотеку streadway/amqp):

msgs, err := ch.Consume(
    queueName, "", false, false, false, false, nil,
)

for d := range msgs {
    // Обработка сообщения
    err := processMessage(d.Body)
    if err == nil {
        d.Ack(false) // Подтверждаем обработку
    } else {
        d.Nack(false, true) // Сообщение вернется в очередь
    }
}

Таким образом, только один воркер подтвердит сообщение, и оно не будет обработано повторно.

Как гарантировать, что сообщение из очереди обработается ровно один раз, если воркеров несколько?