python—通过socketio kafka将服务器生成的消息发送回客户端

kcugc4gi  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(314)

我有一个在服务器端生成的消息。
根据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控制台中显示收到的回复消息,但我什么也看不到。
我错过了什么?请建议。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题