群聊消息

创建群组

Socket.IO 房间是一个虚拟概念，允许你将 sockets（连接）分组在一起。处于同一房间的 sockets 可以轻松地彼此通信。当你想要向特定组的客户端广播消息而不是向所有连接的客户端广播时，这个特性非常有用。

变更 main.py:

@@ -25,3 +25,13 @@ async def user_join(sid, user):
 async def chat(sid, data):
     to = data['to']
     await sio.emit('chat', data, room=to)
+
+
+@sio.on('create-group')
+# Create Room
+async def create_group(sid, data):
+    socketIds, roomName, roomId = data['sids'], data['name'], data['id']
+    for socketId in socketIds:
+        await sio.enter_room(socketId, roomId)
+    await sio.emit('create-group', data, room=roomId)
+    print(f"Room {roomId} => {roomName} created")

• sids 带有待创建群组的所有 socket ID。
• roomId 是一个唯一的字母数字字符串。相比于用户输入的房间名称，它更适合作为房间的内部标识。

sio.emit("create-group", ..., room=roomId) 通知所有参与者“新群组已经创建”。

转发群聊消息

变更 main.py:

@@ -27,6 +27,12 @@ async def chat(sid, data):
     await sio.emit('chat', data, room=to)
 
 
+@sio.on('group-chat')
+async def group_chat(sid, data):
+    roomId = data['room']
+    await sio.emit('group-chat', data, room=roomId, skip_sid=sid)
+
+
 @sio.on('create-group')
 # Create Room
 async def create_group(sid, data):

sio.emit(..., room=roomId, skip_sid=sid) 转发消息给所有房间参与者，除了发送者自己。