事由
使用nsq的go sdk发现吞吐量一直上不去。经过边看代码,便阅读文档,发现MaxInFlight
这个参数会影响吞吐量
修改
知道哪个参数影响就好办了,直接修改大就行
- 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"`
网友评论