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

Question

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

当前连接的名称为“ip:port”，因此当同一IP +端口有多个连接时，它们变得几乎无法区分。如果您可以为每个连接指定一个名称，那将是很好的。

是否有任何方法为每个连接设置不同的友好名称？

- elham anari

---

如果您使用*nix系统，可以在/etc/hosts文件中添加域名和地址。Windows系统也有类似的功能。请注意，需要将域名和地址分别填写在相应的位置。 - nilsocket

当您有来自同一IP的大量连接时，该怎么办？这有什么问题吗？我在一个服务器上有一些子系统。@nilsocket - elham anari

没关系，所有的 DNS 查询都通过操作系统进行，操作系统首先查找文件，如果文件不存在，则查询 DNS 服务器。我不确定你具体在问什么，一些代码示例会有所帮助。 - nilsocket

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 管理 Web UI 的“连接”页面中，将数字替换为 X，将产生以下输出：

个人连接详细页面显示“客户提供的名称”详细值下的值：

- Cosmic Ossifrage