NSQ记录

config := nsq.NewConfig()
//最大允许向两台NSQD服务器接受消息，默认是1，要特别注意
config.MaxInFlight=2
c1, err1 := nsq.NewConsumer("test", "test-channel1", nsq.NewConfig()) // 新建一个消费者