nsq客户跟不上

Question

我是来自Node世界的围棋新手，我正在使用正式的Bitly Go客户端构建一个消费者。我正在使用AddConcurrentHandlers来孕育50只猩猩来处理信息的消防软管。问题是，我的消费者在nsq上留下了指数级的未处理/接收消息。还有其他人遇到过这个吗？

我在Node中构建了同样的东西，以查看是否存在服务器或NSQ配置问题，以及它是否能够尽快处理所有消息。

GO代码：

q, _ := nsq.NewConsumer("chat", "golangbetches", config)

q.AddConcurrentHandlers(nsq.HandlerFunc(func(message *nsq.Message) error {
  l.Debug("Got a message: %v", message)
  message.Finish()
  return nil
}), 50)

err := q.ConnectToNSQLookupd("<address here>")

Answer 1

cfg.MaxInFlight处理的是，“这个comsumer实例将允许在飞行中允许的最大消息数量.”更多详细信息可在消费者来源中获得

将cfg.MaxInFlight设置为合理的东西，因为它是默认值为1

示例配置是可在文件中查阅，其中将其设置为1000。这可能适用于您的应用程序，也可能不适合您的应用程序；而且，您最好监视它，因为错误的配置可能导致截短消息。

Answer 2

另一种加快消费者购买速度的方法可以在这里找到：https://github.com/nsqio/go-nsq/issues/187

其中一个对我有用的是在nsqd上增加--max-rdy-count，这使得用户的--max_in_flight比默认的--max_in_flight还要高。