本文我將使用 Go 語言在 RabbitMQ 上發布和接收訊息，

Go 的標準庫本身并沒有 RabbitMQ 的原生系結，但是有一個第三方庫確能夠支持 RabbitMQ，它的原始碼在 https://github.com/streadway/amqp ，其檔案在 https://pkg.go.dev/github.com/streadway/amqp，

發布訊息到 RabbitMQ

建立一個 Go 的專案，并使用 go mod init 進行初始化：

mod init
go: creating new go.mod: module demo
main .go

使用 go get -u github.com/streadway/amqp 命令來安裝這個庫：

get —u github . com/streadway/amqp
go: downloading github . com/streadway/amqp vl.e.e
go: github . com/streadway/amqp upgrade vl.e.e

獲取 Queue

代碼如下：

x
ma ln.go
-GO main.go > getQueue
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
package main
import (
" fmt "
"log"
" github.com/streadway/amqp"
func main() { }
func failOnError(err
error,
if
err
log. Fatalf("%s: %s",
string) {
msg
err, msg)
panic(fmt.Sprintf( "%s: ,
err, msg))
func getQueue() (*amqp.Connection, *amqp.Channel, *amqp.Queue) {
amqp. Dial( " amqp : //guest?localhost : 5672 " )
conn, err
failOnError(err,
"Failed to connect to RabbitMQ")
conn. Channel()
ch, err
failOnError(err,
"Failed to open a channel")
ch . hello " ,
q, err
false,
false,
false,
false,
nil)
failOnError(err,
"Failed to declare a queue")
conn, ch,
return

首先匯入需要的包，主要是 streadway/amqp
第 12 行，撰寫處理錯誤的函式 failOnError
第 19 行，撰寫可以獲得 AMQP Connection、Channel、Queue 的幫助函式 getQueue()

我們知道我們需要將訊息發布到 Exchange 上面，但是如果使用默認 Exchange 的話，就可以使用一個捷徑：我們可以將訊息直接發送到 Queue 的名稱上（但實際并不是直接發送到 Queue 上面），

getQueue() 函式不用任何引數，它回傳三個物件：
1. *amqp.Connection 表示應用和 RabbitMQ 之間的網路連接
2. *amqp.Channel 位于 Connection 之上，它提供了用于雙方通信的通道，通過把 Connection 和 Channel 分開，客戶應用中就可以在同一個 Connection 上擁有多個 Channel 用來通信，這樣就減少了對資源的需求，
3. *amqp.Queue 也就是佇列
第 20 行，使用 amqp 的 Dial 函式可以回傳一個 Connection，Dial 函式的引數是 RabbitMQ 的 URL，URL 里面需要包含用戶憑證，
第 22 行，通過呼叫 Connection 物件上的 Channel 方法，創建一個 Channel
第 24 行，通過呼叫 Channel 物件上的 QueueDeclare 方法，回傳一個 Queue，注意：這個 Queue 不一定是被創建的，如果不存在指定名稱的 Queue，那么 RabbitMQ 就會創建一個；如果存在指定名稱的 Queue，但是和指定的配置不同，那么 RabbitMQ 就會拒絕這個請求，并拋出錯誤，
QueueDeclare 方法引數：
1. 第一個引數是 Queue 的名稱：我們就寫死一個 hello
2. 第二個引數是 durable bool，表示是否將添加到 Queue 的訊息存盤在硬碟上，如果這個引數值為 true，那么 RabbitMQ 服務器重啟之后訊息依然會存在，但是它會導致處理訊息的能力明顯下降，這里我把它設為 false，
3. 第三個引數 autoDelete bool，它會告訴 RabbitMQ 如果訊息沒有消費者應該怎么做：
  1. true：訊息就會從 Queue 中洗掉
  2. false：將訊息保留直到某個消費者前來獲取該訊息，這里我把它設為 false
4. 第四個引數 exclusive bool，它允許我們把這個 Queue 設定為只能從請求它的那個 Connection 上進行訪問，
  1. 如果它為 true，但想創建一個來自其它 Connection 的同名 Queue，那么就會報錯
  2. 如果它是 false，那么想創建一個來自其它 Connection 的同名 Queue 的結果就是：兩個 Connection 都連接到同一個 Queue，兩個 Connection 會共享它，這里我把它設為 false
5. 第五個引數 noWait bool，
  1. 如果為 true，這個 Queue 就被認為已經在服務器上存在了，將它回傳即可，如果它不存在，那么就會報錯
  2. 所以這里設定為 false，因為我要創建的 Queue 在服務器上不存在，
6. 第六個引數 args amqp.Table，這個引數用于某些特定場景，例如宣告一些要被這個 Queue 匹配的 Headers，如果這個 Queue 被系結到 Header Exchange 的話，這里我傳的是 nil，
如果第 24 行的 QueueDeclare 方法呼叫成功，那么就會得到一個系結到 Default Exchange 的 Queue，
注意：Default Exchange 的型別是 Direct，也就是說任何沒有路由 Key（和 Queue 的名稱相同，在這里就是 hello）的訊息傳進來，將會被直接通過 exchange 送往輸出的 Queue，
第 31 行，將 3 個物件回傳即可，注意 q 我們回傳的是指標

發布訊息

10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
func main() {
for {
server()
func server()
getQueue( )
conn, ch, q
conn. Close()
defer
ch . Close()
defer
amqp. Publishing{
msg
"text/plain" ,
Content Type:
Body :
ch . Publish(
q. Name ,
false,
false,
msg)
[]byte( "Hello RabbitMQ"),

16 行，撰寫了一個 server 函式
17 行，通過 getQueue 來獲得 Connection，Channel 和 Queue
18，19 行，按順序 defer 關閉 Connection 和 Channel
21 行，創建一個訊息 amqp.Publishing 結構體，很多引數都是可選的，這里我設定兩個：
1. ContentType 會指明訊息的型別，RabbitMQ 會把資料變成位元組流來傳輸，所以它其實并不關心訊息的型別，但是如果你往同一個 Queue 發送不同型別的訊息，那么還是設定一下這個欄位比較好，便于區分訊息的型別，
2. Body 可能是該結構體中最重要的欄位：它的型別是 Byte Slice，里面包含著要傳送的資料，
第 26 行，將訊息發布到訊息代理上，這里我們使用 Channel 上的 Publish 方法，其引數有：
1. 第一個引數 Exchange：“”表示使用 Default Exchange，它沒有名稱
2. 第二個引數是路由 Key：本例中，需要把它設定為 Queue 的名稱
3. 第三、四各引數 mandatory bool，immediate bool：用于發生者需要確認訊息是否被傳遞成功，以及什么時候傳遞成功的，
4. 第五個引數就是訊息本身：也就是 msg
在 main 函式中呼叫 server 函式，這里回圈呼叫是為了看看 RabbitMQ 的性能，你可以只呼叫一次，