问题标签 [nsq]

由于 golang 在单独的 goroutine 中处理传入的请求，我不清楚哪些类型的任务应该推迟到消息队列（例如 NSQ 消费者）处理，哪些类型的任务应该在 http 请求 goroutine 中处理。

我正在尝试创建 NSQ 主题并在 rethinkdb 中插入数据，但我无法将数据插入 rethinkdb。谁能帮我。

我正在尝试使用环境变量来不设置“http 地址”，因为在使用 AWS 机器时 IP 地址可能会发生变化。如何在找到 HTTPAddresses 的地方使用环境变量？这里我使用本地主机地址，但在 AWS 我不能这样使用。任何建议如何解决这个问题？

提前致谢。

我正在尝试使用docker-compose.

容器运行良好，我什至可以通过网络浏览器访问管理面板，但无法连接到 nsqd：

有任何想法吗？

我现在正在使用这个类：

• com.trendrr.nsq.NSQProducer
• com.trendrr.nsq.NSQConsumer

我的服务需要知道目前有多少消息排队，因为有一些“何时完成”的估计方法。

有人知道如何获得实际的队列大小吗？也许与其他一些java实现？

我发现了什么：

• https://github.com/brainlag/JavaNSQClient（消费者有一些 getTotalMessages() 方法，但它是一个总处理的 msg 计数器）

我正在尝试在 vb.net NsqSharp中使用这个包 在 C# 中有一个很好的代码，但我在 vb.net 中需要它。

我得到它来向我的 NSQ 服务器发送消息，但问题是得到它。但我得到一个错误consumer.AddHandler(New HandleMessage())，我不知道我是否声明了HandleMessage权利。

我正在为特定项目使用 NSQ http://nsq.io/进行评估。这个想法是建立一个数据管道，其中每个步骤都是一个作业，并且理想情况下状态将位于消息正文中。

这让我想到了潜在的最大消息大小。我无法找到有关该主题的任何文档。可以是任意大小吗？我想如果消息足够大而无法放入内存，它会影响性能。

我想要的只是在一个线程中运行一个 ioloop，然后将消息写入 nsqd。这是一个尝试：

但它没有用。你可以帮帮我吗？谢谢！

我有一组提供 nsqlookupd 服务的 pod。现在我需要每个 nsqd 容器同时拥有一个要连接的 nsqlookupd 服务器列表（而服务每次都会指向不同的服务器）。我得到了类似的东西

但我想将它放在我的部署定义中的一个变量中，或者以某种方式从 nsqd 容器中

我在javascript中有以下代码

这是python中的等效版本。

与 javascript 相比，python 版本的运行速度非常快。javascript 版本似乎每 2 分钟处理 1 条消息。而 python 似乎可以在几毫秒内处理。我真的很惊讶这里发生了什么？这是我运行的确切代码，我的队列有很多我确实验证过的消息。任何想法为什么javascript版本真的很慢？