python-3.x - 与 aiohttp 应用程序内的 Redis(aioredis) 失去连接

Question

我正在aiohttp中构建基于text/event-stream的 View ，并在aioredis实现中使用Redis的pub-sub。它看起来像:

从服务器获取一些数据并发布到chanell的脚本

def main(host, port):
    server_logger.info('Got params connection host {0}, port {1}'.format(host, port))
    loop = asyncio.get_event_loop()
    title = None
    redis = loop.run_until_complete(create_redis(('localhost', 6379)))
    while True:
        new_title = loop.run_until_complete(get_title(host, port))
        if new_title != title:
            loop.run_until_complete(redis.publish('CHANNEL', new_title))
            title = new_title
    loop.close()
    return False

aiohttp View 订阅 channel 并将其写入 Stream 响应

stream = web.StreamResponse()
stream.headers['Content-Type'] = 'text/event-stream'
stream.headers['Cache-Control'] = 'no-cache'
stream.headers['Connection'] = 'keep-alive'

await stream.prepare(request)

redis = await create_redis(('localhost', 6379))
channel = (await redis.subscribe('CHANNEL'))[0]

while await channel.wait_message():
        message = await channel.get()
        if message:
            stream.write(b'event: track_update\r\n')
            stream.write(b'data: ' + message + b'\r\n\r\n')
        else:
            continue

我有很多次这样的情况:

DEBUG:aioredis:Creating tcp connection to ('localhost', 6379)

因此 Sonnection 丢失，这也会导致 concurrent.futures.CancelledError 并且保持事件连接将丢失。 连接经常丢失可以吗？我期待有持久的连接，如果我错过了什么，抱歉。

Answer 1

首先在请求处理程序中创建新的 Redis 连接是个坏主意。 请为每个应用程序使用一个连接池。

您可能会得到https://github.com/KeepSafe/aiohttp/blob/master/demos/polls/aiohttpdemo_polls/main.py作为推荐设计原则的草图。

关于保持连接 - 它们不是很持久，但默认在 75 秒不活动期后关闭。

您可以通过将 keep_alive=300 参数传递给 app.make_handler() 调用来增加周期，但设置非常大的值并不稳健 - 在 TCP 自然连接期间可能会在某些情况下会在没有通知的情况下被破坏。 如果没有数据要传递，最好保持合理的慢速超时并定期向服务器发送自定义 ping 请求。