问题：

无法使用Flask SocketIO将消息发送到房间

欧阳狐若

2023-03-14

我正在构建一个简单的聊天应用程序，我一直试图用Flask-SocketIO向房间发送消息。

来自客户端的“mesage_event”事件很好地到达服务器，但是，我在客户端看不到任何东西。我不知道服务器是否向房间发射了一些东西，但是在客户端，我看不到控制台中的任何东西。我只能成功的发送给所有的客户端与广播。

这是我在服务器端的代码：

@socketio.on("send msg")
def sendsocket(data):
    print("send msg start:", data["msg"])
    msg = data["msg"]
    room = data["room"]
    emit("message_event", msg, room = room)

以及客户端：

1-用于发送消息：

socket.emit('send msg', {'msg': msg, 'room': room})

2-用于触发事件处理程序：

socket.on('message_event', data => {
    console.log("message received:", data);
});

共有2个答案

公良照

2023-03-14

不知道为什么发送和发射功能从flask_socketio不工作。如果我使用ocketio（套接字实例），它将成功发送消息。

socketio.emit('EVENT_NAME', data, to='YOUR_ROOM')

方野

2023-03-14

你错过了两件事。

首先，您需要向服务器发送一个“join”事件。

<script>
function joinRoom() {
    console.log("ask server to join room");
    socket.emit("join", { "user": Date.now(), "room": "Notifications" });
}
</script>

<body>
    <button onclick="joinRoom()">Join</button>
</body>

例如，这里我将触发器连接到一个按钮上。为了使最初测试向文件室添加用户更容易，我使用了Date。现在（）作为用户名。您可以打开不同的选项卡作为不同的用户。

第二，您需要有一个处理该连接事件的处理程序。
在Flask-SocketIO文档的房间和命名空间部分有一个例子。

@socketio.on("join")
def on_join(data):
    user = data["user"]
    room = data["room"]
    print(f"client {user} wants to join: {room}")
    join_room(room)
    emit("room_message", f"Welcome to {room}, {user}", room=room)

在处理程序中，需要调用join\u room方法将用户添加到当前命名空间下的文件室中。请注意关于名称空间的那部分。默认情况下，所有连接都位于根（/）命名空间下。如果您有自定义名称空间，那么每个名称空间都有自己的文件室。

还有一个相应的离开房间方法。

以下是完整的服务器端代码：

@socketio.on("connect")
def connect():
    print("client wants to connect")
    emit("status", { "data": "Connected. Hello!" })

@socketio.on("join")
def on_join(data):
    user = data["user"]
    room = data["room"]
    print(f"client {user} wants to join: {room}")
    join_room(room)
    emit("room_message", f"Welcome to {room}, {user}", room=room)

以下是完整的客户端代码：

<script type="text/javascript" charset="utf-8">
    const socket = io();
    socket.on("connect", () => {
        console.log("connect");
    });
    socket.on("status", (status) => {
        console.log("received status: " + status.data);
    });
    socket.on("room_message", (msg) => {
        console.log("message from room: " + msg);
    });
    function joinRoom() {
        console.log("ask server to join room");
        socket.emit("join", { "user": Date.now(), "room": "Notifications" });
    }
</script>

<body>
    <button onclick="joinRoom()">Join</button>
</body>

现在，您可以打开多个选项卡并将每个选项卡连接到服务器。服务器端应显示以下消息：

client wants to connect
client wants to connect
client wants to connect
client 1582428076724 wants to join: Notifications
client 1582428080023 wants to join: Notifications
client 1582428082916 wants to join: Notifications

在第一个用户加入聊天室时（1582428076724），您应该能够看到其他用户加入聊天室时的日志。

connect 
received status: Connected. Hello!
ask server to join room 
message from room: Welcome to Notifications, 1582428076724 
message from room: Welcome to Notifications, 1582428080023 
message from room: Welcome to Notifications, 1582428082916

无法使用Flask SocketIO将消息发送到房间

共有2个答案

相关问答

相关文章

相关阅读

相关工具

相关文档