SpringBoot搭建go-cqhttp机器人的方法实现
作者：OY.. 发布时间：2022-11-17 23:58:40
标签：SpringBoot,go-cqhttp,机器人
百度一下搭建go-cqhttp，千篇一律都是采用python搭建的，Java搭建根本没有。导致自己在搭建的时候可折磨了，出现了许多的问题。唯一能参考就只有官方文档。文档对小白也不是太友好，所以出这篇博客弥补一下Java 的搭建版本。
搭建环境： winndows 系统 + Java + Idea 2020.2
注意：本博客写的比较简单，存在很多不完善的地方，如需符合自己需求请参考官方文档
参考文档：
官方文档
一、搭建go-cqhttp机器人
请 参考go-cqhttp 视频：https://www.bilibili.com/video/av247603841/
测试
给自己好友发送一条私聊消息(user_id:好友的QQ号)
# cmd
crul '127.0.0.1:5700/send_private_msg?user_id=xxxxxx&message=你好~'
#postMan
GET http://127.0.0.1:5700/send_private_msg?user_id=xxxxx&message=你好~
响应：
二、搭建SpringBoot环境
基本环境
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.46</version>
</dependency>
<!--httpUtils-->
<dependency>
<groupId>commons-httpclient</groupId>
<artifactId>commons-httpclient</artifactId>
<version>3.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.4.1</version>
</dependency>
<!--websocket作为客户端-->
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.3.5</version>
</dependency>
</dependencies>
1、HTTP通信
修改go-cqhhtp 配置文件 config.yml
post:
# 这里一定要填成这样的http://{host}:{ip}
- url: 'http://127.0.0.1:8400'
secret: ''
Java 代码
测试案例：https://docs.go-cqhttp.org/api/#％E5％8F％91％E9％80％81％E7％A7％81％E8％81％8A％E6％B6％88％E6％81％AF 发送私聊消息
QqRobotController.java
@RestController
@Slf4j
public class QqRobotController {
@Resource
private QqRobotService robotService;
@PostMapping
public void QqRobotEven(HttpServletRequest request){
robotService.QqRobotEvenHandle(request);
}
}
QqRobotService.java
public interface QqRobotService {
void QqRobotEvenHandle(HttpServletRequest request);
}
QqRobotServiceImpl.java
@Service
@Slf4j
public class QqRobotServiceImpl implements QqRobotService {
@Override
public void QqRobotEvenHandle(HttpServletRequest request) {
//JSONObject
JSONObject jsonParam = this.getJSONParam(request);
log.info("接收参数为:{}",jsonParam.toString() !=null ? "SUCCESS" : "FALSE");
if("message".equals(jsonParam.getString("post_type"))){
String message = jsonParam.getString("message");
if("你好".equals(message)){
// user_id 为QQ好友QQ号
String url = "http://127.0.0.1:5700/send_private_msg?user_id=xxxxx&message=你好~";
String result = HttpRequestUtil.doGet(url);
log.info("发送成功:==>{}",result);
}
}
}
public JSONObject getJSONParam(HttpServletRequest request){
JSONObject jsonParam = null;
try {
// 获取输入流
BufferedReader streamReader = new BufferedReader(new InputStreamReader(request.getInputStream(), "UTF-8"));
// 数据写入Stringbuilder
StringBuilder sb = new StringBuilder();
String line = null;
while ((line = streamReader.readLine()) != null) {
sb.append(line);
}
jsonParam = JSONObject.parseObject(sb.toString());
} catch (Exception e) {
e.printStackTrace();
}
return jsonParam;
}
}
HttpUtils 工具类
public class HttpRequestUtil {
/**
* @Description: 发送get请求
*/
public static String doGet(String url) {
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpGet httpGet = new HttpGet(url);
httpGet.setHeader("Content-type", "application/json");
httpGet.setHeader("DataEncoding", "UTF-8");
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000).setConnectionRequestTimeout(35000).setSocketTimeout(60000).build();
httpGet.setConfig(requestConfig);
CloseableHttpResponse httpResponse = null;
try {
httpResponse = httpClient.execute(httpGet);
HttpEntity entity = httpResponse.getEntity();
if(httpResponse.getStatusLine().getStatusCode() != 200){
return null;
}
return EntityUtils.toString(entity);
} catch (ClientProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
if (httpResponse != null) {
try {
httpResponse.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (null != httpClient) {
try {
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return null;
}
/**
* @Description: 发送http post请求
*/
public static String doPost(String url, String jsonStr) {
CloseableHttpClient httpClient = HttpClients.createDefault();
HttpPost httpPost = new HttpPost(url);
RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000).setConnectionRequestTimeout(35000).setSocketTimeout(60000).build();
httpPost.setConfig(requestConfig);
httpPost.setHeader("Content-type", "application/json");
httpPost.setHeader("DataEncoding", "UTF-8");
CloseableHttpResponse httpResponse = null;
try {
httpPost.setEntity(new StringEntity(jsonStr));
httpResponse = httpClient.execute(httpPost);
if(httpResponse.getStatusLine().getStatusCode() != 200){
return null;
}
HttpEntity entity = httpResponse.getEntity();
String result = EntityUtils.toString(entity);
return result;
} catch (ClientProtocolException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (httpResponse != null) {
try {
httpResponse.close();
} catch (IOException e) {
e.printStackTrace();
}
}
if (null != httpClient) {
try {
httpClient.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
return null;
}
}
响应：
发送成功:==>{"data":{"message_id":2113266863},"retcode":0,"status":"ok"}
2、WebScoket 通信
一般WebScoket的客户端都是H5, 但是为了测试本篇博客使用Java作为客户端
修改go-cqhhtp 配置文件 config.yml
- ws:
# 正向WS服务器监听地址
host: 127.0.0.1
# 正向WS服务器监听端口
port: 5701
Java 代码
需要导入pom包
WebsocketClient.java
@Slf4j
@Component
public class WebSocketConfig {
@Bean
public WebSocketClient webSocketClient() {
try {
WebSocketClient webSocketClient = new WebSocketClient(new URI("ws://127.0.0.1:5701"),new Draft_6455()) {
@Override
public void onOpen(ServerHandshake handshakedata) {
log.info("[websocket] 连接成功");
}
@Override
public void onMessage(String message) {
log.info("[websocket] 收到消息={}",message);
}
@Override
public void onClose(int code, String reason, boolean remote) {
log.info("[websocket] 退出连接");
}
@Override
public void onError(Exception ex) {
log.info("[websocket] 连接错误={}",ex.getMessage());
}
};
webSocketClient.connect();
return webSocketClient;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
}
测试（具体需求实现就根据官方API实现，参考本篇博客HTTP通信的逻辑）
[websocket] 收到消息={"interval":5000,"meta_event_type":"heartbeat","post_type":"meta_event","self_id":2878522414,"status":{"app_enabled":true,"app_good":true,"app_initialized":true,"good":true,"online":true,"plugins_good":null,"stat":{"packet_received":29,"packet_sent":21,"packet_lost":0,"message_received":0,"message_sent":0,"disconnect_times":0,"lost_times":0,"last_message_time":0}},"time":1639797397}
三、补充
具体详细需求请参考实现：https://docs.go-cqhttp.org/api/
来源：https://blog.csdn.net/qq_45738810/article/details/122075899
0
投稿猜你喜欢
综述在Retrofit2.0使用详解这篇文章中详细介绍了retrofit的用法。并且在retrofit中我们可以通过ResponseBody- 我们主要介绍一下：java中如何通过最简单的方式实现链式创建json对象，解决创建json代码臃肿的问题。1、假设我们要创建一个json对象
- 错误内容：com.alibaba.druid.pool.GetConnectionTimeoutException: wait millis
- EF的基本使用 一、EF的创建二、修改数据库一、加数据库字段二、加数据库 表 一、EF的创建第一步： 创建一个类库第二步： 选择类库第三步：
- 前言：在多线程编程中，wait 方法是让当前线程进入休眠状态，直到另一个线程调用了 notify 或 notifyAll 方法之后，才能继续
- RSA算法是一种非对称加密算法，那么何为非对称加密算法呢？一般我们理解上的加密是这样子进行的：原文经过了一把钥匙（密钥）加密后变成了密文，然
- 目录Java 基础语法中的逻辑控制一、逻辑控制语句1. 顺序结构2. 分支结构3. 循环结构二、输入输出方式1. 输出到控制台2. 从键盘输
- 本文实例为大家分享了Unity3D实现物体旋转缩放移动的具体代码，供大家参考，具体内容如下由于项目运行在安卓上，运用到了插件，比较麻烦。你们
- 测试代码如下： package swt_jface.demo; import org.eclipse.jface.window.Applic
- 首先给大家介绍一文件的上传 实体类import java.sql.Timestamp; /** * * @Decription 文件上传实体
- 目前网上流行着很多对“时间对话框TimePickerDialog”的讲解文章，但感觉都不是很详细。所以浣熊在这里详细对该方面的知识进行介绍，
- 目录@CachePut设置的key值无法与@CacheValue的值匹配缓存注解key的基本数据类型要求必须要统一Spring-Cache
- 这篇文章主要介绍了Spring @Transactional注解失效解决方案,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的
- 公司app要求做一个扭蛋功能，其实就是一个可拖动层叠卡片列表，原理还是由一个自定义Recyclerview和LayoutManager来实现
- 本篇文章主要介绍泛型的应用。泛型是.NET work 2.0 版类库就已经提供的语法，主要用于提高代码的可重用性、类型安全性和效
- 一个好的app 异常处理机制 我认为应该至少包含以下几个功能：1.能把错误信息上传到服务器 让开发者可以持续改进app2.错误信
- JAVA的 * 代理模式 代理模式是常用的java设计模式，他的特征是代理类与委托类有同样的接口，代理类主要负责为委托类预处理消息、过滤
- 本教程源码https://github.com/bestaone/HiAuth源码比较全面，教程我就只介绍关键代码了，喜欢的点个star，谢
- 关于Spring Data JPA中自定义sql 条件的 in参数记录此文做一个记录，以便以后观看，也希望正在遇到同样问题的同学能有所启发，
- 一、导入JAR包二、配置applicationContext.xml的spring核心配置三、 public static void mai
