在Tornado RequestHandler中使用AsyncHttpClient抛出事件循环已运行异常

这个错误的核心原因很明确：你在已经运行的IOLoop里调用了run_sync()，而这个方法的设计初衷是用于在未启动的IOLoop上同步运行异步任务，或者作为程序入口启动循环。当Tornado服务器正在处理请求时，主IOLoop已经处于运行状态，此时调用run_sync()就会触发冲突异常。

问题代码的关键问题点 #

你的RegistrationHandler.post()是同步方法，然后在call_async_register()里试图用instance.run_sync(call)来执行异步的HTTP请求——这完全违背了Tornado的异步设计思路。run_sync()会尝试启动一个新的循环（或者复用已有的，但要求循环处于停止状态），而此时处理请求的循环已经在跑了，自然会报错。

修正方案：改用Tornado的异步RequestHandler #

Tornado原生支持异步的请求处理方法，只需要把post方法改成async def，然后直接await异步操作即可，完全不需要手动管理Future或者调用run_sync()。

修正后的代码示例：

class RegistrationHandler(tornado.web.RequestHandler):
    # 把post改成异步方法
    async def post(self, *args, **kwargs):
        # 直接await异步调用
        response_body = await call_async_register("some params")
        # 根据结果处理响应
        if response_body:
            self.write(response_body)
        else:
            self.set_status(500)
            self.write("Registration failed")

async def call_async_register(parameters):
    try:
        http_client = AsyncHTTPClient()
        # 假设url、request_type、body是你已经定义好的变量
        http_request = HTTPRequest(url, request_type.name, headers={'X-Peering': '1'}, body=body)
        # 直接await fetch返回的Future，无需手动处理回调
        response = await http_client.fetch(http_request)
        return response.body.decode()
    except Exception as err:
        # 注意：这里的self需要调整，因为call_async_register现在不在RequestHandler实例里
        # 如果需要日志，可以把logger作为参数传入，或者用全局logger
        self.logger.exception("Account Request Failed: {}".format(err))
        return None

关键改动说明 #

1. 异步请求处理：将post方法声明为async def，Tornado会自动将其纳入已运行的IOLoop中调度，不需要额外启动循环。
2. 简化异步调用：AsyncHTTPClient.fetch()本身就返回一个Future，直接用await等待其完成即可，不需要手动创建Future和添加回调函数，代码更简洁易读。
3. 移除run_sync：完全去掉IOLoop.current().run_sync()的调用，避免了循环重复启动的冲突。

另外注意：原代码中call_async_register里的self.logger需要调整，因为现在这个函数不在RequestHandler实例内部了——你可以把logger作为参数传入，或者使用全局的logger实例。

内容的提问来源于stack exchange，提问作者Super Hornet