Python调用websockets.broadcast()报错:模块无该属性的问题咨询
解决websockets模块无broadcast属性的问题
问题根源
websockets.broadcast是websockets 10.0版本才新增的API,你遇到AttributeError的核心原因是当前环境安装的websockets版本低于10.0——即便你认为已安装最新版,也可能存在环境不一致的情况(比如未激活虚拟环境、全局/局部包版本冲突)。
排查与解决步骤
确认当前websockets版本
可以通过终端命令直接查看:pip show websockets也可以在你的代码开头加入版本打印,验证运行环境的实际版本:
print(f"当前websockets版本: {websockets.__version__}")若输出版本号小于10.0,说明需要升级。
升级websockets到最新稳定版
执行终端命令完成升级:pip install --upgrade websockets
代码额外修正说明
你的代码还有两处错误,即便版本升级后也无法正常运行:
websockets.serve的回调函数chat参数定义错误:serve默认传递的是(websocket, path),而非(websocket, debug),需修正参数名。websockets.broadcast用法错误:该函数第一个参数必须是所有连接的websocket对象集合,而非直接传入消息。需要维护一个连接池管理客户端连接,修正后的完整可运行代码如下:
import asyncio import websockets # 维护所有在线客户端的连接集合 connected_clients = set() async def chat(websocket, path): # 客户端连接成功后加入集合 connected_clients.add(websocket) try: while True: message = await websocket.recv() # 向所有在线客户端广播消息 await websockets.broadcast(connected_clients, message) finally: # 客户端断开连接后从集合移除 connected_clients.remove(websocket) async def main(): async with websockets.serve(chat, "localhost", 8008): await asyncio.Future() # 挂起协程以保持服务持续运行 if __name__ == "__main__": print(f"websockets版本: {websockets.__version__}") print(f"websockets模块路径: {websockets.__file__}") asyncio.run(main())
内容的提问来源于stack exchange,提问作者PBRParker
相关产品推荐
相关产品推荐

