回答情况：
提问时间：
问题标签：
2回答
我试着在码头群中使用NSQ，但没有成功# crete a bridged network$ docker run--name nsqlookupd --network nsq_
浏览 3修改于2016-12-09得票数 3
回答已采纳
我有一个NSQ的工作实例，可以注册任务，消费者等等。不幸的是，我最初没有建立这个系统。我想要做的是弄清楚如何激活NSQ提供的一些内置命令行工具( nsq_to_file、nsq_tail等)。当我尝试nsq_tail --channel=MyTestChannel --topic=test --lookupd-http-address=127.0.0.1:4161时，我会得到nsq_tail我唯一知道的另一件事是，在我们的情况下，NSQ是由码头商管理的。任何帮助
浏览 3提问于2014-08-29得票数 5
回答已采纳
2回答
问题是，我的消费者在nsq上留下了指数级的未处理/接收消息。还有其他人遇到过这个吗？q, _ := nsq.NewConsumer("chat", "golangbetches", config)
q.AddConcurrentHandlers(nsq.HandlerFunc(func(message *nsq.Message) error
浏览 4提问于2015-03-24得票数 2
回答已采纳
2回答
系统: VMware CentOS + Docker-compose NSQ版本:全部最新version: '3' nsqlookupd: command: /nsqlookupd - "4160:4160" image: nsqio/nsq
浏览 4修改于2019-07-05得票数 2
1回答
我正试图使用docker-compose来提升NSQ。nsqlookupd容器运行良好，我甚至可以通过web浏览器访问管理面板，但无法连接到nsqd：192.168.59.103
~/D/t/nsq % curl -d 'hello world 1' 'http://192.168
浏览 6提问于2015-05-29得票数 0
回答已采纳
1回答
我是新来的NSQ，我想知道是否有可能承认一个消息被消耗(就像在谷歌PubSub)。我正在使用Golang，在浏览NSQ文档()时，我发现了方法FinishMessage，根据它的注释，它应该是successfully discards an in-flight message。如果一条信息在NSQ中没有被确认，它如何确保它一旦被消耗掉，就不会再次被消耗？
谢谢
浏览 8修改于2022-04-09得票数 2
我正试图在库伯内特斯建立一个NSQ集群，并有问题。基本上，我想扩大NSQ和NSQ的查找范围。我对它们都有一个有状态集(2个节点)的定义。为了不发布整个YAML文件，我将只为NSQ发布其中的一部分command: - -data-path
- /data实例打开与所有NSQ实例的连接，这实际上是没有发生的。但是，如果我像这样显式地列出所有NSQ查找主机，它就能工作。我使用
浏览 2修改于2021-04-13得票数 3
1回答
我有需要连接到NSQ的节点，它们需要获取该主题的所有消息。为此，他们各自创建了一个通道。我想知道是否有一种方法，让nsqd在消费者被切断后清理它们？
浏览 6提问于2017-08-11得票数 0
回答已采纳
我已经在我的Go微服务中创建了一个NSQ生成器，并且我正在尝试为它创建一个方法，以便在NSQ重启后尝试重新连接。我查看了nsq配置文档，希望查看是否可以在重新启动/退出时提供故障转移方法，但我没有太多的运气。我将发布如何创建我的NSQ生成器： type ProducerNSQ struct {}
config := nsq.New
浏览 35提问于2020-01-17得票数 0
我尝试使用docker-compose来运行nsq，docker-compose.yml如下所示：services: image: nsqio/nsq ports: - "4161:4161" image: nsqio/nsq
command: &#
浏览 13修改于2018-01-31得票数 2
回答已采纳
我正试图使用nsq作为的经纪人。
我正在考虑让通过REST 向发送数据。根据该文档，我可以发出一个HTTP请求来向弹性搜索添加数据。但是，根据nsq ，nsq只能通过nsq_to_http实用程序发出帖子或获得请求。我不能提出elasticsearch要求的PUT请求。如何将值从nsq传递到elasticsearch？
浏览 1修改于2015-05-26得票数 3
回答已采纳
我正在为一个特定的项目使用NSQ，进行评估。其想法是设置一个数据管道，其中每个步骤都是一个作业，状态理想的位置将位于消息体中。
这让我想到了一个潜在的最大信息大小。我找不到关于这个问题的任何文件。
浏览 8提问于2015-10-23得票数 5
回答已采纳
/nsq_to_file --lookupd-http-address=<http_address> --topic=ta-gcp-test -output-dir=/path/to/local/dir
浏览 26提问于2022-02-18得票数 0
尝试学习nsq，并学习和的例子。我在服务器端发送消息，执行w/ a for循环和go例程。// channel = 'import_progress_587e6442ff74889098498f6e'
let reader = new nsq.Reader(channel, channel,
浏览 2修改于2017-01-19得票数 1
这里是完整的yaml文件(没有问题，因为它很长，而且下面的describe涵盖了许多重要的位元)：
容器与官方的NSQminikube/192.168.99.100Labels: app=nsqdocker://381e4a1313e4e13a63b8a17004d79a6e828a8bc
浏览 4提问于2016-12-05得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号