go怎么实现消息队列_运维文库_资讯中心

发布时间:2026-04-26 09:39:55

阅读量:2

在Go语言中，你可以使用第三方库来实现消息队列。目前比较常用的消息队列库有：

RabbitMQ：RabbitMQ是一个开源的消息队列系统，使用AMQP协议来实现消息的传递。你可以使用Go语言的第三方库github.com/streadway/amqp来与RabbitMQ进行交互。
Apache Kafka：Kafka是一个分布式的、高吞吐量的消息队列系统，使用发布-订阅模式来处理消息。你可以使用Go语言的第三方库github.com/Shopify/sarama来与Kafka进行交互。
NSQ：NSQ是一个实时分布式消息平台，具有高可用性和可伸缩性。你可以使用Go语言的第三方库github.com/nsqio/go-nsq来与NSQ进行交互。

下面是一个使用RabbitMQ的简单示例：

package main
import (
"log"
"github.com/streadway/amqp"
)
func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}
}
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
failOnError(err, "Failed to connect to RabbitMQ")
defer conn.Close()
ch, err := conn.Channel()
failOnError(err, "Failed to open a channel")
defer ch.Close()
q, err := ch.QueueDeclare(
"hello", // 队列名称
false,   // 是否持久化
false,   // 是否自动删除
false,   // 是否独占队列
false,   // 是否等待消费者自动删除
nil,     // 其他参数
)
failOnError(err, "Failed to declare a queue")
msgs, err := ch.Consume(
q.Name, // 队列名称
"",     // 消费者标识符
true,   // 自动应答
false,  // 是否排他队列
false,  // 是否非阻塞
false,  // 其他参数
)
failOnError(err, "Failed to register a consumer")
forever := make(chan bool)
go func() {
for d := range msgs {
log.Printf("Received a message: %s", d.Body)
}
}()
log.Printf(" [*] Waiting for messages. To exit press CTRL+C")
<-forever
}