RabbitMQ Golang教程

RabbitMQ Golang教程


  • 首先,使用go get安装amqp

    go get github.com/streadway/amqp

发送


我们将消息发布者(发送者)称为 send.go,将消息消费者(接收者)称为receive.go。发布者将连接到RabbitMQ,发送一条消息,然后退出。

package mainimport (
"github.com/streadway/amqp"
"log")func failOnError(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}}func main()  {
conn,err := amqp.Dial("amqp://admin:admin@xx.xxx.xxx.xxx: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", // name
false,   // durable
false,   // delete when unused
false,   // exclusive
false,   // no-wait
nil,     // arguments
)
failOnError(err, "Failed to declare a queue")

body := "Hello World!"

err = ch.Publish(
"",     // exchange
q.Name, // routing key
false,  // mandatory
false,  // immediate
amqp.Publishing{
ContentType: "text/plain",
Body:        []byte(body),
})
failOnError(err, "Failed to publish a message")
log.Printf(" [x] Sent %s", body)}

接收


上面是我们的发布者。我们的消费者监听来自RabbitMQ的消息,因此与发布单个消息的发布者不同,我们将使消费者保持运行状态以监听消息并打印出来。

该代码(在receive.go中)具有与send相同的导入和帮助功能:

package mainimport (
"github.com/streadway/amqp"
"log")func failOnErrors(err error, msg string) {
if err != nil {
log.Fatalf("%s: %s", msg, err)
}}func main()  {
conn,err := amqp.Dial("amqp://admin:admin@xx.xxx.xxx.xxx:5672/")
failOnErrors(err, "Failed to connect to RabbitMQ")
defer conn.Close()

ch, err := conn.Channel()
failOnErrors(err, "Failed to open a channel")
defer ch.Close()

q, err := ch.QueueDeclare(
"hello", // name
false,   // durable
false,   // delete when unused
false,   // exclusive
false,   // no-wait
nil,     // arguments
)
failOnErrors(err, "Failed to declare a queue")

msgs, err := ch.Consume(
q.Name, // queue
"",     // consumer
true,   // auto-ack
false,  // exclusive
false,  // no-local
false,  // no-wait
nil,    // args
)
failOnErrors(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}
(0)

相关推荐