nsq的hanlder任务执行时间一长会报IO error错误（大概两分钟左右）
小弟正在开发go语言基于nsq的异步任务。但是现在发现，只要任务时间一长，客户端就会报错，报错信息如下：2019/08/28 09:21:59 ERR 2 [free/alfx] (1…
nsq topic 与 channel 设计
现在通过 nsq 去操作 es 的增删改，是设置一个 topic 多个channel(增，删，改)还是设置多个topic(增，删，改) 一个channel好呢？…
docker-compose 启动 NSQ 数据持久化如何设置？
如图，官方介绍了如何使用 docker-compose 启动 nsq 的几个服务，在 docker-compose 中没有配置共享数据卷，但是在 Persisting NSQ Data 中介绍了如…
如何只订阅 nsq 某个 topic下的特定channel?
本地环境:testtopic下 有 两个channel: testchannel1, testchannel2,通过nsq_to_http的方式把数据消费到http接口上e.g:消费者1:/usr/local/opt/nsq/b…
pynsq处理长时间任务
在我使用pynsq的时候遇到这样的问题，需要处理长时间的任务，nsq报错提示： ERROR:nsq.client:[127.0.0.1:4150:hello:channel] ERROR: ConnectionClo…
关于用nsq做消息队列的设计模型问题，如果是用做为聊天消息的中间转发者，那么具体设计模型应该怎么样合理呢？
1、问题描述：我想借助nsq做一个简单的IM系统，实现私聊群聊等功能。那么nsq的生产者如何得到需要转发的消息呢（是nsqd和消息发出者不在一台主机的情…
nsq 消费消息有延迟, 怎么通过配置让 nsq 收到消息后, 订阅的消费者能够立即收到消息.
我简单部署了一下 nsqd+nsqlookupd 我的程序同时作为生产者(收到post请求后生产消息), 也作为消费者(消费post来的消息)发消息到 nsqd.消费消息通过 n…
两个nsqd间传输数据时，如果有一方或者双方都在LAN中，数据怎样传输？
@昏鸦 你好，想跟你请教个问题： 按照我的学习了解：客户端通过查询nsqlookup得知自己想要的topic的新数据在哪些nsqd上，得到一个nsqd列表，然后客户…
如何为公网上的RabbitMQ/ZeroMQ/nanomsg集群节省流量？
我的期望是这样的： 现在有多个异地的局域网，各局域网内都有若干服务器，所有服务器上的程序之间都需要相互通信。我想通过构建消息队列集群的方式来…
- 共 1 页
- 1
