在 Go amqp 客户端中设置连接友好名称

Question

我在我的应用程序中使用http://github.com/streadway/amqp包来处理与远程 RabbitMQ 服务器的连接。一切正常，工作正常，但我有一个问题。一个连接的当前名称是“ip:port”，所以当有多个连接来自同一个 IP+端口时，它们变得很难区分。如果您可以为每个连接指定一个名称，那就太好了。有没有办法为每个连接设置一个独特的友好名称？

Answer 1

RabbitMQ 3.6.5 添加了连接客户端报告友好名称字符串值的功能，以识别用于管理目的的连接。这严格来说是一个标识符，因为它是客户端报告的，所以除了连接的弱识别之外，不能依赖它。发行说明指出：

客户端现在可以提供一个人类可读的连接名称，该名称将显示在管理 UI 中...为了使用此功能，请connection_name在客户端属性中设置密钥。请注意，此名称不必是唯一的，也不能用作连接标识符，例如，在 HTTP API 请求中。

---

解决方案

如果您使用的是足够新的 RabbitMQ 版本，则可以在建立连接时设置此参数，方法是在建立初始连接时streadway/amqp传递一个实例。amqp.Config该Properties字段允许指定连接的自定义属性。

下面的示例程序使用环境变量中提供的 AMQP URL 打开一个连接AMQP_URL，使用作为第一个命令行参数传递给调用的连接名称来标识。

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”页面中，用数字代替会X产生以下输出：

并且各个连接详细信息页面显示“客户端提供的名称”详细信息下的值：