nsq.reader错误connection closed

描述

学习官网例子时，会碰到的一个小错误. 过程描述:

按照nsq官网，搭建一个nsq小集群
使用python客户端pynsq编写测试客户端
如果上面过程在一台机子上完成，不会有问题
如果客户端与nsq不在一台机子上，会出现下面错误

错误内容

WARNING:nsq.reader:[localhost.localdomain:4150:test:abc] connection closed

python消费客户端

import nsqdef handler(message):print(message, message.body)return Truer = nsq.Reader(message_handler=handler,lookupd_http_addresses=['http://192.168.120.101:4161'],topic='test', channel='abc', lookupd_poll_interval=15)nsq.run()

python生产客户端

import nsq
import tornado.ioloop
import timedef pub_message():writer.pub('test', str(time.strftime('%H:%M:%S')).encode("utf-8"), finish_pub)def finish_pub(conn, data):print(data)writer = nsq.Writer(['127.0.0.1:4150'])tornado.ioloop.PeriodicCallback(pub_message, 1000).start()
nsq.run()

正确方法

启动nsqd时，指定nsqd的广播ip，也就是其它机子可以访问的ip，而非默认的localhost。例如："-broadcast-address 192.168.120.101"

佛說大乘無量壽莊嚴清淨平等覺經pdf
净土大经科注2014-doc
此生必看的科学实验-水知道答案
印光大师十念法（胡小林主讲第1集）

nsq.reader错误connection closed相关推荐

Idhttp get baidu 错误 connection closed Gracefully
url:=IdHTTP1.get('http://www.baidu.com'); memo1.text:=url; 就这么简短的一个代码,他既然报个connection closed Gracefu ...
解决莫名其妙出现connection closed的错误
最近发现使用了springMVC的新项目偶尔出现connection closed,同事反映当访问同一个controller时经常出现类似错误上回发现在使用 <context:componen ...
oracle12537错误,ORA-12537:TNS:connection closed错误处理方法
1.ORA-12537:TNS:connection closed错误处理过程检查监听正常,Oracle服务也是正常启动的,但是登录不进去. 2.解决方案 1. cd $ORACLE_HOME/bi ...
xshell 常用配置_Xshell连接报Connection closed by foreign host错误的解决办法
最近阿里云服务器控制管理平台升级后变化很大,在服务器安全上也更加完善,部分功能也加入付费需求,系统打补丁也开始收钱啦.导致很多人在用Xshell连接服务器的时候莫名报很多错误. 下面说说最常报的连接错 ...
关于Indy TIdTCPServer控件出现 connection closed gracefully 错误的处理
简单的说,当TidTCPServer调用Read方法接收数据时.或调用Write方法发送数据时,客户端主动直接断开了连接,就会触发该异常:这是正常,忽略这一错误就可以了. Indy : Connect ...
【错误】kex_exchange_identification: Connection closed by remote hos
文章目录错误描述解决方法错误描述在 git push 的时候出现了下面这个错误 kex_exchange_identification: Connection closed by remote ...
Connection closed by foreign host. 误改BUG
昨天调试远程服务器,为了增加socket链接数,理所当然的进行了limits.conf配置,之后悲剧发生了. 利用xshell再度远程时,被强制T了.链接瞬间即断,如果幸运,会弹出 "Con ...
Flutter之运行提示Could not update files on device: Connection closed before full header was received
1 问题运行flutter app提示错误如下 Performing hot restart... Syncing files to device MIX 3... Could not update ...
ssh_exchange_identification: Connection closed by remote host解决方法
scp远程传输文件时发现报 ssh_exchange_identification: Connection closed by remote host 尝试ssh报相同的错误,首先telnet 22端 ...

nsq.reader错误connection closed

描述

错误内容

python消费客户端

python生产客户端

正确方法

nsq.reader错误connection closed相关推荐

最新文章

热门文章