最新要闻

广告

手机

iphone11大小尺寸是多少？苹果iPhone11和iPhone13的区别是什么？

iphone11大小尺寸是多少？苹果iPhone11和iPhone13的区别是什么？

 警方通报辅警执法直播中被撞飞：犯罪嫌疑人已投案

警方通报辅警执法直播中被撞飞：犯罪嫌疑人已投案

家电

  1. 首页
  2. 移动通信
  3. 内容

使用go-cqhttp搭建qq机器人

来源：博客园

使用go-cqhttp搭建qq机器人--python处理消息

1.环境部署

  • 本次使用windows测试部署
  • 下载地址：https://github.com/Mrs4s/go-cqhttp/releases

  • 下载后解压，会有三个文件，点击运行exe


    (相关资料图)

    • 生成bat文件，再运行

      • 运行bat，填入0，然后生成配置文件config.yml;填入qq号和密码(不过填入密码，一直登陆失败，最后还是选择扫码登陆)

        • 取消倒数三四排的代码注释，开启监听端口api，方便后续操作

          • 打开device.json文件，修改protocol的值为2，否则一直登陆失败

            • 最后再次点击bat文件运行，扫码登陆；显示如下就表示登陆成功以及cqhttp接管qq成功

            2.python代码

            • receive.py文件负责监听socket(端口要和上面配置文件中的端口一致)，接收由cqhttp传来的消息；

              import socketimport jsonListenSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)ListenSocket.bind(("127.0.0.1", 5701))ListenSocket.listen(100)HttpResponseHeader = """HTTP/1.1 200 OK\r\nContent-Type: text/html\r\n\r\n"""def request_to_json(msg):    for i in range(len(msg)):        if msg[i] == "{" and msg[-1] == "\n":            return json.loads(msg[i:])    return None# 需要循环执行，返回值为json格式def rev_msg():  # json or None    Client, Address = ListenSocket.accept()    Request = Client.recv(1024).decode(encoding="utf-8")    rev_json = request_to_json(Request)    Client.sendall((HttpResponseHeader).encode(encoding="utf-8"))    Client.close()    return rev_json

            • send_msg.py;python后端处理消息后返回的消息由该文件发出

              import socketport = 5700def send_msg(resp_dict):    client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    ip = "127.0.0.1"    client.connect((ip, port))    msg_type = resp_dict["msg_type"]  # 回复类型（群聊/私聊）    number = resp_dict["number"]  # 回复账号（群号/好友号）    msg = resp_dict["msg"]  # 要回复的消息    # 将字符中的特殊字符进行url编码    msg = msg.replace(" ", "%20")    msg = msg.replace("\n", "%0a")    if msg_type == "group":        payload = "GET /send_group_msg?group_id=" + str(            number) + "&message=" + msg + " HTTP/1.1\r\nHost:" + ip + f":{port}\r\nConnection: close\r\n\r\n"    elif msg_type == "private":        payload = "GET /send_private_msg?user_id=" + str(            number) + "&message=" + msg + " HTTP/1.1\r\nHost:" + ip + f":{port}\r\nConnection: close\r\n\r\n"    print("发送" + payload)    client.send(payload.encode("utf-8"))    client.close()    return 0

            • bot.py最关键的文件，负责写一些逻辑，像接收到什么消息返回特点的消息

              import refrom receive import rev_msgfrom send_msg import send_msgimport socketimport requestsimport randomimport urllib.request, jsonimport other_apiwhile True:    try:        rev = rev_msg()        print(rev)        if rev == None:            continue    except:        continue    if rev["post_type"] == "message":        if rev["message_type"] == "private":  # 私聊            if "在吗" in rev["raw_message"]:                qq = rev["sender"]["user_id"]  # 获取消息发出者的qq号                send_msg({"msg_type": "private", "number": qq, "msg": "我在"})  # 发送        elif rev["message_type"] == "group":  # 群聊            group = rev["group_id"]            if "在吗" in rev["raw_message"]:                qq = rev["sender"]["user_id"]                send_msg({"msg_type": "group", "number": group, "msg": "你好"})        else:            continue    else:  # rev["post_type"]=="meta_event":        continue

            • 记得将所有py文件放在同一目录，最后运行bot.py文件

              • 测试效果：

                • 一些测试代码：

                  • elif "热搜" in rev["raw_message"]:                    qq = rev["sender"]["user_id"]                    result = other_api.rs()                    result_rs = ""                    for i in range(15):                        t = str(i + 1) + ":" + result[i] + "\n"                        result_rs = result_rs + t                    send_msg({"msg_type": "group", "number": group,                              "msg": result_rs})
                    def rs():  # 微博热搜    header = {        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/112.0",        "Accept": "*/*",        "Accept-Language": "zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2",        "Accept-Encoding": "gzip, deflate",    }    url = "https://tophub.today/n/KqndgxeLl9"    res = requests.get(url, headers=header)    selector = etree.HTML(res.text)    result = []    for i in range(30):        t = selector.xpath(f"/html/body/div[1]/div[2]/div[2]/div[1]/div[2]/div/div[1]/table/tbody/tr[{i + 1}]/td[2]/a")        result.append(t[0].text)        # print(i+1, t[0].text)    return result

                    当@机器人并输入热搜时，会展示15天热搜新闻：

                • 搭建成功，后面就靠自己DIY了；

                  • 免费API：ALAPI
                  • 官方文档：https://docs.go-cqhttp.org/(有一些其他有趣的接口，可以尝试下)

                关键词：