使用python实现qqbot(三)

假设是你已经能开发一个django项目。如果对django不太懂,可以去看看教程。

虽然flask比django更方便开发应用,插件开发者也推出了简单的flask插件,但是本人对 django接触更多,更倾向使用django开发。

对我而言,djangoorm和基于此存在的管理后台十分方便,所以更倾向django开发。

有了之前的基础(获取消息,发送消息),其实完全可以独立开发自己的django应用了,下面是我的一些思路。可能不够好,但是希望能给你启发。

废话(关于django)

功能代码写在哪里

既然是bot,功能很难避免各种数据处理。

对于普通网站,我们采用的往往是 客户端发送请求→服务器进行查询→服务器进行返回。

如果需要登录等交互,可以通过``sessioncookie`完成

实际上的逻辑很简单,使用 url,viewmodel基本可以解决所有问题。

但是对于bot,插件没有提供session,一个最简单的问题是:假设一个功能需要分布完成,基于用户的选择答复,我该如何保存状态?

具体实现方法先不细究,首先考虑一个问题:django的类在哪可以保持,而不会随着请求结束返回释放掉?

解决方法是:

定义在各个view.py中的代码会得到执行,如果我们在那定义一个实例,那么那个实例会被定义为全局对象,从而可以在各大view函数中使用.

所以可以在 app中写一个 extensions.py我们的功能代码写在这里.我们在 view.py中全局实例化一个监听对象(比如qq_listener),这样随着传递过来的请求,我们可以在功能函数中向监听对象发送信息.

bot功能思路

不妨先看看人家的bot。在我见到的一些bot(qq,telegram等等)里,bot能提供签到,文件处理(图片),群管理(禁言,欢迎等等)。

稍微总结下,bot可以大致分类为:

  1. 是否需要互动

  2. 对象

是否需要互动

互动指的是是否需要对用户消息做出反应。

需要互动的有 :

  • 根据对话关键词禁言(需要监听关键词)

  • 对话bot

  • 查询bot(比如对bot发送ping指令能返回ping结果)

  • ...

不需要互动的有:

  • 早晚安

  • 消息订阅(比如github的webhook)

  • ...

这是两个区别很大的类:一个需要互动,难度在如何与用户交互;一个需要根据条件触发,难度在于如何获取消息并得到触发条件。

对象

对象很容易理解,分别是用户与群组,其中群组中是包含用户的。开发的时候主要考虑的是逻辑结构。

一个简单的思路

定义一个基类,分别写好向群组与用户发送消息的方法,所有类继承他,就能得到向qq发送消息能力,同时定义字段ext_name作为扩展的标识.

需要互动的功能需要一个方法(on_msg)来监听传过来的方法,需要订阅的功能需要方法发送推送,分别写好接口:

class QQExtension:
    ext_name = list()

    send_url = COOLQ_BASE_URL  # 发送url
    timeout = MSG_TIMEOUT  # 超时时限

    try_times = 0  # 遇到错误,已经尝试次数
    max_try_times = MAX_TRY_TIMES  # 最大尝试次数

    def send_private_msg(self, msg, qq_num, auto_escape=False):
        """
        发送 qq 消息给个人,超时尝试 max_try_times 次,失败返回错误信息
        :param auto_escape: 是否作为纯文本发送,只在 msg 为字符串时有效
        :param qq_num: qq号
        :param msg: 消息内容
        :return: 第一个参数检测是否成功,第二个参数返回成功 rsp 对象或者 error 对象
        """
        params = {
            'user_id': qq_num,
            'message': msg,
            'auto_escape': auto_escape
        }
        try:
            rsp = requests.post(COOLQ_BASE_URL + '/send_private_msg', params=params, timeout=self.timeout)
            return True, rsp
        except requests.exceptions.RequestException as e:
            self.try_times += 1
            if self.try_times < self.max_try_times:
                return False, e

    def send_group_msg(self, msg, qq_num, auto_escape=False):
        """
        发送 qq 消息给群组,超时尝试 max_try_times 次,失败返回错误信息
        :param auto_escape: 是否作为纯文本发送,只在 msg 为字符串时有效
        :param qq_num: qq号
        :param msg: 消息内容
        :return: 第一个参数检测是否成功,第二个参数返回成功 rsp 对象或者 error 对象
        """
        params = {
            'group_id': qq_num,
            'message': msg,
            'auto_escape': auto_escape
        }
        try:
            rsp = requests.post(COOLQ_BASE_URL + '/send_group_msg', params=params, timeout=self.timeout)
            return True, rsp
        except requests.exceptions.RequestException as e:
            self.try_times += 1
            if self.try_times < self.max_try_times:
                return False, e

    
# 订阅的抽象类,订阅的特点是定时推送,没有互动操作,不需要监听消息
class QQSubscribe(QQExtension):
    ext_name = ['订阅']

    def send_to_private(self, send_items):
        pass

    def send_to_group(self, send_items):
        pass


# 聊天的抽象类,聊天的特点是互动,需要监听消息
class QQChat(QQExtension):
    ext_name = ['聊天']

    def on_msg(self, msg):
        pass

对于需要互动的功能,继承自QQchat:

class QQChatExample1(QQChat):
     # 复写下面方法
     def on_msg(self, msg):
         pass

然后需要一个对象来实现消息监听转发:

class QQListener:
    def on_message(self):
        pass

思路是: 在view.py里面实例化QQListener对象,通过on_message方法向所有扩展的on_msg方法传递数据,然后每个扩展处理信息.

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。