所以我有一个简单的flask服务器,想听听nsqd(我的nsqd和nsqlookupd dockers运行得很好。)我使用python中的gnsq作为实现这一点的工具
server.py:
from flask import Flask
import gnsq
consumer = gnsq.Consumer('test_topic', 'test_channel', '0.0.0.0:4161')
@consumer.on_message.connect
def handler(consumer, message):
print ('got message:', message.body)
consumer.start()
app = Flask(__name__)
@app.route("/")
def hello():
return "Flasky"
当我运行服务器时,我得到的只是
[0.0.0.0:4161] connection failed (NSQSocketError(57, 'Socket is not connected'))
我也尝试过更换端口,但仍然坚持
目前没有回答
相关问题 更多 >
编程相关推荐