更新批量客户端

notify/consumer.go

@@ -40,9 +40,10 @@ func InitBatchConsumer(consumer *NsqConfig, clientNum int) {
 	if clientNum == 0 {
 		clientNum = 1
 	}
-	for i := 0; i < clientNum; i++ {
-		c.AddHandler(consumer.Handler) // 批量添加消费者接口
-	}
+
+	c.ChangeMaxInFlight(clientNum) //可以根据nsqds数量来配置
+	c.AddHandler(consumer.Handler) // 批量添加消费者接口
+
 	//建立NSQLookupd连接
 	err = c.ConnectToNSQD(consumer.Addr)
 	if logs.CheckErr(err, "ConnectToNSQD") {