当前位置： > > > > 在 Go amqp 客户端中设置连接友好名称

来源：stackoverflow
2024-04-22 08:12:34
0浏览
收藏

哈喽！今天心血来潮给大家带来了《在 Go amqp 客户端中设置连接友好名称》，想必大家应该对Golang都不陌生吧，那么阅读本文就都不会很困难，以下内容主要涉及到，若是你正在学习Golang，千万别错过这篇文章~希望能帮助到你！

问题内容

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

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

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

解决方案

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

用数字代替 x 会在 rabbitmq 管理 web ui 的“连接”页面中产生以下输出：

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

到这里，我们也就讲完了《在 Go amqp 客户端中设置连接友好名称》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注公众号，带你了解更多关于的知识点！