go - 在 Go amqp 客户端中设置连接友好名称
问题描述
我在我的应用程序中使用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
在 RabbitMQ 管理 Web UI 的“连接”页面中,用数字代替会X
产生以下输出:
并且各个连接详细信息页面显示“客户端提供的名称”详细信息值下的值:
推荐阅读
- bash - 尝试使用 bash 脚本自动化我的 docker 容器会给我一个 OCI 运行时错误
- javascript - 如何防止元素沿对角线移动
- javascript - 保存 Javascript 函数的输出
- r - 错误:namespaceExport(ns,exports)中“R.utils”的包或命名空间加载失败:未定义的导出:.Last.lib [R with Windows]
- mysql - php-mysql left join table last data
- c# - 导航到路线不发生
- python - Py/sqlite3 错误:InterfaceError 错误绑定参数1
- python - 如何在python中将字符串转换为数字?
- database - 如何在 ERD 中表示多对多关系
- vue.js - 发送媒体上的彗星聊天无法调用附加消息