我在我的應(yīng)用程序中使用http://github.com/streadway/amqp包來處理與遠(yuǎn)程 RabbitMQ 服務(wù)器的連接。一切正常，工作正常，但我有一個問題。一個連接的當(dāng)前名稱是“ip:port”，所以當(dāng)有多個連接來自同一個 IP+端口時，它們變得很難區(qū)分。如果您可以為每個連接指定一個名稱，那就太好了。有沒有辦法為每個連接設(shè)置一個獨特的友好名稱？
1 回答
守著星空守著你
TA貢獻(xiàn)1799條經(jīng)驗 獲得超8個贊
RabbitMQ 3.6.5 添加了連接客戶端報告友好名稱字符串值的功能，以識別用于管理目的的連接。這嚴(yán)格來說是一個標(biāo)識符，因為它是客戶端報告的，所以除了連接的弱識別之外，不能依賴它。發(fā)行說明指出：
客戶端現(xiàn)在可以提供一個人類可讀的連接名稱，該名稱將顯示在管理 UI 中...為了使用此功能，請
connection_name在客戶端屬性中設(shè)置密鑰。請注意，此名稱不必是唯一的，也不能用作連接標(biāo)識符，例如，在 HTTP API 請求中。
解決方案
如果您使用的是足夠新的 RabbitMQ 版本，則可以在建立連接時設(shè)置此參數(shù)，方法是在建立初始連接時streadway/amqp傳遞一個實例。amqp.Config該Properties字段允許指定連接的自定義屬性。
下面的示例程序使用環(huán)境變量中提供的 AMQP URL 打開一個連接AMQP_URL，使用作為第一個命令行參數(shù)傳遞給調(diào)用的連接名稱來標(biāo)識。
package main
import (
? ? "log"
? ? "os"
? ? "github.com/streadway/amqp"
)
func main() {
? ? amqpUrl := os.Getenv("AMQP_URL")
? ? cfg := amqp.Config{
? ? ? ? Properties: amqp.Table{
? ? ? ? ? ? "connection_name": os.Args[1],
? ? ? ? },
? ? }
? ? conn, err := amqp.DialConfig(amqpUrl, cfg)
? ? if err != nil {
? ? ? ? log.Fatal(err)
? ? }
? ? defer conn.Close()
? ? <-(chan struct{})(nil)
}
使用以下命令行啟動多個實例以連接到本地 RabbitMQ 實例：
AMQP_URL=amqp://admin:password@localhost:5672 go run ./main.go connX
在 RabbitMQ Management web UI 的“Connections”頁面中，用數(shù)字代替會X產(chǎn)生以下輸出：
并且各個連接詳細(xì)信息頁面顯示“客戶端提供的名稱”詳細(xì)信息下的值：
- 1 回答
- 0 關(guān)注
- 184 瀏覽
添加回答
舉報
0/150
提交
取消