首页 文章

aiohttp - 多个websockets，单个会话？

提问于
浏览 次
1

我对图书馆越来越熟悉，但我对以下情况感到困惑：

我希望不断处理来自两个不同网站的websockets的更新消息 .

但是，由于aiohttp.ClientSession（）对象应存在于协同程序中，因此我无法使用单个会话变量实现此目的 .

import asyncio
import aiohttp

url1 = 'wss://example.com'

async def main():
    session = aiohttp.ClientSession()
    async with session.ws_connect(url1) as ws1:
        async for msg in ws1:
            # do some processing

loop = asyncio.get_event_loop()
loop.create_task(main())
loop.run_forever()

以上将适用于单个websocket连接 . 但是因为ws中msg的异步是一个无限循环，我无法看到我可以把这个异步循环的ws2版本放在哪里 .

python python-asyncio aiohttp

1 回答

  • 3

    由于每个websocket都需要自己的无限循环，因此您可以将其抽象为一个协程，该协程服务于websocket并接受来自其调用者的会话 . 调用协程将使用 loop.create_task 创建服务任务"in the background"，也可以从协程调用：

    async def setup():
    session = aiohttp.ClientSession()
    loop = asyncio.get_event_loop()
    loop.create_task(serve(url1, session))
    loop.create_task(serve(url2, session))

async def serve(url, session):
    async with session.ws_connect(url) as ws:
        async for msg in ws:
            ...

loop = asyncio.get_event_loop()
loop.run_until_complete(setup())
loop.run_forever()
    回复于

相关问题