Go 中的 AMQP 連接應該是全域的還是為每個訊息創建？

在 AMQP Dial 中管理連線

在 Go 中， amqp.Dial 函數用於建立與 AMQP 伺服器的連線。但是，有人擔心 amqp.Dial 函數是否應該在每次發送訊息時調用，或者是否可以全域聲明並重用於多個操作。

全域連線管理

如官方文件中所提到的，TCP 連線的建立可能會佔用大量資源。為了優化效能，AMQP 中引入了通道的概念，允許在單一連接上建立多個通道。

因此，一般建議只建立一次 AMQP 連接，作為全域變量，並將其重用於所有後續操作。這減少了每次建立新連線所需的開銷。

線程安全

amqp.Dial 函數是線程安全的，可以從多個 goroutine 並發呼叫。這允許在必要時創建多個連接，而無需任何競爭條件。

連線失敗處理

要優雅地處理連線失敗，您可以使用 Connection. NotifyClose 方法註冊一個通道以在連線關閉時接收通知。這使您能夠根據需要進行檢測並重新連接。

在提供的範例中，程式碼偵聽通道並在發生錯誤時嘗試重新建立連線。但是，在終止現有連線並嘗試發布訊息時會發生錯誤。這可能是由於現有通道仍保留對已關閉連線的參考。

要解決此問題，您還應該在重新建立連線時關閉所有活動通道以避免意外行為。

錯誤處理範例

這是一個包含連接失敗處理的範例：

<code class="go">import (
    "context"
    "log"
    "sync"
    "time"

    "github.com/streadway/amqp"
)

var (
    connOnce sync.Once
    conn     *amqp.Connection
)

func main() {
    connOnce.Do(func() {
        var err error
        conn, err = amqp.Dial("amqp://guest:guest@localhost:5672/")
        if err != nil {
            log.Panicf("Failed to connect: %v", err)
        }
    })

    c := make(chan *amqp.Error)
    conn.NotifyClose(c)

    go func() {
        for {
            err := <-c
            log.Println("reconnect: " + err.Error())
            connOnce.Do(func() {
                var err error
                conn, err = amqp.Dial("amqp://guest:guest@localhost:5672/")
                if err != nil {
                    log.Panicf("Failed to connect: %v", err)
                }
            })
            conn.NotifyClose(c)
            // Give time for any pending messages to be delivered
            // after reconnection
            time.Sleep(5 * time.Second)
        }
    }()

    // Create channels and perform operations here
    // ...

    // Close the connection when done
    defer conn.Close()
}</code>

在此範例中，使用sync.Once 建立了一個全域連接。類型以確保它只被初始化一次。 Connection.NotifyClose 方法用於監視連線失敗並根據需要重新建立連線。

以上是Go 中的 AMQP 連接應該是全域的還是為每個訊息創建？的詳細內容。更多資訊請關注PHP中文網其他相關文章！