假设是你已经能开发一个
django项目。如果对django不太懂,可以去看看教程。虽然
flask比django更方便开发应用,插件开发者也推出了简单的flask插件,但是本人对django接触更多,更倾向使用django开发。对我而言,
django的orm和基于此存在的管理后台十分方便,所以更倾向django开发。
有了之前的基础(获取消息,发送消息),其实完全可以独立开发自己的django应用了,下面是我的一些思路。可能不够好,但是希望能给你启发。
废话(关于django)
功能代码写在哪里
既然是bot,功能很难避免各种数据处理。
对于普通网站,我们采用的往往是 客户端发送请求→服务器进行查询→服务器进行返回。
如果需要登录等交互,可以通过``session
与cookie`完成实际上的逻辑很简单,使用
url,view,model基本可以解决所有问题。
但是对于bot,插件没有提供session,一个最简单的问题是:假设一个功能需要分布完成,基于用户的选择答复,我该如何保存状态?
具体实现方法先不细究,首先考虑一个问题:django的类在哪可以保持,而不会随着请求结束返回释放掉?
解决方法是:
定义在各个view.py中的代码会得到执行,如果我们在那定义一个实例,那么那个实例会被定义为全局对象,从而可以在各大view函数中使用.
所以可以在 app中写一个 extensions.py我们的功能代码写在这里.我们在 view.py中全局实例化一个监听对象(比如qq_listener),这样随着传递过来的请求,我们可以在功能函数中向监听对象发送信息.
bot功能思路
不妨先看看人家的bot。在我见到的一些bot(qq,telegram等等)里,bot能提供签到,文件处理(图片),群管理(禁言,欢迎等等)。
稍微总结下,bot可以大致分类为:
- 是否需要互动 
- 对象 
是否需要互动
互动指的是是否需要对用户消息做出反应。
需要互动的有 :
- 根据对话关键词禁言(需要监听关键词) 
- 对话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方法传递数据,然后每个扩展处理信息.