fix

registry/zookeeper/listener.go

@@ -77,6 +77,7 @@ type RegistryConfigurationListener struct {
 }
 
 func NewRegistryConfigurationListener(client *zk.ZookeeperClient, reg *zkRegistry) *RegistryConfigurationListener {
+	reg.wg.Add(1)
 	return &RegistryConfigurationListener{client: client, registry: reg, events: make(chan *config_center.ConfigChangeEvent, 32)}
 }
 func (l *RegistryConfigurationListener) Process(configType *config_center.ConfigChangeEvent) {

registry/zookeeper/registry.go

@@ -432,7 +432,7 @@ func (r *zkRegistry) Subscribe(url *common.URL, notifyListener registry.NotifyLi
 			time.Sleep(time.Duration(RegistryConnDelay) * time.Second)
 			continue
 		}
-		r.wg.Add(1)
+
 		for {
 			if serviceEvent, err := listener.Next(); err != nil {
 				listener.Close()