nonebot2/website/docs/advanced
Ju4tCode 91f4daa722
📝 add custom rule guide (#914)
Co-authored-by: StarHeart <starheart233@gmail.com>
2022-04-16 10:20:01 +08:00
..
di 📝 refactor dependency-injection documents (#791) 2022-02-14 17:26:55 +08:00
images 📝 update some advanced docs 2022-02-04 15:12:02 +08:00
export-and-require.md 📝 Fix copywriting 2022-02-06 19:46:14 +08:00
permission.md 📝 add custom rule guide (#914) 2022-04-16 10:20:01 +08:00
publish-plugin.md 📝 Fix copywriting 2022-02-06 19:46:14 +08:00
README.md 📝 refactor dependency-injection documents (#791) 2022-02-14 17:26:55 +08:00
rule.md 📝 add custom rule guide (#914) 2022-04-16 10:20:01 +08:00
runtime-hook.md 📝 refactor dependency-injection documents (#791) 2022-02-14 17:26:55 +08:00
scheduler.md 📝 Fix copywriting 2022-02-06 19:46:14 +08:00
unittest.md 📝 update handler doc 2022-01-06 17:51:32 +08:00

id slug options
index /advanced/
menu
weight category
10 advanced

深入

:::danger 警告 进阶部分尚未更新完成 :::

它如何工作?

如同概览所言:

NoneBot2 是一个可扩展的 Python 异步机器人框架,它会对机器人收到的事件进行解析和处理,并以插件化的形式,按优先级分发给事件所对应的事件响应器,来完成具体的功能。

NoneBot2 是一个可以对机器人上报的事件进行处理并完成具体功能的机器人框架,在这里,我们将简要讲述它的工作内容。

便捷起见,以下内容对 NoneBot2 会被称为 NoneBot与 NoneBot2 交互的机器人实现会被称为协议端

在实际应用中NoneBot 会充当一个高性能,轻量级的 Python 微服务框架。协议端可以通过 http、websocket 等方式与之通信,这个通信往往是双向的:一方面,协议端可以上报数据给 NoneBotNoneBot 会处理数据并返回响应给协议端另一方面NoneBot 可以主动推送数据给协议端。而 NoneBot 便是围绕双向通信进行工作的。

在开始工作之前NoneBot 需要进行准备工作:

  1. 运行 nonebot.init 初始化函数,它会读取配置文件,并初始化 NoneBot 和后端驱动 Driver 对象。
  2. 注册协议适配器 Adapter
  3. 加载插件

准备工作完成后NoneBot 会利用 uvicorn 启动,并运行 on_startup 钩子函数。

随后,倘若一个协议端与 NoneBot 进行了连接NoneBot 的后端驱动 Driver 就会将数据交给 Adapter,然后会实例化 BotNoneBot 便会利用 Bot 开始工作,它的工作内容分为两个方面:

  1. 事件处理Bot 会将协议端上报的数据转化为 Event(事件),之后 NoneBot 会根据一套既定流程来处理事件。

  2. 调用 API,在事件处理的过程中NoneBot 可以通过 Bot 调用协议端指定的 API 来获取更多数据或者反馈响应给协议端NoneBot 也可以通过调用 API 向协议端主动请求数据或者主动推送数据。

指南模块,我们已经叙述了如何配置 NoneBot如何注册协议适配器以及如何加载插件,这里便不再赘述。

下面,我们将对事件处理调用 API 进行说明。

事件处理

我们可以先看事件处理的流程图:

handle-event

在流程图里我们可以看到NoneBot 会有三个阶段来处理事件:

  1. Driver 接收上报数据
  2. Adapter 处理原始数据
  3. NoneBot 处理 Event

我们将顺序说明这三个阶段。其中,会将第三个阶段拆分成概念解释处理 Event特殊异常处理三个部分来说明。

Driver 接收上报数据

  1. 协议端会通过 websocket 或 http 等方式与 NoneBot 的后端驱动 Driver 连接,协议端上报数据后,Driver 会将原始数据交给 Adapter 处理。

:::warning 连接之前必须要注册 Adapter :::

Adapter 处理原始数据

  1. Adapter 检查授权许可,并获取 self-id 作为唯一识别 id 。

:::tip 如果协议端通过 websocket 上报数据,这个步骤只会在建立连接时进行,并在之后运行 on_bot_connect 钩子函数;通过 http 方式连接时,会在协议端每次上报数据时都进行这个步骤。 :::

:::warning self-id 是帐号的唯一识别 ID ,这意味着不能出现相同的 self-id。 :::

  1. 根据 self-id 实例化 Adapter 相应的 Bot

  2. 根据 Event Model 将原始数据转化为 NoneBot 可以处理的 Event 对象。

:::tip Adapter 在转换数据格式的同时可以进行一系列的特殊操作,例如 OneBot 适配器会对 reply 信息进行提取。 :::

  1. BotEvent 交由 NoneBot 进一步处理。

NoneBot 处理 Event

在讲述这个阶段之前,我们需要先对几个概念进行解释。

概念解释

  1. hook ,或者说钩子函数,它们可以在 NoneBot 处理 Event 的不同时刻进行拦截,修改或者扩展,在 NoneBot 中,事件钩子函数分为事件预处理 hook运行预处理 hook运行后处理 hook事件后处理 hook

:::tip 关于 hook 的更多信息,可以查阅这里。 :::

  1. Matchermatcher,在指南中,我们讲述了如何注册事件响应器,这里的事件响应器或者说 Matcher 并不是一个具体的实例 instance,而是一个具有特定属性的类 class。只有当 Matcher 响应事件时,才会实例化为具体的 instance,也就是 matchermatcher 可以认为是 NoneBot 处理 Event 的基本单位,运行 matcher 是 NoneBot 工作的主要内容。

  2. handler,或者说事件处理函数,它们可以认为是 NoneBot 处理 Event 的最小单位。在不考虑 hook 的情况下,运行 matcher 就是顺序运行 matcher.handlers,这句话换种表达方式就是,handler 只有添加到 matcher.handlers 时,才可以参与到 NoneBot 的工作中来。

:::tip 如何让 handler 添加到 matcher.handlers

一方面,我们可以参照这里利用装饰器来添加;另一方面,我们在用 on() 或者 on_*() 注册事件响应器时,可以添加 handlers=[handler1, handler2, ...] 这样的关键词参数来添加。 :::

处理 Event

  1. 执行事件预处理 hook NoneBot 接收到 Event 后,会传入到 事件预处理 hook 中进行处理。

:::warning 需要注意的是,执行多个 事件预处理 hook 时并无顺序可言,它们是并发运行的。这个原则同样适用于其他的 hook。 :::

  1. 按优先级升序选出同一优先级的 MatcherNoneBot 提供了一个全局字典 matchers,这个字典的 key 是优先级 priorityvalue 是一个 list,里面存放着同一优先级的 Matcher。在注册 Matcher 时,它和优先级 priority 会添加到里面。

    在执行 事件预处理 hookNoneBot 会对 matcherskey 升序排序并选择出当前最小优先级的 Matcher

  2. 根据 Matcher 定义的 Rule、Permission 判断是否运行,在选出 MatcherNoneBot 会将 botEvent 传入到 Matcher.check_ruleMatcher.check_perm 两个函数中,两个函数分别对 Matcher 定义的 RulePermission 进行 check当 check 通过后,这个 Matcher 就会响应事件。当同一个优先级的所有 Matcher 均没有响应时NoneBot 会返回到上一个步骤,选择出下一优先级的 Matcher

  3. 实例化 matcher 并执行运行预处理 hook,当 Matcher 响应事件后,它便会实例化为 matcher,并执行 运行预处理 hook

  4. 顺序运行 matcher 的所有 handlers运行预处理 hook 执行完毕后,便会运行 matcher,也就是顺序运行它的 handlers

:::tip matcher 运行 handlers 的顺序是:先运行该 matcher 的类 Matcher 注册时添加的 handlers(如果有的话),再按照装饰器装饰顺序运行装饰的 handlers。 :::

  1. 执行运行后处理 hookmatcherhandlers 运行完毕后,会执行 运行后处理 hook

  2. 判断是否停止事件传播NoneBot 会根据当前优先级所有 matcherblock 参数或者 StopPropagation 异常判断是否停止传播 Event如果事件没有停止传播NoneBot 便会返回到第 2 步, 选择出下一优先级的 Matcher

  3. 执行事件后处理 hook,在 Event 停止传播或执行完所有响应的 MatcherNoneBot 会执行 事件后处理 hook

    事件后处理 hook 执行完毕后,当前 Event 的处理周期就顺利结束了。

特殊异常处理

在这个阶段NoneBot 规定了几个特殊的异常,当 NoneBot 捕获到它们时,会用特定的行为来处理它们。

  1. IgnoredException

    这个异常可以在 事件预处理 hook运行预处理 hook 抛出。

    事件预处理 hook 抛出它时NoneBot 会忽略当前的 Event,不进行处理。

    运行预处理 hook 抛出它时NoneBot 会忽略当前的 matcher,结束当前 matcher 的运行。

:::warning 当 hook 需要抛出这个异常时,要写明原因。 :::

  1. PausedException

    这个异常可以在 handler 中由 Matcher.pause 抛出。

    当 NoneBot 捕获到它时,会停止运行当前 handler 并结束当前 matcher 的运行,并将后续的 handler 交给一个临时 Matcher 来响应当前交互用户的下一个消息事件,当临时 Matcher 响应时,临时 Matcher 会运行后续的 handler

  2. RejectedException

    这个异常可以在 handler 中由 Matcher.reject 抛出。

    当 NoneBot 捕获到它时,会停止运行当前 handler 并结束当前 matcher 的运行,并将当前 handler 和后续 handler 交给一个临时 Matcher 来响应当前交互用户的下一个消息事件,当临时 Matcher 响应时,临时 Matcher 会运行当前 handler 和后续的 handler

  3. FinishedException

    这个异常可以在 handler 中由 Matcher.finish 抛出。

    当 NoneBot 捕获到它时,会停止运行当前 handler 并结束当前 matcher 的运行。

  4. StopPropagation

    这个异常一般会在执行 运行后处理 hook 后抛出。

    当 NoneBot 捕获到它时, 会停止传播当前 Event ,不再寻找下一优先级的 Matcher ,直接执行 事件后处理 hook

调用 API

NoneBot 可以通过 bot 来调用 APIAPI 可以向协议端发送数据,也可以向协议端请求更多的数据。

NoneBot 调用 API 会有如下过程:

  1. 调用 calling_api_hook 预处理钩子。

  2. adapter 将信息处理为原始数据,并转交 driverdriver 交给协议端处理。

  3. driver 接收协议端的结果,交给adapter 处理之后将结果反馈给 NoneBot 。

  4. 调用 called_api_hook 后处理钩子。

在调用 API 时同样规定了特殊的异常,叫做 MockApiException 。该异常会由预处理钩子和后处理钩子触发当预处理钩子触发时NoneBot 会跳过之后的调用过程,直接执行后处理钩子。

:::tip 不同 adapter 规定了不同的 API对应的 API 列表请参照协议规范。 :::

一般来说,我们可以用 bot.* 来调用 API*是 APIaction 或者 endpoint)。

对于发送消息而言,一方面可以调用既有的 API ;另一方面 NoneBot 实现了两个便捷方法,bot.send(event, message, **kwargs) 方法和可以在 handler 中使用的 Matcher.send(message, **kwargs) 方法,来向事件主体发送消息。