我正在嘗試使用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”，但客戶端還是關閉了連接。在

總結

以上是生活随笔為你收集整理的python3.6 websocket异步高并发_在Python3.6上的websocket客户端中侦听传入消息时出现问题...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。