SpringBoot搭建go-cqhttp机器人的方法实现
更新时间：2021年12月23日 09:24:05 作者：OY..
本文主要介绍了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/
到此这篇关于SpringBoot搭建go-cqhttp机器人的方法实现的文章就介绍到这了,更多相关SpringBoot搭建go-cqhttp机器人内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Java接口继承和使用接口操作,结合具体实例形式分析了Java接口继承与使用的相关原理、操作技巧与注意事项,需要的朋友可以参考下2019-09-09
在Java学习过程中，在写类经常为用到public，private和protected，我个人的经验是一般类的成员变量都是用private，方法用public，类的内部用protected方法，如果是存在子类的，那我就会把父类中的成员变量变为protected。（其余的看具体实际情 况而定）2015-08-08
Netty提供了一套完整的API,用于处理网络IO操作,如TCP和UDP套接字,本文主要介绍了SpringBoot整合Netty服务端的实现示例,具有一定的参考价值,感兴趣的可以了解一下2024-07-07
这篇文章主要介绍了Java 常量池详解之字符串常量池,本文结合示例代码对java字符串常量池相关知识讲解的非常详细，需要的朋友可以参考下2022-12-12
本文介绍了Java使用线程池执行定时任务，其中ScheduledThreadPool和SingleThreadScheduledExecutor都是可以执行定时任务的，但是具体怎么执行，下面我们一起进入文章了解具体详情吧2022-05-05
本文主要介绍了java中的connection reset 异常处理分析的相关资料，具有很好的参考价值。下面跟着小编一起来看下吧2017-04-04
在日常的开发中避免不了操作Excel,下面这篇文章主要给大家介绍了关于springboot实现excel表格导出的几种常见方法,文中通过代码介绍的非常详细,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了Java使用正则表达式去除小数点后面多余的0功能,结合具体实例形式分析了java字符串正则替换相关操作技巧,需要的朋友可以参考下2017-06-06
这篇文章主要介绍了如何使用Sentry 监控你的Spring Boot应用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-11-11
今天小编就为大家分享一篇关于Java面向对象选择题总结归纳，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-01-01
最新评论