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



我正在构建一个简单的聊天应用程序,我一直在尝试使用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);
});

您缺少了两件事。

1st,您需要向服务器发送一个"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.now()作为用户名。您可以打开不同的选项卡作为不同的用户。

2nd,您需要有一个join事件的处理程序
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_room方法将用户添加到当前命名空间下的房间中。请注意关于命名空间的部分。默认情况下,所有连接都在根(/(命名空间下。如果您有自定义名称空间,那么每个名称空间都将有自己的房间。

还有一种相应的leave_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的send-and-emit函数不起作用。如果我使用socketio(socket实例(,它将成功发送消息。

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

最新更新