go-cqhttp+SpringBoot3实现QQ机器人

矫情吗；* 2024-03-24 16:44 73阅读 0赞

## 本QQ机器人实现的功能 ##

1.调用青云客的API进行自动聊天

2.输入关键词自动添加为好友

## 技术栈 ##

非特殊情况保持一致即可！

1.SpringBoot-3.0.5

2.JDK-17

3.go-cqhttp1.0

Github：[GitHub - Mrs4s/go-cqhttp: cqhttp的golang实现，轻量、原生跨平台.][GitHub - Mrs4s_go-cqhttp_ cqhttp_golang_.]

gocq api文档地址：https://docs.go-cqhttp.org/api/

## 源码 ##

[https://gitee.com/mumangguo/go-cqhttp][https_gitee.com_mumangguo_go-cqhttp]

## 实现步骤： ##

### 1. 新建一个springBoot项目，不选任何依赖直接创建即可 ###

![93df3ecb0b4c48949de84fd35a7ef387.png][]

![d04dbfb42c2c4bd0b8cbb4b9b6a0e4b4.png][]

### 2. 引入相关依赖 ###

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-websocket</artifactId>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>2.0.21</version>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.apache.httpcomponents</groupId>
                <artifactId>httpclient</artifactId>
                <version>4.5.13</version>
            </dependency>

### 3.编写相关实体类，处理json ###

Friend类

import lombok.Data;
    
    @Data
    public class Friend {
    
        private String user_id;
        private String comment;
        private String flag;
    }

Message类

import com.alibaba.fastjson.annotation.JSONField;
    import lombok.Data;
    
    import java.io.Serializable;
    
    @Data
    public class Message implements Serializable {
    
        @JSONField(name = "post_type")
        private String postType;
        @JSONField(name = "meta_event_type")
        private String metaEventType;
        @JSONField(name = "message_type")
        private String messageType;
        @JSONField(name = "notice_type")
        private String noticeType;
        // 操作人id 比如群管理员a踢了一个人,那么该值为a的qq号
        @JSONField(name = "operator_id")
        private String operatorId;
        private Long time;
        @JSONField(name = "self_id")
        private String selfId;
        @JSONField(name = "sub_type")
        private String subType;
        @JSONField(name = "user_id")
        private String userId;
        @JSONField(name = "sender_id")
        private String senderId;
        @JSONField(name = "group_id")
        private String groupId;
        @JSONField(name = "target_id")
        private String targetId;
        private String message;
        @JSONField(name = "raw_message")
        private String rawMessage;
        private Integer font;
        //private Sender sender;
        @JSONField(name = "message_id")
        private String messageId;
        @JSONField(name = "message_seq")
        private Integer messageSeq;
        private String anonymous;
    }

Request类

import lombok.Data;
    
    @Data
    public class Request<T> {
    
        private String action;
        private T params;
        private String echo;
    }

### 4.编写消息监听类(Websocket实现) ###

/**
     * 消息监听
     */
    @ClientEndpoint
    public class Client {
        private static final Logger logger = LoggerFactory.getLogger(Client.class);
        private Session session;
        public static Client instance;
        public static boolean isOpen = false;
    
        private Client(String url) {
            try {
                session = ContainerProvider.getWebSocketContainer().connectToServer(this, URI.create(url));
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    
        public synchronized static boolean connect(String url) {
            instance = new Client(url);
            return true;
        }
    
        @OnOpen
        public void onOpen(Session session) {
            isOpen = true;
            logger.info("连接成功！");
        }
    
        @OnClose
        public void onClose(Session session) {
            isOpen = false;
            logger.info("连接关闭！");
        }
    
        @OnError
        public void onError(Session session, Throwable throwable) {
            logger.info("连接错误！");
        }
    
        @OnMessage
        public void onMessage(String message) {
            if (message.contains("\"request_type\":\"friend\"")) {
                sendFriend(message);
            }
            if (message.contains("\"post_type\":\"message\"") && message.contains("\"message_type\":\"private\"")) {
                sendMsg(message);
            }
        }
    
        /**
         * 好友请求
         */
        private synchronized void sendFriend(String msg) {
            Friend parseObject = JSONObject.parseObject(msg, Friend.class);
            logger.info("收到好友请求：" + parseObject.getUser_id() + ",验证消息：" + parseObject.getComment());
            Request<Object> paramsRequest = new Request<>();
            paramsRequest.setAction("set_friend_add_request");
            Map<String, Object> params = new HashMap<>();
            params.put("flag", parseObject.getFlag());
            if (parseObject.getComment().equals("木芒果")) {
                params.put("approve", true);
                logger.info("已同意好友请求：" + parseObject.getUser_id());
            } else {
                params.put("approve", false);
                logger.info("已拒绝好友请求：" + parseObject.getUser_id());
            }
            paramsRequest.setParams(params);
            instance.session.getAsyncRemote().sendText(JSONObject.toJSONString(paramsRequest));
        }
    
        /**
         * 好友消息
         */
        public synchronized static void sendMsg(String msg) {
            Message parseObject = JSONObject.parseObject(msg, Message.class);
            String message = parseObject.getMessage();
            //message = message.replaceAll(" ", ",");
            logger.info("收到好友" + parseObject.getUserId() + "的消息：" + message);
            Request<Object> paramsRequest = new Request<>();
            paramsRequest.setAction("send_private_msg");
            Map<String, Object> params = new HashMap<>();
            params.put("user_id", parseObject.getUserId());
            String ai = AiOne(message);
            if (ai == null) {
              ai = "宝，回复失败!重新试试把!";
            }
            params.put("message",ai);
            paramsRequest.setParams(params);
            msg = JSONObject.toJSONString(paramsRequest);
            System.out.println("msg="+msg);
            instance.session.getAsyncRemote().sendText(msg);
        }
    
        public static String AiOne(String sendMsg) {
            try {
                HttpGet httpGet = new HttpGet("http://api.qingyunke.com/api.php?key=free&appid=0&msg=" + sendMsg);
                String user_agent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/108.0.0.0 Safari/537.36 Edg/108.0.1462.42";
                httpGet.addHeader("user-agent", user_agent);
                CloseableHttpClient httpClient = HttpClients.createDefault();
                CloseableHttpResponse response = httpClient.execute(httpGet);
                String body = EntityUtils.toString(response.getEntity(), StandardCharsets.UTF_8);
                body = body.substring(body.indexOf("content") + 10, body.length() - 2);
                logger.info("AiOne={}", body);
                return body;
            } catch (Exception e) {
                logger.error(e.toString());
                return null;
            }
        }
    }

### 5.代码部分完成，下载go-cqhttp ###

下载链接：[Releases · Mrs4s/go-cqhttp · GitHub][Releases _ Mrs4s_go-cqhttp _ GitHub]，根据自身实际情况下载对应的操作系统版本，当然我的源码中包含了Linux版本和Windows版本

![a052cc691bc148a498b8b466bb1905e1.png][]

### 6.这边只演示windows操作系统如何启动，Linux启动可以看api文档 ###

官方推荐使用cmd的方式启动，我们就在文件目录上输入cmd启动即可

![80262ee033f541eeac968916e1d065e9.png][]

![1ec4226b677d4b4798573586a73587ea.png][]

可以看到他在当前文件夹下生成了一个config.yml文件，我们打开看看，只要修改我箭头标注位置即可

![d1d7a146b982450b9ed3379c2dcbed36.png][]

![640c1501d5dc4b639b253a34cb4fa6f6.png][]

修改完后，重新启动该程序，完成qq的登录验证，正常完成验证的情况下，就会出现登录成功！

![5bed41fc0c5c45038f91624254f245ec.png][]

登录出现45/235错误代表着当前QQ号处于腾讯的风控，就需要修改协议（不用配置密码，把密码保持为空即可）采用扫码的方式进行登录！

![78f781c81ce7436083a5c1311804e51d.png][]

一、修改config.yml，把密码置为空表示扫码登录

![266b078b4ea24eebbfafaa96a88105cf.png][]

二、修改刚刚生成的device.json

![fced7e67b3574b66bef10169229c4b00.png][]

三、把这个protocol修改为2或者0，保存后再继续启动，出现扫码登录即可

![93d26f09149c4f13b64a8da5c3d9be7e.png][]

### 7.编写启动类，启动项目即可，就可以实现自动所有功能了，需要特别注意的是要先启动go-cqhttp才能启动项目！ ###

import com.mmg.gocqhttp.websocket.Client;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.boot.CommandLineRunner;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    import java.util.Timer;
    import java.util.TimerTask;
    
    /**
     * https://docs.go-cqhttp.org/guide/quick_start.html
     */
    @SpringBootApplication
    public class GoCqhttpApplication implements CommandLineRunner {
        private static final Logger logger = LoggerFactory.getLogger(GoCqhttpApplication.class);
    
        public static void main(String[] args) {
            SpringApplication.run(GoCqhttpApplication.class, args);
        }
    
        @Override
        public void run(String... args) {
            Client.connect("ws://127.0.0.1:9090");
            // 断线重连
            Timer t = new Timer();
            t.scheduleAtFixedRate(new TimerTask() {
                @Override
                public void run() {
                    if (!Client.isOpen || Client.instance == null) {
                        Client.connect("ws://127.0.0.1:9090");
                        logger.error("正在断线重连！");
                    }
                }
            }, 1000, 5000);
        }
    }

[GitHub - Mrs4s_go-cqhttp_ cqhttp_golang_.]: https://github.com/Mrs4s/go-cqhttp
[https_gitee.com_mumangguo_go-cqhttp]: https://gitee.com/mumangguo/go-cqhttp
[93df3ecb0b4c48949de84fd35a7ef387.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/a8158491adce4837a52c91af40bdfa13.png
[d04dbfb42c2c4bd0b8cbb4b9b6a0e4b4.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/72a8e82cd2cb4ac5a99b28bb5dbffd7f.png
[Releases _ Mrs4s_go-cqhttp _ GitHub]: https://github.com/Mrs4s/go-cqhttp/releases
[a052cc691bc148a498b8b466bb1905e1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/cb41e9bb64cc48a480f4bccc766ade33.png
[80262ee033f541eeac968916e1d065e9.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/6cc2c3c55e9c4e439ee1e3fd2d598a38.png
[1ec4226b677d4b4798573586a73587ea.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/3df593f621384246ab8ffb5c95ae83f0.png
[d1d7a146b982450b9ed3379c2dcbed36.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/3c30bf8519c5418292838093b76f62cb.png
[640c1501d5dc4b639b253a34cb4fa6f6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/4e37d6275ff34ee38b9a8eec78400eef.png
[5bed41fc0c5c45038f91624254f245ec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/b968d47a51a44638b3b78f20ec21d6f3.png
[78f781c81ce7436083a5c1311804e51d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/5038d874302e4334af381f49e8cd3482.png
[266b078b4ea24eebbfafaa96a88105cf.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/5d3b570c15894d24b0f165104e349a4b.png
[fced7e67b3574b66bef10169229c4b00.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/41031f22247e49f991ab400c3136d331.png
[93d26f09149c4f13b64a8da5c3d9be7e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/eba8b542d7ed4f9297a73384d1b74002.png