在NSQ中确认消息

Question

我是 NSQ 的新手，想知道是否可以确认消息已被消耗（就像在 Google PubSub 中一样）。我正在使用 Golang，并在浏览 NSQ 文档时（https://github.com/nsqio/nsq/blob/v1.2.1/nsqd/channel.go#L350）我找到了方法FinishMessage 根据其注释，它应该成功丢弃正在传输的消息。这是否就等于承认了？如果一条消息在 NSQ 中没有被确认，如何确保它一旦被消费就消失了，这样就不会被再次消费？

谢谢

Answer 1

NSQ 在将消息发送给消费者后自动从队列中删除消息。如果在设置的超时后消费者没有响应，则自动重新排队消息。

是的，根据您使用的编程语言客户端，您必须发送“完成”。
这是 Golang 的文档
https://pkg.go.dev/github.com/nsqio/ go-nsq#Finish

但由于 NSQ 的设计方式，如果预期操作不成功，您必须重新排队来自应用程序的消息。

这是他们网站的摘录

NSQ 保证消息至少被传递一次，尽管可能存在重复消息。消费者应该预料到这一点并进行重复数据删除或执行幂等操作。

此保证作为协议的一部分强制执行，工作原理如下（假设客户端已成功连接并订阅主题）：

1. 客户端表示他们已准备好接收消息
2. NSQ 发送消息并在本地临时存储数据（以防重新排队或超时）
3. 客户端回复FIN（完成）或REQ（重新排队），分别指示成功或失败。如果客户端没有回复 NSQ 将超时
   可配置的持续时间并自动重新排队消息）

您可以在此处阅读更多信息：https://nsq.io /overview/design.html

希望我的回答对您有所帮助。