线程中的aiohttp服务器的以下示例失败，并出现RuntimeError: There is no current event loop in thread 'Thread-1'.错误：
import threading
from aiohttp import web
def aiohttp_server():
def say_hello(request):
return web.Response(text='Hello, world')
app = web.Application(debug=True)
app.add_routes([web.get('/', say_hello)])
web.run_app(app)
t = threading.Thread(target=aiohttp_server)
t.start()
如何在线程中运行aiohttp服务器？
handler在主线程中创建，然后在子线程中手动创建事件循环。
import asyncio
import threading
from aiohttp import web
def aiohttp_server():
def say_hello(request):
return web.Response(text='Hello, world')
app = web.Application(debug=True)
app.add_routes([web.get('/', say_hello)])
handler = app.make_handler()
return handler
def run_server(handler):
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
server = loop.create_server(handler, host='127.0.0.1', port=8089)
loop.run_until_complete(server)
loop.run_forever()
t = threading.Thread(target=run_server, args=(aiohttp_server(),))
t.start()
对于new aiohttp，请使用以下内容，感谢@Auyer的通知。
import asyncio
import threading
from aiohttp import web
def aiohttp_server():
def say_hello(request):
return web.Response(text='Hello, world')
app = web.Application()
app.add_routes([web.get('/', say_hello)])
runner = web.AppRunner(app)
return runner
def run_server(runner):
loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
loop.run_until_complete(runner.setup())
site = web.TCPSite(runner, 'localhost', 8080)
loop.run_until_complete(site.start())
loop.run_forever()
t = threading.Thread(target=run_server, args=(aiohttp_server(),))
t.start()
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句