Расскажите о своем опыте работы с RabbitMQ в Go. Какие библиотеки и паттерны вы использовали?

Ну, слушай, вот сидишь ты такой, пишешь на Go, и тут тебе надо, чтобы одно приложение на другом конце сервера пиздануло сообщение, а второе его подхватило, да не сразу, а когда захочет. И тут, блядь, на сцену выходит RabbitMQ — этакая мартышлюшка-посредник, которая всё организует.

Раньше все, как дурачки, юзали streadway/amqp, а она, сука, уже лет пять как накрылась медным тазом. Теперь надо брать официальную — github.com/rabbitmq/amqp091-go. Её хоть кто-то поддерживает, не то что те древние артефакты.

Чтобы не выглядеть полным дегенератом, запомни главные термины, а то потом будешь как Герасим — мычать «Муму» и нихуя не понимать.

Producer — это тот, кто пиздаёт сообщения. Как я, когда начинаю нести хуйню после трёх бутылок пива. Exchange (Обменник) — получает эти посылы и решает, куда их дальше толкать. У него есть свои приколы: direct (точно в цель), topic (по шаблону, типа «всё, что про собак»), fanout (всем сестрам по серьгам) и headers (для совсем ебнутых сценариев). Queue (Очередь) — это, блядь, просто очередь. Сообщения тут тупо висят, пока их не заберут. Binding — невидимая ниточка, которая связывает обменник и очередь. Без неё — пиздец, сообщения улетают в никуда. Consumer — это алкаш, который подходит к стойке бара (очереди) и забирает свою порцию сообщений.

Паттерны, которые реально работают:

• Work Queues — когда задач дохуища, и ты нанимаешь толпу рабов (workers), чтобы они их расхерачивали. Одно сообщение — один раб.
• Publish/Subscribe — это когда ты орал на всю деревню, а тебя слышали все, у кого уши не заложило. Используешь fanout exchange.
• Routing — уже поумнее. Кричишь «Собирайся, Вань!», и только Ваня откликается. Это direct exchange.
• Topics — военная хитрость. Можешь орать «собака.*», и тебя услышат все, у кого есть «собака.лает» или «собака.спит». topic exchange, ёпта.

А вот, смотри, как отправить сообщение. Просто скопируй этот кусок кода, не еби мозг:

import (
    "context"
    "log"
    "time"
    amqp "github.com/rabbitmq/amqp091-go"
)

// ...

conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
// handle err
defer conn.Close()

ch, err := conn.Channel()
// handle err
defer ch.Close()

// Объявляем очередь, куда будем отправлять сообщения
q, err := ch.QueueDeclare(
    "hello", // name
    false,   // durable
    false,   // delete when unused
    false,   // exclusive
    false,   // no-wait
    nil,     // arguments
)
// handle err

ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()

err = ch.PublishWithContext(ctx,
    "",     // exchange (пустое значение - default exchange)
    q.Name, // routing key (имя очереди для default exchange)
    false,  // mandatory
    false,  // immediate
    amqp.Publishing{
        ContentType: "text/plain",
        Body:        []byte("Hello World!"),
    },
)
// handle err

И главное, блядь, не забудь про две вещи, а то наебнёшься:

1. Acknowledgements (Подтверждения). Consumer должен явно сказать: «О, спасибо, сообщение получил, обработал, всё чики-пуки» (ack). Или «На хуй это дерьмо, дай другое» (nack). Без этого твои сообщения будут теряться, как носки в стиральной машине.
2. Graceful Shutdown. Когда приложение закрывается, надо аккуратно прибраться: закрыть каналы и соединение. А то останешься как тот мудак, который ушёл, не заплатив в баре, — на тебя все собаки будут вешать лапшу.