diff --git a/notify/consumer.go b/notify/consumer.go index 4345b448ae16baf341b3e9bf59055e2459b5560b..32077acb02d8051b77771378b8c255fb005a76d1 100644 --- a/notify/consumer.go +++ b/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") {