Browse Source

增加重新续约

wangkaiyue 3 năm trước cách đây
mục cha
commit
dbf3f86be0
2 tập tin đã thay đổi với 2 bổ sung2 xóa
  1. 1 1
      core/node/NewReigster.go
  2. 1 1
      core/node/register.go

+ 1 - 1
core/node/NewReigster.go

@@ -58,7 +58,7 @@ func (p *Publisher) getRegisterKey() (key, val string) {
 	if addr == "" {
 		addr = fmt.Sprintf("http://%s", iputil.InternalIp())
 	}
-	if p.serPort != "" {
+	if p.serPort == "" {
 		port = "80"
 	}
 	finalAddr := fmt.Sprintf("%s:%s", addr, port)

+ 1 - 1
core/node/register.go

@@ -11,7 +11,7 @@ import (
 
 // Register 注册服务
 func (n *Node) Register(serverCode string, serverPort string, serverIp ...string) (func(), error) {
-	stop, err := NewPublisher(serverCode, fmt.Sprintf("%s", serverPort), n.Client.Endpoints()...).Register()
+	stop, err := NewPublisher(serverCode, serverPort, n.Client.Endpoints()...).Register()
 	if err != nil {
 		return nil, err
 	}