首頁 > 後端開發 > Golang > golang實作rabbitmq監聽

golang實作rabbitmq監聽

PHPz
發布: 2023-05-10 10:53:06
原創
632 人瀏覽過

我們知道,訊息佇列是一種常用的解決非同步處理、任務分發等問題的架構模式,而RabbitMQ則是目前使用最廣泛的訊息中間件之一。在實際應用中,我們可能需要使用Golang來實現RabbitMQ的監聽,本文將介紹如何使用Golang實現RabbitMQ的監聽。

準備工作

在開始之前,需要確保已經安裝RabbitMQ。由於RabbitMQ依賴Erlang,所以還需要安裝Erlang。

安裝完成之後,我們需要安裝Golang第三方套件。其中,AMQP套件是必不可少的,它可以讓我們很方便地連接和操作RabbitMQ。

go get github.com/streadway/amqp

程式碼實作

首先,我們需要連接到RabbitMQ。連線成功後,我們需要宣告一個名為「test」、類型為「fanout」的exchange。 exchange是RabbitMQ中實現訊息路由的重要組成部分,它負責接收訊息並將它們分發給佇列。在這種情況下,我們將聲明一個名為“test”的exchange,並將其類型設為“fanout”,這意味著它將訊息廣播給所有訂閱了它的佇列。

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()

# err = ch.ExchangeDeclare(

"test",   // name
"fanout", // type
true,     // durable
false,    // auto-deleted
false,    // internal
false,    // no-wait
nil,      // arguments
登入後複製

)
failOnError(err, "Failed to declare an exchange")

接下來,我們需要創建一個新的、非持久的、具有自動產生名稱的隊列。在這裡,我們將使用隊列的名稱來綁定它們與剛剛聲明的「test」exchange。

q, err := ch.QueueDeclare(

"",    // name
false, // durable
false, // delete when unused
true,  // exclusive
false, // no-wait
nil,   // arguments
登入後複製

)
failOnError(err, "Failed to declare a queue")

err = ch.QueueBind(

q.Name, // queue name
"",     // routing key
"test", // exchange
false,
nil,
登入後複製

)
failOnError(err, "Failed to bind a queue")

現在,RabbitMQ已經準備就緒,我們可以開始監聽它的訊息了。我們可以使用Consume函數來實作訊息監聽,它可以使我們持續不斷地接收來自佇列的訊息,並對它們進行處理。

msgs, err := ch.Consume(

q.Name, // queue name
"",     // consumer
true,   // auto-ack
false,  // exclusive
false,  // no-local
false,  // no-wait
nil,    // args
登入後複製

)
failOnError(err, "Failed to register a consumer")

for msg := range msgs {

log.Printf("Received a message: %s", msg.Body)
登入後複製

}

在上述程式碼中,我們使用了ch.Consume()方法來監聽指定佇列中的消息,並透過列印日誌的方式輸出了訊息內容。需要注意的是,我們使用了一個死循環來部署進行訊息監聽,這意味著我們會一直監聽佇列,直到程式被停止或出現錯誤。

完整程式碼如下:

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()

err = ch.ExchangeDeclare(
    "test",   // name
    "fanout", // type
    true,     // durable
    false,    // auto-deleted
    false,    // internal
    false,    // no-wait
    nil,      // arguments
)
failOnError(err, "Failed to declare an exchange")

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

err = ch.QueueBind(
    q.Name, // queue name
    "",     // routing key
    "test", // exchange
    false,
    nil,
)
failOnError(err, "Failed to bind a queue")

msgs, err := ch.Consume(
    q.Name, // queue name
    "",     // consumer
    true,   // auto-ack
    false,  // exclusive
    false,  // no-local
    false,  // no-wait
    nil,    // args
)
failOnError(err, "Failed to register a consumer")

for msg := range msgs {
    log.Printf("Received a message: %s", msg.Body)
}
登入後複製

}

總結

本文介紹如何使用Golang來實作rabbitmq的監聽,首先我們需要連線到rabbitmq,宣告一個exchange,建立一個佇列並將佇列與exchange進行綁定,最後使用消費者來監聽佇列中的消息。希望本文能對正在使用Golang進行rabbitmq開發的開發者們有所幫助。

以上是golang實作rabbitmq監聽的詳細內容。更多資訊請關注PHP中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板