我想通过asyncio
和websockets
连接到一个websocket,格式如下所示。我该如何实现?
from websockets import connect
class EchoWebsocket:
def __init__(self):
self.websocket = self._connect()
def _connect(self):
return connect("wss://echo.websocket.org")
def send(self, message):
self.websocket.send(message)
def receive(self):
return self.websocket.recv()
echo = EchoWebsocket()
echo.send("Hello!")
print(echo.receive()) # "Hello!"
server.serve_forever()
行。具体启动服务器的方式取决于您想要实现什么目标。与asyncio一起使用的流行高级库是aiohttp。它提供了一种处理许多协议(包括WebSockets)的方法。 - Mikhail Gerasimovserver.serve.forever()
,所以我有点困惑。你能否看一下我的问题,链接在SO上 https://dev59.com/Irroa4cB1Zd3GeqPi151 - HJA24