go-cqhttp智能聊天功能的实现
作者:A-L-Kun 发布时间:2024-04-26 17:30:53
标签:go,cqhttp,智能聊天
智能聊天
一、 概述
我们将我们的qq聊天机器人的环境配置好后,其就可以开始接收消息啦!那么,我们除了可以接收特定的消息,是不是还需要接收那些不是我们指定的消息呢?我想是的!那么,我们要如何接入呢?
这里,我找了一个比较好用的聊天机器人的API接口。可以将其接入我们的程序中,做一个陪聊小助手。当然,如果你机器学习学的比较好的话,你也可以自己训练一个模型来实现智能聊天的接口。
我们选择的是青云客智能聊天
二、 使用方法
同时,其还有一些拓展的功能!
三、 接入程序
我们暂时只对私信消息进行处理,接入我们的智能聊天接口
在private_script.py
文件中,添加一个函数,同时修改处理私聊消息的接口:
#!/usr/bin/python3
# -*- coding: UTF-8 -*-
__author__ = "A.L.Kun"
__file__ = "private_script.py.py"
__time__ = "2022/9/9 22:04"
import httpx
from datetime import datetime
async def handle_private(uid, message): # 处理私聊信息
if message: # 简单的判断,只是判断其是否为空
_ = await get_resp(message)
ret = _.get("content", "获取回复失败")
await send(uid, f"{ret}\n发送时间:{datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
async def get_resp(message): # 对接口发送请求,获取响应数据
async with httpx.AsyncClient() as client:
params = {
"key": "free",
"appid": 0,
"msg": message,
}
resp = await client.get("http://api.qingyunke.com/api.php", params=params)
return resp.json()
async def send(uid, message):
"""
用于发送消息的函数
:param uid: 用户id
:param message: 发送的消息
:return: None
"""
async with httpx.AsyncClient(base_url="http://127.0.0.1:5700") as client:
# 如果发送的为私聊消息
params = {
"user_id": uid,
"message": message,
}
await client.get("/send_private_msg", params=params)
这个文件负责发送私聊信息
四、 智能群聊
我们这里开发一个智能水群的功能,其可以自动的根据群消息回复,同时增加了进群欢迎的功能!
实现群聊艾特回复功能
实现戳一戳回复功能
实现新入群成员欢迎功能
在我们的main.py
中,添加接口
#!/usr/bin/python3
# -*- coding: UTF-8 -*-
__author__ = "A.L.Kun"
__file__ = "main.py"
__time__ = "2022/9/9 22:03"
from flask import Flask, request
from flask_restful import Resource, Api
import private_script, group_script
import asyncio
app = Flask(__name__)
api = Api(app)
class AcceptMes(Resource):
def post(self):
# 这里对消息进行分发,暂时先设置一个简单的分发
_ = request.json
if _.get("message_type") == "private": # 说明有好友发送信息过来
uid = _["sender"]["user_id"] # 获取发信息的好友qq号
message = _["raw_message"] # 获取发送过来的消息
asyncio.run(private_script.handle_private(uid, message))
elif _.get("message_type") == "group" and "[CQ:at,qq=2786631176]" in _["raw_message"]: # 制作群聊消息
message = _["raw_message"].replace("[CQ:at,qq=2786631176]", "") # 获取发送过来的消息
gid = _["group_id"] # 获取发送消息的群号
asyncio.run(group_script.handle_group(gid, message))、
elif _.get("notice_type") == "group_increase": # 有新成员加入
uid = _["user_id"] # 获取加入者的qq
gid = _["group_id"] # 获取群号
asyncio.run(group_script.group_increase(uid, gid)) # 发送欢迎语
elif _.get("sub_type") == "poke": # 如果事件类型为戳一戳
uid = _["user_id"]
tid = _["target_id"]
if str(tid) != "3500515050" and str(tid) != "2786631176": # 判断是否戳的是自己的账号
return
try:
gid = _["group_id"]
except KeyError as e:
gid = None
asyncio.run(group_script.click_event(uid, gid)) # 传入群号和qq号
api.add_resource(AcceptMes, "/", endpoint="index")
if __name__ == '__main__':
app.run("0.0.0.0", 5701, debug=True) # 注意,这里的端口要和配置文件中的保持一致
创建一个文件group_script.py
,用于处理群聊消息
#!/usr/bin/python3
# -*- coding: UTF-8 -*-
__author__ = "A.L.Kun"
__file__ = "group_script.py"
__time__ = "2022/9/10 11:49"
import httpx
import private_script
import config
from random import choice
async def handle_group(gid, message): # 处理群聊信息
if str(gid) in config.allow_group_id: # 简单的判断,只是判断其是否为空
if message.strip() == "":
await send(gid, "艾特 * 啥?又不发消息,一巴掌呼死你![CQ:face,id=86][CQ:face,id=12]")
else:
_ = await private_script.get_resp(message)
ret = _.get("content", "获取回复失败")
await send(gid, ret)
async def group_increase(uid, gid): # 处理有新成员加入的情况
if str(gid) in config.allow_group_id:
msg = config.welcome_group.get(str(gid), config.welcome_group["default"]) % uid # welcome_group的键是qq群号,值是欢迎语
await send(gid, msg) # 发送信息
async def click_event(uid, gid):
info = choice(config.click_info) # 获取戳一戳的信息
try:
info = info % uid
except TypeError:
if gid: # 说明其为群戳戳
info = f"[CQ:at,qq={uid}]" + info
if gid:
await send(gid, info)
else:
await private_script.send(uid, info)
async def send(gid, message):
"""
用于发送消息的函数
:param gid: 群号
:param message: 发送的消息
:return: None
"""
async with httpx.AsyncClient(base_url="http://127.0.0.1:5700") as client:
# 如果发送的为私聊消息
params = {
"group_id": gid,
"message": message.replace("{br}", "\n").replace("菲菲", "坤坤"),
}
await client.get("/send_group_msg", params=params)
设置配置文件config.py
:
#!/usr/bin/python3
# -*- coding: UTF-8 -*-
__author__ = "A.L.Kun"
__file__ = "config.py"
__time__ = "2022/9/10 11:57"
allow_group_id = [
]
welcome_group = { # 新成员进入回复信息
"default": f"[CQ:at,qq=%d] 欢迎加入本群,来了就别想走哦![CQ:face,id={43}]",
}
click_info = [ # 戳一戳的回复信息
"?有事吗?没事我走了![CQ:face,id=125],goodbye",
"没问题么?〒没问题的话,我就溜了哦!",
"睡觉去,困死了!",
"戳 * 啥!本人在叙利亚做兼职呢?没事别烦我!",
"你好呀!我在躺平呢!请问有啥事呀?",
"hello",
"[CQ:poke,qq=%d]",
]
最后,我们开发的智能聊天就可以使用了!
来源:https://blog.csdn.net/qq_62789540/article/details/126796017


猜你喜欢
- 这篇文章主要介绍了一种简单的MySQL数据库安装方法,详细内容请大家参考下文:虽然安装MySQL数据库的文章很多,但是我看后感觉对于初学者来
- 本章内容,我们主要来讲一下Python内置的HTML解析库HTMLParser模块,基本上也是应用于页面抓取上,假设,我们需要去收集页面上已
- 引言反射是通过实体对象获取反射对象(Value、Type),然后可以操作相应的方法。在某些情况下,我们可能并不知道变量的具体类型,这时候就可
- 1、mysql下载下载地址:https://dev.mysql.com/downloads/mysql/5.6.html<br>
- 用的pytorch来训练deeplabv3+在做deeplabv3+的过程中,我的训练图片是8位的,如下图:8位的:24位的:这样虽然在训练
- 今天出于需要,要将爬虫爬取的一些数据整理成二维数组,再编码成json字符串传入数据库那么问题就来了,在php中这个过程很简便 ,类似这样:
- Git/GitHub/GitHub Desktop相关概念1、GitGit是一款免费的、开源的、最先进的分布式版本控制系统,可以有效、高速地
- 何为聚类分析聚类分析或聚类是对一组对象进行分组的任务,使得同一组(称为聚类)中的对象(在某种意义上)与其他组(聚类)中的对象更相似(在某种意
- 暂时性死区只要块级作用域存在let命令,它所声明的变量就“绑定”这个区域,不再受外部的影响。这么说可能有些抽象,举个例子:var
- interface {} 可以用于模拟多态xdm 咱们写一个简单的例子,就举动物的例子写一个 Animal 的接口,类似于 jav
- 识别快递单号这次跟老师做项目,这项目大概是流水线上识别快递上的快递单号。首先我尝试了解条形码的基本知识 百度百科:条形码 条形码(barco
- Keras的.h5模型转成tensorflow的.pb格式模型,方便后期的前端部署。直接上代码from keras.models impor
- declare @i int set @i='a' &
- IFRAME 元素 | iframe 对象创建内嵌浮动框架。成员表下面的表格列出了 iframe 对象引出的成员。请单击左侧的标签来选择你想
- 图像(包括动图)是传递信息的一种高效方式,往往能增强表象、记忆与思维等方面的反应强度。所谓一图胜千言,说的就是这个道理。今天为大家整理了十张
- 本文实例为大家分享了python实现用户名密码校验的具体代码,供大家参考,具体内容如下需要实现功能输入用户名密码 ;认证成功后显示 欢迎信息
- Oracle数据库各类控制语句的使用是本文我们主要要介绍的内容,包括一些逻辑控制语句、Case when的使用、While的使用以及For的
- 第三方库 binarytree其使用环境、安装方法及二叉树的相关知识,请见:《Python 初识二叉树,新手也秒懂!》不能导入的请安装:pi
- 这篇文章主要介绍了Python遍历字典方式就实例详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友
- 1.什么是SQL注入 所谓SQL注入式攻击,就是攻击者把SQL命令插入到Web表单的输入域或页面请求的查询字符串,欺骗服务器执行恶意的SQL