Merge branch 'v3.5.x' of https://github.com/Tencent/bk-cmdb into v3.5.x

Author: breezelxp

src/scene_server/datacollection/datacollection/porter.go

@@ -50,7 +50,7 @@ func BuildChanPorter(name string, analyzer Analyzer, redisCli, snapCli *redis.Cl
 		slaveC:          make(chan string, cacheSize),
 		analyzeCounterC: make(chan int, runtime.NumCPU()),
 		runed:           util.NewBool(false),
-		Engine:			 engine,
+		Engine:          engine,
 	}
 
 	ns := "cmdb_collector_" + name + "_"
@@ -269,7 +269,10 @@ func (p *chanPorter) subscribeLoop() error {
 	if nil != err {
 		return fmt.Errorf("subscribe channel failed, %v", err)
 	}
-	defer subChan.Unsubscribe(p.channels...)
+	defer func() {
+		_ = subChan.Unsubscribe(p.channels...)
+		_ = subChan.Close()
+	}()
 
 	blog.Info("[data-collection][%s] subscribing channel %v from redis", p.name, p.channels)
 	defer blog.Info("[data-collection][%s] unsubscribe channel %v from redis", p.name, p.channels)