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