异步使用指南¶
本章节介绍项目中提供的异步接口。章节结构与 0_common_usage.md 基本对应,可作为从同步迁移到异步代码的对照参考。
1. 异步下载本子/章节¶
你可以直接使用以下方法来进行异步下载:
import asyncio
import jmcomic
async def main():
# 异步下载单个本子
await jmcomic.download_album_async('438696')
# 异步下载单章节
await jmcomic.download_photo_async('438696')
# 批量异步下载(直接传递包含 ID 的列表或迭代器即可,内部会自动同时下载)
await jmcomic.download_album_async(['123', '456'])
if __name__ == '__main__':
asyncio.run(main())
2. 使用 Option 定制化异步下载¶
和同步版本一样,你可以配合 option 对象来定制网络请求、代理、下载路径等:
import asyncio
from jmcomic import create_option_by_file, download_album_async
async def main():
# 通过配置文件来创建option对象
option = create_option_by_file('op.yml')
# 调用异步下载 api,把 option 作为参数传递
await download_album_async(123, option)
asyncio.run(main())
3. 异步获取实体类,并发请求¶
💡 关于 async with 和自动初始化¶
当你使用异步客户端时,推荐直接搭配 async with 上下文管理器来使用:
# 离开代码块时会自动清理并断开连接
async with JmOption.default().new_jm_async_client() as cl:
album = await cl.get_album_detail(123)
客户端会在你真正发起网络请求时自动初始化:
- 结合
async with:当进入async with作用域时,客户端会自动完成域名解析、联通性检查等必要的初始化工作,并在离开时安全释放连接。 - 单独使用:如果你不想使用
async with,而是直接调用cl = op.new_jm_async_client(),那么在第一次发起真实的请求(比如get_album_detail)时,客户端也会自动检测并先执行一遍初始化。
无论哪种写法都只会初始化一次,你不需要自己去调用任何初始化代码,直接用就行。
并发请求示例¶
使用 asyncio.gather 可以并发执行网络请求:
import asyncio
from jmcomic import JmOption, AsyncJmApiClient
async def main():
op = JmOption.default()
# 同步获取客户端对象,并通过上下文管理器自动管理生命周期
async with op.new_jm_async_client() as cl:
# 示例:使用 async 并发获取本子详情
album_id_list = [123, 456]
album_list = await asyncio.gather(
*(cl.get_album_detail(aid) for aid in album_id_list)
)
# 打印结果
for aid, album in zip(album_id_list, album_list):
print(f'[JM{aid}] 本子详情: {album}')
# 获取章节实体类
photo = await cl.get_photo_detail('212214')
print(photo.name)
asyncio.run(main())
4. 异步异常处理示例¶
异步调用的异常机制与同步完全一致,同样可以通过捕获 JmcomicException 及各类派生异常进行处理:
import asyncio
from jmcomic import JmOption, MissingAlbumPhotoException, JsonResolveFailException, RequestRetryAllFailException, JmcomicException
async def main():
async with JmOption.default().new_jm_async_client() as cl:
try:
album = await cl.get_album_detail('99999999')
except MissingAlbumPhotoException as e:
print(f'id={e.error_jmid}的本子不存在')
except JsonResolveFailException as e:
print(f'解析json失败: {e.resp.status_code}')
except RequestRetryAllFailException:
print(f'请求失败,重试次数耗尽')
except JmcomicException as e:
print(f'遇到异常: {e}')
asyncio.run(main())
5. 异步搜索本子¶
由于搜索结果通常有多页,推荐使用 search_gen 异步生成器。配合 async for,客户端会自动处理翻页逻辑并逐页获取数据:
import asyncio
from jmcomic import JmOption
async def main():
async with JmOption.default().new_jm_async_client() as cl:
# async for 会帮你自动加载下一页,一页一页往下搜
async for page in cl.search_gen('+MANA +无修正'):
print(f'当前获取到了第 {page.page} 页,本页数据量: {page.page_size}')
for album_id, title in page.iter_id_title():
print(f'[{album_id}]: {title}')
asyncio.run(main())
如果只需要第一页的数据,依然可以直接调用基础的 await cl.search(...) 方法。
6. 异步获取收藏夹¶
获取收藏夹的用法和搜索非常像,同样支持使用异步生成器 favorite_folder_gen 自动翻页获取整个收藏夹的内容:
import asyncio
from jmcomic import JmOption
async def main():
async with JmOption.default().new_jm_async_client() as cl:
# 先登录
await cl.login('你的用户名', '你的密码')
# 使用 async for 遍历整个收藏夹的所有页
async for page in cl.favorite_folder_gen(folder_id='0'):
# 遍历本页的所有本子
for aid, atitle in page.iter_id_title():
print(aid, atitle)
# 同时支持获取当前账号下的所有收藏夹目录信息
for folder_id, folder_name in page.iter_folder_id_name():
print(f'收藏夹id: {folder_id}, 名称: {folder_name}')
asyncio.run(main())
7. 异步分类 / 排行榜¶
分类和排行榜本质上都是过滤请求,可以使用 categories_filter 异步方法获取分页。
import asyncio
from jmcomic import JmOption
async def main():
async with JmOption.default().new_jm_async_client() as cl:
# 获取全部时间、全部分类下,按观看数排序的第一页本子
page = await cl.categories_filter(
page=1,
time='a', # JmMagicConstants.TIME_ALL
category='all', # JmMagicConstants.CATEGORY_ALL
order_by='mv', # JmMagicConstants.ORDER_BY_VIEW
)
for aid, atitle in page:
print(aid, atitle)
asyncio.run(main())
8. 关于 async_impl 配置¶
注意:仅仅在 option.yml 中增加配置并不能让代码自动变成异步,你必须要在代码中改为调用 _async 相关方法(如上文所示)。
async_impl目前可以不配置,因为配置的作用仅仅是指定底层使用哪种API实现。目前的唯一实现是 async_api: