Golang RabbitMQ work模式, 实现多个消费者并发消费。
说明：
P 代表生产者 , C1、C2 代表消费者，红色代表队列。
提示：每条消息只能被一个消费者消费
前置教程
请先阅读Golang RabbitMQ快速入门教程，了解golang对RabbitMQ的基本操作，如果不了解RabbitMQ请先阅读前面的章节。
并发消费
golang主要使用协程实现多个消费者，下面是多个消费者的实现方式。
提示：如何发送消息请参考Golang RabbitMQ快速入门教程。
package main
import (
"log"
"time"
"github.com/streadway/amqp"
)
// 错误处理
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
// 连接RabbitMQ
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
// 通过协程创建5个消费者
for i := 0; i < 5; i++ {
go func(number int) {
// 创建一个rabbitmq信道, 每个消费者一个
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
// 声明需要操作的队列
q, err := ch.QueueDeclare(
"hello", // 队列名
false, // 是否需要持久化
false, // delete when unused
false, // exclusive
false, // no-wait
nil, // arguments
)
failOnError(err, "Failed to declare a queue")
// 创建一个消费者
msgs, err := ch.Consume(
q.Name, // 需要操作的队列名
"", // 消费者唯一id，不填，则自动生成一个唯一值
true, // 自动提交消息（即自动确认消息已经处理完成）
false, // exclusive
false, // no-local
false, // no-wait
nil, // args
)
failOnError(err, "Failed to register a consumer")
// 循环处理消息
for d := range msgs {
log.Printf("[消费者编号=%d] 收到消息: %s", number, d.Body)
// 模拟业务处理，休眠1秒
time.Sleep(time.Second)
}
}(i)
}
// 挂起主协程，避免程序退出
forever := make(chan bool)
<-forever
}
提示：rabbitmq无论使用何种类型的交换机(exchange)，队列都可以拥有多个消费者，启动多个消费者的方式以本例相同。