代码之家 › 专栏 › 技术社区 › SimSimY

python websockets,如何设置连接超时

websocket python-3.x python

SimSimY · 技术社区 · 6 年前

目前,连接尝试和 TimeoutError

我似乎找不到一种方法来减少这个窗口(所以我可以尝试另一个WebSocket服务器)

这是我正在运行的演示代码:(刚从 official docs

#!/usr/bin/env python

import asyncio
import websockets
import os
import socket
import logging
logging.basicConfig(level=logging.INFO, format='%(asctime)s %(levelname)-8s [%(name)s.%(funcName)s:%(lineno)d]: %(message)s', datefmt='%m-%d %H:%M:%S', )


host = os.environ.get('SERVER_URL','localhost:9090')
self_id = os.environ.get('SELF_ID',socket.gethostname())

connect_url =f'ws://{host}/{self_id}'
logging.info(f'Connect to: {connect_url}')

async def hello(uri):
    logging.info(f'Connecting to {uri}')
    async with websockets.connect(uri, timeout=1, close_timeout=1) as websocket:
        logging.info(f"Conected to {uri}")
        async for message in websocket:
            await websocket.send(message)

asyncio.get_event_loop().run_until_complete(
    hello(connect_url))

0 回复 | 直到 6 年前

Joules 4 年前

可以使用asyncio的wait_for(),如下所示:

import asyncio
from concurrent.futures import TimeoutError as ConnectionTimeoutError
# whatever url is your websocket server
url = 'ws://localhost:9090'
# timeout in seconds
timeout = 10  
try:
    # make connection attempt
    connection = await asyncio.wait_for(websockets.connect(url), timeout)
except ConnectionTimeoutError as e:
    # handle error
    print('Error connecting.')

它会引起 <class 'concurrent.futures._base.TimeoutError'> 可以用 except ConnectionTimeoutError 阻止。

在python3.8中,它会引发一个 TimeoutError 可以用 except asyncio.exceptions.TimeoutError 阻止。

推荐文章

young · 插座io错误格式错误的箭头函数参数列表[关闭]

3 年前

Taylor Johnson · c从套接字接收到无符号字符数组时的意外输出

3 年前

Moshe Shaham · 我应该使用现有的websocket连接进行请求/响应操作吗?

3 年前

Nikita Sivukhin · Kotlin ktor库不必等待websockets处理程序中的所有协同程序完成

3 年前

noobyy · 异步函数阻塞主线程

3 年前

June Leow · 跨选项卡使用Web套接字的实时通知栏

3 年前

Muposat · AIOHTTPS服务器不与套接字通信。io客户端,错误404

7 年前

garson · 打开Websocket(“消息”)不工作

7 年前

TomáÅ¡ Zato · 无法连接到套接字io服务器

7 年前

Tonys AnsonÄ« Misirgis · 当“网站”选项卡关闭时,服务器如何知道关闭websocket的连接

7 年前