fix panic error

apache · Dec 3, 2020 · ee35594 · ee35594
1 parent 2b8aad0
commit ee35594
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/registry/zookeeper/registry.go b/registry/zookeeper/registry.go
@@ -212,6 +212,9 @@ func (r *zkRegistry) registerTempZookeeperNode(root string, node string) error {
 
 	r.cltLock.Lock()
 	defer r.cltLock.Unlock()
+	if r.client == nil{
+		return perrors.WithStack(perrors.New("zk client already been closed"))
+	}
 	err = r.client.Create(root)
 	if err != nil {
 		logger.Errorf("zk.Create(root{%s}) = err{%v}", root, perrors.WithStack(err))