Update registry.go

go-zk · Sep 7, 2020 · 980bd1a · 980bd1a
1 parent c487351
commit 980bd1a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/registry.go b/registry.go
@@ -153,7 +153,9 @@ func (z *ZkRegistry) watchNode(serviceName string, wg *sync.WaitGroup) {
  for {
  nodeIds, _, events, err := conn.ChildrenW(path)
  if err != nil {
- log.Println(err.Error())
+ log.Println("watch[" + serviceName + "]err:" + err.Error())
+ time.Sleep(time.Duration(z.opts.timeout) * time.Second)
+ continue
  }
  //获取信息
  var newNodes = make(map[string]bool)
@@ -170,7 +172,7 @@ func (z *ZkRegistry) watchNode(serviceName string, wg *sync.WaitGroup) {
  continue
  }
  newNodes[nodeId] = true
- if node.Id == "" { //兼容node没有定义ID的情况
+ if node.Id == "" { //兼容node没有定义ID的情况
  node.Id = nodeId
  }
  err = z.setServiceNode(serviceName, &node)