nsq.reader错误connection closed

妙音 posted @ 2021年4月02日 11:13 in golang with tags nsq , 683 阅读

描述

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

1. 按照nsq官网，搭建一个nsq小集群

2.使用python客户端pynsq编写测试客户端

3. 如果上面过程在一台机子上完成，不会有问题

4. 如果客户端与nsq不在一台机子上，会出现下面错误

错误内容

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

python消费客户端

import nsq

def handler(message):
    print(message, message.body)
    return True


r = 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 time

def 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()