加入hostname注册

This commit is contained in:
marvzhang
2020-03-05 08:56:01 +08:00
parent 47fcae9456
commit 6b39167a8b
4 changed files with 71 additions and 8 deletions

View File

@@ -43,6 +43,7 @@ func IsMaster() bool {
}
// 获取本机节点
// TODO: 这里职责不单一,需要重构
func GetCurrentNode() (Node, error) {
// 获得注册的key值
key, err := register.GetRegister().GetKey()
@@ -68,7 +69,7 @@ func GetCurrentNode() (Node, error) {
//只在master节点运行的时候才检测master节点的信息是否存在
if IsMaster() && err == mgo.ErrNotFound {
// 获取本机信息
ip, mac, key, err := GetNodeBaseInfo()
ip, mac, hostname, key, err := GetNodeBaseInfo()
if err != nil {
debug.PrintStack()
return node, err
@@ -81,6 +82,7 @@ func GetCurrentNode() (Node, error) {
Ip: ip,
Name: ip,
Mac: mac,
Hostname: hostname,
IsMaster: true,
}
if err := node.Add(); err != nil {
@@ -240,25 +242,31 @@ func GetNodeCount(query interface{}) (int, error) {
}
// 节点基本信息
func GetNodeBaseInfo() (ip string, mac string, key string, error error) {
func GetNodeBaseInfo() (ip string, mac string, hostname string, key string, error error) {
ip, err := register.GetRegister().GetIp()
if err != nil {
debug.PrintStack()
return "", "", "", err
return "", "", "", "", err
}
mac, err = register.GetRegister().GetMac()
if err != nil {
debug.PrintStack()
return "", "", "", err
return "", "", "", "", err
}
hostname, err = register.GetRegister().GetHostname()
if err != nil {
debug.PrintStack()
return "", "", "", "", err
}
key, err = register.GetRegister().GetKey()
if err != nil {
debug.PrintStack()
return "", "", "", err
return "", "", "", "", err
}
return ip, mac, key, nil
return ip, mac, key, hostname, nil
}
// 根据redis的key值重置node节点为offline