事由
使用nsq的go sdk發(fā)現(xiàn)吞吐量一直上不去糠雨。經(jīng)過邊看代碼,便閱讀文檔,發(fā)現(xiàn)MaxInFlight
這個參數(shù)會影響吞吐量
修改
知道哪個參數(shù)影響就好辦了瞭空,直接修改大就行
- nsq go sdk url
"github.com/nsqio/go-nsq"
- 配置
config := nsq.NewConfig()
config.MaxInFlight = 10000
- 該配置官方注釋(代碼位置go-nsq/config.go里面)
// Maximum number of messages to allow in flight (concurrency knob)
MaxInFlight int `opt:"max_in_flight" min:"0" default:"1"`