所以我有一个简单的烧瓶服务器,想听 nsqd,(我的 nsqd 和 nsqlookupd docker 运行良好。)我使用 python 中的 gnsq 作为工具来实现这一点
服务器.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'))
我也尝试过更改端口,但仍然存在。