我正在尝试使用websockets包在Python上构建一个websockets客户端:Websockets 4.0 API
我使用这种方式而不是示例代码,因为我想创建一个websocket客户机类对象,并将其用作网关。在
我在客户端的侦听器方法(receiveMessage)有问题,这会在执行时引发ConnectionClose异常。我想也许这个循环有什么问题。在
这是我尝试构建的简单webSocket客户端:import websockets
class WebSocketClient():
def __init__(self):
pass
async def connect(self):
'''
Connecting to webSocket server
websockets.client.connect returns a WebSocketClientProtocol, which is used to send and receive messages
'''
self.connection = await websockets.client.connect('ws://127.0.0.1:8765')
if self.connection.open:
print('Connection stablished. Client correcly connected')
# Send greeting
await self.sendMessage('Hey server, this is webSocket client')
# Enable listener
await self.receiveMessage()
async def sendMessage(self, message):
'''
Sending message to webSocket server
'''
await self.connection.send(message)
async def receiveMessage(self):
'''
Receiving all server messages and handling them
'''
while True:
message = await self.connection.recv()
print('Received message from server: ' + str(message))
这是主要的:
^{pr2}$
为了测试传入消息侦听器,服务器在建立连接时向客户端发送两条消息。在
客户端正确连接到服务器,并发送问候语。然而,当客户机接收到这两条消息时,它会引发一个ConnectionClosed异常,代码为1000(没有原因)。在
如果删除receiveMessage客户机方法中的循环,则客户机不会引发任何异常,但它只接收一条消息,所以我想我需要一个循环来保持侦听器的活动,但我不知道确切的位置和方式。在
有什么解决办法吗?在
提前谢谢。在
编辑:我意识到,当客户端从服务器接收到所有挂起的消息时,它会关闭连接(并中断循环)。不过,我希望客户能继续收听未来的消息。在
此外,我还尝试添加另一个函数,其任务是向服务器发送“heartbeat”,但客户端还是关闭了连接。在