问题标签 [go-nsq]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
logging - 在 log.SetOutput(ioutil.Discard) 之后延迟 log.SetOutput(os.Stdout)
在go-nsq
库(https://github.com/bitly/go-nsq/blob/master/writer_test.go#L38)中,我找到了以下代码:
为什么作者在丢弃日志后将日志记录推迟到标准输出?
docker - nsq 无法通过连接到 nsqlookupd 来消费消息
我尝试使用 docker-compose 来运行 nsq,docker-compose.yml
如下:
我使用的是nsq客户端go-nsq来生产和消费消息,消息可以直接连接nsqd来消费,但是不能通过连接nsqlookupd来消费:
我可以连接到 nsqlookup 实例:
源代码链接:
https://gist.github.com/liuzxc/1baf85cff7db8dee8c26b8707fc48799
环境:
有什么想法吗?
go - 如何在不消耗消息的情况下在 NSQ 中创建通道
我正在使用github.com/nsqio/go-nsq
Go 包与NSQ一起工作,我遇到了以下问题。当生产者写一条消息时 - 它创建了一个主题,但没有创建一个频道,而且似乎 NSQ 服务器只是在没有频道时丢弃了一条消息。我不想丢失消息,也不想依赖消费者和生产者的启动顺序。所以一个可能的解决方案是在生产者端创建一个通道,这样当它写入时它不会丢弃消息。为了创建通道,我如何在不消费消息的情况下创建和销毁消费者?
序列
可以消费
删除AddConcurrentHandlers
导致错误
从协议规范我看不出它应该怎么做,除了发送 SUB 后跟 CLS,但因为这是两个命令和非“原子”类型的操作 - 理论上可能会发生在两者之间..
所以可能我试图做错了吗?例如 RABBITMQ 可以预先创建它,这里是这样的吗?