我有一个在服务器端生成的消息。
根据flask socketio doc,您可以将服务器端生成的消息通过 socketio.emit
或者 socketio.send
信息是在Kafka消费者
topicReply = 'botReply'
consumerReply = KafkaConsumer(topicReply, value_deserializer=lambda m: json.loads(m.decode('ascii')))
for message in consumerReply:
fromConsumer(message.value)
我将此消息发送给 server.py
通过简单的呼叫 fromConsumer
方法如上所示。
然后在我的 server.py
,我打电话 socketio.emit
发送给客户
app = Flask(__name__)
socketio = SocketIO(app)
def fromConsumer(msg):
socketio.emit('reply', msg)
if __name__ == '__main__':
socketio.run(app)
然后在我的客户端javascript
var socket = io.connect('http://localhost:1000/');
socket.on('reply', function(msg) {
console.log('Received reply');
console.log(msg)
});
这应该会在浏览器javascript控制台中显示收到的回复消息,但我什么也看不到。
我错过了什么?请建议。
暂无答案!
目前还没有任何答案,快来回答吧!