问题标签 [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.

0 投票
1 回答
1201 浏览

logging - 在 log.SetOutput(ioutil.Discard) 之后延迟 log.SetOutput(os.Stdout)

go-nsq库(https://github.com/bitly/go-nsq/blob/master/writer_test.go#L38)中,我找到了以下代码:

为什么作者在丢弃日志后将日志记录推迟到标准输出?

0 投票
1 回答
807 浏览

go - nsqjs 客户端,不立即从 go-nsq 服务器端接收消息

尝试学习 nsq,并遵循golang 示例nsqjs中的示例。我正在服务器端发送消息,使用 for 循环和执行例程

但问题是,在客户端。

消息不会立即发送给客户端。我将等待几秒钟,直到消息到达 nodejs 客户端。有什么我需要做的设置吗?谢谢你!

0 投票
1 回答
2714 浏览

docker - nsq 无法通过连接到 nsqlookupd 来消费消息

我尝试使用 docker-compose 来运行 nsq,docker-compose.yml如下:

我使用的是nsq客户端go-nsq来生产和消费消息,消息可以直接连接nsqd来消费,但是不能通过连接nsqlookupd来消费:

我可以连接到 nsqlookup 实例:

源代码链接:

https://gist.github.com/liuzxc/1baf85cff7db8dee8c26b8707fc48799

环境:

有什么想法吗?

0 投票
0 回答
72 浏览

go - 如何在不消耗消息的情况下在 NSQ 中创建通道

我正在使用github.com/nsqio/go-nsqGo 包与NSQ一起工作,我遇到了以下问题。当生产者写一条消息时 - 它创建了一个主题,但没有创建一个频道,而且似乎 NSQ 服务器只是在没有频道时丢弃了一条消息。我不想丢失消息,也不想依赖消费者和生产者的启动顺序。所以一个可能的解决方案是在生产者端创建一个通道,这样当它写入时它不会丢弃消息。为了创建通道,我如何在不消费消息的情况下创建和销毁消费者?

序列

可以消费

删除AddConcurrentHandlers导致错误

协议规范我看不出它应该怎么做,除了发送 SUB 后跟 CLS,但因为这是两个命令和非“原子”类型的操作 - 理论上可能会发生在两者之间..

所以可能我试图做错了吗?例如 RABBITMQ 可以预先创建它,这里是这样的吗?