Skip to content

异步使用指南

本章节介绍项目中提供的异步接口。章节结构与 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

# myoption.yml
client:
  impl: html
  # 指定异步客户端的底层实现类 (目前仅有: async_api)
  async_impl: async_api