直播爬虫

本项目同一时间仅支持监听一个直播间， 目前仅支持 Bilibili 直播间的使用。 当然，后续可能会实现同时监听多个直播间， 目前因为技术原因只选择该直播间进行实现。

在该部分中，我们通过 Crawler 对象类进行封装， 它主要接受一个回调函数 receive_callback， 当爬虫接收到了直播间传输过来的消息之后，它会进行处理和封装， 然后通过回调函数将消息 Message 传输到内核中。 其中回调函数的定义如下。

# 回调函数暂时只接受字符串
def receive_callback(text: str):
    ...

Vritual

为了方便调试，本系统提供一个虚拟的爬虫接口。 该接口的运行逻辑是循环从本地存储的消息队列中读取消息信息， 然后通过回调函数将消息记录中的信息添加到 Message Queue 中。

Bilibili

目前该直播平台提供两种监听的方式：官方的开放平台与第三方。 前者需要通过开放平台申请 key， 然后使用提供的 API 进行调用。 后者则是使用 Github 的开源项目 blivedm 对直播弹幕进行爬取。

由于开放平台的 key 没有申请下来，目前仅支持第三方的爬虫。