### 多人协作文档编辑的功能实现 #### WebSocket 连接管理与消息广播 为了支持多人实时协作，可以利用 Python 的 `websockets` 库创建 WebSocket 服务器。该库提供了异步 I/O 支持，能够高效处理多个客户端连接并进行消息广播。 当一个用户发送更新文档的消息时，服务器会接收此消息并通过 WebSocket 将其广播给其他已连接的客户端[^1]。以下是基本的 WebSocket 服务端代码： ```python import asyncio import websockets from collections import defaultdict connected_clients = set() document_content = {} async def broadcast(message): if connected_clients: await asyncio.wait([client.send(message) for client in connected_clients]) async def handle_client(websocket, path): global document_content # 注册新连接 connected_clients.add(websocket) try: async for message in websocket: data = eval(message) action = data.get('action') if action == 'edit': doc_id = data['docId'] content = data['content'] # 更新内存中的文档内容 if doc_id not in document_content: document_content[doc_id] = "" # 使用最后修改者优先策略覆盖冲突 document_content[doc_id] = content # 广播更改后的文档内容 response = { "type": "update", "docId": doc_id, "content": document_content[doc_id] } await broadcast(str(response)) finally: # 移除断开连接的客户端 connected_clients.remove(websocket) start_server = websockets.serve(handle_client, "localhost", 8765) asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_forever() ``` 以上代码实现了简单的 WebSocket 通信逻辑，其中包含了客户端加入、退出以及消息广播等功能[^1]。 --- #### 内存存储笔记内容 在上述代码中，`document_content` 是一个字典对象，用于保存当前所有正在编辑的文档及其内容。每当有新的编辑请求到达时，都会更新对应文档的内容，并将其同步至所有在线用户。这种方式适合轻量级应用，但如果需要持久化存储，则应考虑数据库解决方案（如 SQLite 或 MongoDB）[^3]。 需要注意的是，在多线程或多进程环境中访问共享资源可能会引发可见性问题。例如，如果两个不同的线程同时尝试修改同一份文档内容，可能导致部分更新丢失或数据不一致的情况发生。针对此类场景，可以通过引入锁机制或其他并发控制手段加以规避[^2]。 --- #### 冲突检测与解决机制 本方案采用 **“最后修改者优先”** 的策略来处理潜在的编辑冲突。具体而言，无论何时收到用户的编辑指令，都将直接替换掉现有版本的数据，而无需额外协商或合并差异。这种做法简单易行，但在某些情况下也可能带来负面体验——特别是当两位作者几乎同时提交改动时，后者的工作成果将会完全覆盖前者的结果。 更复杂的冲突解决方法涉及文本差分算法（diff algorithm），它可以识别两版之间的新增删除片段，并试图自动融合这些变化；然而这通常意味着更高的计算成本和技术复杂度。因此，在实际开发过程中需权衡用户体验需求与系统性能表现之间关系作出合理取舍[^1]。 ---