假设是你已经能开发一个
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
方法传递数据,然后每个扩展处理信息.