• go-cqhttp系列教程-gocqhttp数据处理端-2


    简介

    其实这里接收数据进行处理没什么技术含量,但是有很多人不会

    这里我使用Python的flask进行数据流推送的监听

    这是go-cqhttp的http推送的工作原理(比较简略)
    在这里插入图片描述

    数据处理端的搭建

    我这里使用Python的flask组件来进行端口的监听,并使用requests组件将处理好的数据推送到go-cqhttp客户端,有go-cqhttp客户端进行消息的发送操作
    话不多说直接上代码

    环境的搭建

    我们使用Python这个语言肯定要装python的(默认你已经装好了版本>3.x)
    这里是示例代码使用到的库 flask requests

    pip install  flask requests
    
    • 1

    直接上示例代码,看不懂,后面有逐行解析

    功能:将私聊发送的消息,机器人在重复发送一遍

    from flask import Flask, request
    import requests
    app = Flask(__name__)
    
    @app.route('/', methods=["POST"])
    def post_data():
        if request.get_json().get('message_type') == 'private':          # 如果是私聊信息
            QQ_name = request.get_json().get('sender').get('nickname')        # 发送者昵称
            QQ_id = request.get_json().get('sender').get('user_id')           # 发送者账号
            Xingxi_text = request.get_json().get('raw_message')               # 信息内容
            Xingxi_id = request.get_json().get('message_id')                  # 信息ID
            requests.get("http://127.0.0.1:5700/send_private_msg?user_id=%s&message=%s" % (QQ_id,Xingxi_text) )
    
        return 'OK'
    
    
    if __name__ == '__main__':
        app.run(debug=True, host='127.0.0.1', port=5701)  # 此处的 host和 port对应上面 yml文件的设置
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18

    内容解析

    代码启动

    if __name__ == '__main__':
        app.run(debug=True, host='127.0.0.1', port=5701)
    
    • 1
    • 2

    启动flask,使用debug模式(关还是开凭个人意愿),监听的地址为本机(127.0.0.1)的5701端口(要与go-cqhttp客户端推送的端口一直,不然接收不到推送的json数据)

    数据的获取

    if request.get_json().get('message_type') == 'private':          # 如果是私聊信息
        QQ_name = request.get_json().get('sender').get('nickname')        # 发送者昵称
        QQ_id = request.get_json().get('sender').get('user_id')           # 发送者账号
        Xingxi_text = request.get_json().get('raw_message')               # 信息内容
        Xingxi_id = request.get_json().get('message_id')                  # 信息ID
    
    • 1
    • 2
    • 3
    • 4
    • 5

    request.get_json().get(‘message_type’) == ‘private’:是获取消息的类型(事件类型)

    群聊group
    私聊private
    频道guild

    将处理好的数进行发送

    requests.get("http://127.0.0.1:5700/send_private_msg?user_id=%s&message=%s" % (QQ_id,Xingxi_text) 
    
    • 1

    将数据发送是使用的访问go-cqhttp客户端的5700端口来实现的,访问的格式要符合他的标准

    # 私聊
    "http://客户端地址:5700/send_private_msg?user_id=接收者QQ&message=发送得消息"
    # 群聊
    "http://客户端地址:5700/send_group_msg?group_id=群号&message=发送得消息"
    # 频道
    "http://客户端地址:5700/send_guild_channel_msg?guild_id=主频道编号&channel_id=子频道编号&message=发送得消息"
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6

    下面的是我的星辰机器人的展示群聊,感兴趣的可以加入看看
    QQ演示群聊加群链接

  • 相关阅读:
    Lego-Laom算法深度解析
    【初学者入门C语言】之运算符及表达式(二)
    Leetcode20.有效的括号
    react笔记
    方圆的秒杀系统优化方案实战,(六)分布式缓存
    Java中PDF文件传输有哪些方法?
    PySpark 小白教程 (二) PySpark SQL 简介
    使用MVS-GaN HEMT紧凑模型促进基于GaN的射频和高电压电路设计
    【ES常用查询】基于ElasticsearchRestTemplate及NativeSearchQuery的查询
    async/await 原理及执行顺序分析
  • 原文地址:https://blog.csdn.net/weixin_47768822/article/details/126366161