影响nsq吞吐量的配置-MaxInFlight

事由

使用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"`
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。