【问题标题】：Set connection friendly name in Go amqp client在 Go amqp 客户端中设置连接友好名称
【发布时间】：2020-07-28 17:41:47
【问题描述】：

我在我的应用程序中使用 http://github.com/streadway/amqp 包来处理与远程 RabbitMQ 服务器的连接。一切正常，工作正常，但我有一个问题。

连接的当前名称是“ip:port”，因此当有来自同一个 IP+端口的多个连接时，它们变得难以区分。如果您可以为每个连接指定一个名称，那就太好了。

有没有办法为每个连接设置一个不同的友好名称？

【问题讨论】：

在/etc/hosts文件中添加域名后跟地址，如果你使用*nix，windows也有类似的东西。
当你有一堆来自同一个 ip 的连接时？怎么样？我在一台服务器中有一些子系统。 @nilsocket
没关系，所有的dns查询都经过os，os先查看文件，如果没有，查询dns服务器。我不确定你到底在问什么，一些代码示例会有所帮助。

标签： go amqp

【解决方案1】：

RabbitMQ 3.6.5 为连接客户端添加了报告友好名称字符串值的功能，以识别连接以进行管理。这严格来说是一个标识符，并且由于它是客户端报告的，因此除了连接的弱识别之外，不能依赖它。 release notes 状态：

客户端现在可以提供将显示在管理 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

用数字代替 X 在 RabbitMQ 管理 Web UI 的“连接”页面中产生以下输出：

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

【讨论】：