### Python 高并发 HTTP 请求模拟 在 Python 中，`aiohttp` 和 `asyncio` 是实现高并发 HTTP 请求的理想组合。以下是基于用户需求的一个完整示例程序，展示如何利用这两个库来高效地发起大量 HTTP 请求。 #### 示例代码 以下是一个完整的异步 HTTP 请求模拟脚本： ```python import asyncio import aiohttp @asyncio.coroutine def fetch_url(session, url): """ 发起单个 URL 的 GET 请求并返回响应状态 """ try: with aiohttp.Timeout(10): # 设置超时时间为 10 秒 response = yield from session.get(url) status_code = response.status text = yield from response.text() print(f"URL: {url}, Status Code: {status_code}") return {"url": url, "status": status_code} except Exception as e: print(f"Error fetching {url}: {e}") async def main(urls): """ 主函数：创建会话并并发请求所有 URL """ async with aiohttp.ClientSession() as session: tasks = [] for url in urls: task = asyncio.ensure_future(fetch_url(session, url)) tasks.append(task) results = await asyncio.gather(*tasks) return results if __name__ == "__main__": test_urls = [ "https://www.google.com", "https://www.github.com", "https://www.stackoverflow.com" ] loop = asyncio.get_event_loop() responses = loop.run_until_complete(main(test_urls)) print(responses) ``` 此代码展示了如何使用 `aiohttp` 来发起多个 HTTP 请求，并通过 `asyncio.gather()` 并发运行这些任务[^3]。 --- #### 关键点解析 1. **`aiohttp.ClientSession`**: 它是用于管理连接池的对象，在多次请求间重用 TCP 连接，从而提高性能和资源利用率[^1]。 2. **`asyncio.gather`**: 此方法允许一次性启动多个协程任务，并等待它们全部完成后再继续执行后续逻辑[^3]。 3. **异常处理**: 在实际应用中，网络请求可能会失败或超时。因此，建议为每个请求添加适当的错误捕获机制，以便更好地调试和监控系统行为[^2]。 4. **事件循环控制 (`loop.run_until_complete`)`: 当前版本的 Python 推荐直接调用 `asyncio.run()` 方法简化入口设置；但在更早的标准下，则需手动获取事件循环实例并通过其驱动整个流程结束[^4]。 --- ### 性能优化提示 尽管上述方案已具备较高水平的并发能力，但仍可通过调整参数进一步提升效率： - 调整最大连接数限制（默认值可能不足以满足极高负载场景下的需求）； - 实施指数退避策略应对瞬时流量高峰带来的服务端压力反弹现象。 ---