• 2014/07/11, RabbitMQ & AMQP
• 2015/02/12, Python RabbitMQ
• 2015/04/01, RabbitMQ 管理命令
• 2015/05/04, pika 01: 基础
• 2015/05/04, pika 02: BlockingConnection
• 2015/05/05, pika 03: SelectConnection
• 2015/05/06, pika 04: TornadoConnection
• 2016/02/12, Java RabbitMQ
• 2018/01/31, RabbitMQ 集群
• 2018/04/01, 面试题：RabbitMQ 相关
• 2018/10/02, pika: AsyncioConnection
• 2018/10/06, 使用 RabbitMQ 遇到的一个小问题
• 2019/01/12, 延迟队列
• 2020/10/03, 常见的消息队列
• 2021/06/18, Golang RabbitMQ

RabbitMQ 是啥就不说了，怎么安装部署也不说了，就记录一下 RabbitMQ 在 Golang 开发中的应用。

说明：采用 github.com/streadway/amqp 库。

func (ch *Channel) Publish(exchange, key string, mandatory, immediate bool, msg Publishing) error
func (ch *Channel) Consume(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, args Table) (<-chan Delivery, error)

生产者

生产者基本流程

生产者：连接

1. amqp.Dial -> amqp.Connection
2. amqp.Connection.Channel -> amqp.Channel

conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
    log.Fatalf("Failed to connect to RabbitMQ: %s", err)
}
ch, err := conn.Channel()
if err != nil {
    log.Fatalf("Failed to open a channel: %s", err)
}

生产者：配置（可选）

事先把 MQ 配好就行，但从稳妥起见，还是在连接时加上比较好。

1. amqp.Channel.QueueDeclare
2. amqp.Channel.ExchangeDeclare
3. amqp.Channel.QueueBind

q, err := ch.QueueDeclare(
    "hello", // 队列名称
    true,    // 持久化
    false,   // 自动删除
    false,   // 独占
    false,   // 等待服务器回应
    nil,     // 额外参数
)
if err != nil {
    log.Fatalf("Failed to declare a queue: %s", err)
}

生产者：发送

1. amqp.Channel.Publish

err = ch.Publish(
    "",     // exchange
    q.Name, // routing key
    false,  // mandatory
    false,  // immediate
    amqp.Publishing{
        ContentType: "text/plain",
        Body:        []byte("hello world"),
    })
if err != nil {
    log.Fatalf("Failed to publish a message: %s", err)
}

生产者：收尾

1. amqp.Connection.Close
2. amqp.Channel.Close

消费者

消费者基本流程

和生产者基本一致。只是调用的的是 chan.Consume 而不是 chan.Publish。
然后就是配置阶段，消费者只用关心队列在不在。

参考资料与拓展阅读

• RabbitMQ Tutorials