import asyncio import websockets import time async def echo(websocket, path): async for message in websocket: print(f'[{time.ctime()}]: ') print(message) message = "服务端获取到消息: {}".format(message) await websocket.send(message) print('WebSocket服务启动成功，可通过 ws://localhost:8765 进行访问') # asyncio.create_task(echo('localhost', 8765)) asyncio.get_event_loop().run_until_complete(websockets.serve(echo, 'localhost', 8765)) asyncio.get_event_loop().run_forever() ''' # 创建一个WebSocket服务端 # 用于接收解析到的弹幕数据 # 测试弹幕转发功能 ''' 这段代码会报错 帮我修改一下

这段代码报错的原因是缺少 `websockets` 模块的安装。请先执行以下命令安装 `websockets` 模块：

pip install websockets

然后，你可以尝试修改代码如下：

import asyncio
import websockets
import time

async def echo(websocket, path):
    async for message in websocket:
        print(f'[{time.ctime()}]: ')
        print(message)
        message = "服务端获取到消息: {}".format(message)
        await websocket.send(message)

print('WebSocket服务启动成功，可通过 ws://localhost:8765 进行访问')

start_server = websockets.serve(echo, 'localhost', 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

这样应该可以解决报错的问题。