### 使用Python编写WebSocket服务 WebSocket是一种允许浏览器和服务端之间进行全双工通信的技术协议，广泛应用于实时聊天、在线游戏等应用场景中。接下来我们将演示如何使用`websockets`库快速搭建一个简单的 WebSocket 服务。 #### 准备工作 首先确保安装了所需的 Python 包。可以通过 pip 工具轻松获取它们： ```bash pip install websockets asyncio ``` #### 编写WebSocket服务器代码示例 下面是一个基本的 WebSocket 服务实现。这个服务器将监听来自客户端的信息并在控制台打印出来；同时支持向每个连接过来的新客户广播一条欢迎消息以及处理断线的情况。 ```python import asyncio import websockets import logging logging.basicConfig(level=logging.INFO) connected_clients = set() async def handler(websocket, path): """ 每当有新的 WebSocket 客户端连接进来时调用该处理器。 :param websocket: 表示当前与之互动的具体套接字实例。 :param path: URL 路径部分，默认为空串 ("")。 """ # 将新加入者添加至列表，并告知所有人某人来了 connected_clients.add(websocket) welcome_msg = f"欢迎来到我们的 WebSocket 世界！现在这里有 {len(connected_clients)} 名成员." await notify_users(welcome_msg) try: async for message in websocket: logging.info(f"收到消息 <{message}> 来自：{websocket.remote_address}") # 反射回相同的内容给发送方作为回应 response_to_client = f"[Echo] -> {message}" await websocket.send(response_to_client) # 广播这条消息给大家看 broadcast_message = f"{websocket.remote_address}说：<{message}>" await notify_users(broadcast_message) finally: # 清理离线人员记录并向剩余用户报告有人离开了房间 if websocket in connected_clients: connected_clients.remove(websocket) goodbye_msg = f"一位朋友离开了我们...目前还有 {len(connected_clients)} 位小伙伴在这里." await notify_users(goodbye_msg) async def notify_users(message): """群发消息给所有已知在线的人""" if not connected_clients: return tasks = [client.send(message) for client in connected_clients] await asyncio.wait(tasks) start_server = websockets.serve(handler, "", 6789) logging.info("启动 WebSocket 服务器...") try: asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_forever() except Exception as ex: logging.error(f"遇到了一些问题：{ex}") finally: logging.info("正在关闭 WebSocket 服务器...") if __name__ == "__main__": pass # 此处不需要额外的操作，因为上面已经包含了完整的业务逻辑 ``` #### 主要功能点解析 1. **异步I/O** - 利用了`asyncio`模块提供的并发能力使得多个客户端能够高效地共享相同的事件循环周期； 2. **管理活动参与者集合 (`connected_clients`)** - 新访客到达时将其纳入名单并通过`await notify_users()`通知其他成员知晓新人到来的事实； - 用户离开时及时清理掉对应的引用以防内存泄露的问题出现。 3. **日志记录系统**: 引入标准的日志工具帮助开发者更好地追踪程序运行期间发生的各种状况（如异常信息）； 4. **消息反射机制**: 收取到任意一行文字后直接转发回去构成“回声效应”，便于验证连通性良好与否； 5. **全局通告服务`: 维护一个辅助函数负责把最新的动态分享给每一位仍然活跃着的朋友圈内的伙伴们看到。 以上就是关于构建基础版 WebSocket 服务平台的一个简明教程啦！ ---