Python 3; Websockets服务器和HTTP服务器- run_forever & serve_forever

zengzsys  于 2023-04-19  发布在  Python
关注(0)|答案(2)|浏览(175)

我试图在同一个python应用程序中运行一个websockets服务器和一个http服务器。看起来我试图运行两个永久循环,而第二个循环没有被激活。有什么建议可以让这两个服务器都运行吗?

httpd = HTTPServer(('localhost', 8000), SimpleHTTPRequestHandler)

httpd.serve_forever()
asyncio.get_event_loop().run_until_complete(
    websockets.serve(echo, 'localhost', 8001))
asyncio.get_event_loop().run_forever()
oxf4rvwz

oxf4rvwz1#

这里有一种方法可以在一个服务器上同时处理websockets和http请求。唯一的区别是两个处理程序都监听同一个端口。
我认为可以通过定义两个aiohttp应用程序来监听不同的端口。但是,在任何情况下,您都需要一个支持异步的HTTP服务器。AFAIK HTTPServer不支持异步的,因此您提出的解决方案无法工作,因为您将基于异步的服务器(websockets.serve)与非异步服务器(HTTPServer)混合在一起。

#!/usr/bin/python3.7

import aiohttp
from aiohttp import web, WSCloseCode
import asyncio

async def http_handler(request):
    return web.Response(text='Hello, world')

async def websocket_handler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)

    async for msg in ws:
        if msg.type == aiohttp.WSMsgType.TEXT:
            if msg.data == 'close':
                await ws.close()
            else:
                await ws.send_str('some websocket message payload')
        elif msg.type == aiohttp.WSMsgType.ERROR:
            print('ws connection closed with exception %s' % ws.exception())

    return ws

def create_runner():
    app = web.Application()
    app.add_routes([
        web.get('/',   http_handler),
        web.get('/ws', websocket_handler),
    ])
    return web.AppRunner(app)

async def start_server(host="127.0.0.1", port=1337):
    runner = create_runner()
    await runner.setup()
    site = web.TCPSite(runner, host, port)
    await site.start()

if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(start_server())
    loop.run_forever()
t5zmwmid

t5zmwmid2#

Sanic似乎能够同时提供HTTP和WebSockets服务。
https://sanic.dev/en/guide/basics/app.html
不过,看起来很大很复杂。

相关问题