我有一条在服务器端生成的消息。在
根据flask-socketio doc,可以通过socketio.emit
或{
这个信息是在卡夫卡的消费者那里
topicReply = 'botReply'
consumerReply = KafkaConsumer(topicReply, value_deserializer=lambda m: json.loads(m.decode('ascii')))
for message in consumerReply:
fromConsumer(message.value)
我通过调用上面所示的fromConsumer
方法将此消息发送到server.py
。在
然后在我的server.py
中,我调用socketio.emit
将其发送给客户机
然后在我的客户端javascript上
var socket = io.connect('http://localhost:1000/');
socket.on('reply', function(msg) {
console.log('Received reply');
console.log(msg)
});
这应该会显示浏览器javascript控制台中收到的回复消息,但我什么也没看到。在
我错过了什么?请提出建议。在
目前没有回答
相关问题 更多 >
编程相关推荐