Flask-SocketIO empfängt keine Nachrichten vom Frontend, wenn es mit RabbitMQ verwendet wird

Question

Ich versuche, meine Flask-App so einzurichten, dass RabbitMQ als Nachrichtenwarteschlange verwendet wird. Es funktioniert gut, wenn ich Nachrichten vom Server ausliege, aber wenn ich versuche, Nachrichten auszugeben passiert nichts. Es scheint, als ob der Front-End-Socket nicht mit der Warteschlange kommuniziert.

Mein Socket-Code sieht wie folgt aus:

from flask_socketio import emit, SocketIO 

socketio_mp = SocketIO(message_queue='amqp://guest:guest@localhost:5672//') 

@socketio_mp.on('connected', namespace='/test') 
def joined(): 
    """Sent by clients when they enter a room. 
    A status message is broadcast to all people in the room.""" 
    print('connected') 

Der Sockel richtig in den Kolben-SocketIO docs wie gezeigt initialisiert. Das Ereignis connected wird nie ausgelöst, obwohl es vom Frontend ausgegeben wird.

var namespace = "/test"; 
socket = io.connect(location.protocol + "//" + document.domain + ":" + location.port + namespace); 

socket.on("connect", function() { 

    console.log("connected"); 
    socket.emit("connected", {msg: "next"}); 
}); 

Ich bekomme auch keine Fehler in der Konsole.

Answer 1

Wenn Sie Ihre SocketIO Instanz erstellen, müssen Sie Ihre Flask App als erstes Argument übergeben:

socketio_mp = SocketIO(app, message_queue='amqp://guest:guest@localhost:5672//') 

Als Randbemerkung, ich bin nicht sicher, was Sie erwarten, anders zu sein, wenn Sie ein hinzufügen Nachrichtenwarteschlange auf diese Weise. Die Clients sprechen niemals mit der Nachrichtenwarteschlange. Die Warteschlange wird intern verwendet, wenn Sie mehrere Flask-SocketIO-Server oder Emit-Only-Prozesse haben. Clients haben keinen direkten Zugriff auf die Warteschlange.