SpringBoot搭建go-cqhttp機器人的方法實現(xiàn)
更新時間：2021年12月23日 09:24:05 作者：OY..
本文主要介紹了SpringBoot搭建go-cqhttp機器人的方法實現(xiàn)
百度一下搭建go-cqhttp，千篇一律都是采用python搭建的，Java搭建根本沒有。導致自己在搭建的時候可折磨了，出現(xiàn)了許多的問題。唯一能參考就只有官方文檔。文檔對小白也不是太友好，所以出這篇博客彌補一下Java 的搭建版本。
搭建環(huán)境： winndows 系統(tǒng) + Java + Idea 2020.2
注意：本博客寫的比較簡單，存在很多不完善的地方，如需符合自己需求請參考官方文檔
參考文檔：
一、搭建go-cqhttp機器人
請 參考go-cqhttp 視頻：https://www.bilibili.com/video/av247603841/
測試
給自己好友發(fā)送一條私聊消息(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環(huán)境
基本環(huán)境
<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 發(fā)送私聊消息
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("接收參數(shù)為:{}",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("發(fā)送成功:==>{}",result);
}
}
}
public JSONObject getJSONParam(HttpServletRequest request){
JSONObject jsonParam = null;
try {
// 獲取輸入流
BufferedReader streamReader = new BufferedReader(new InputStreamReader(request.getInputStream(), "UTF-8"));
// 數(shù)據(jù)寫入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: 發(fā)送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: 發(fā)送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;
}
}
響應：
發(fā)送成功:==>{"data":{"message_id":2113266863},"retcode":0,"status":"ok"}
2、WebScoket 通信
一般WebScoket的客戶端都是H5, 但是為了測試本篇博客使用Java作為客戶端
修改go-cqhhtp 配置文件 config.yml
- ws:
# 正向WS服務器監(jiān)聽地址
host: 127.0.0.1
# 正向WS服務器監(jiān)聽端口
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;
}
}
測試（具體需求實現(xiàn)就根據(jù)官方API實現(xiàn)，參考本篇博客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}
三、補充
具體詳細需求請參考實現(xiàn)：https://docs.go-cqhttp.org/api/
到此這篇關于SpringBoot搭建go-cqhttp機器人的方法實現(xiàn)的文章就介紹到這了,更多相關SpringBoot搭建go-cqhttp機器人內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
將一個數(shù)組按照固定大小進行拆分成數(shù)組的方法
下面小編就為大家?guī)硪黄獙⒁粋€數(shù)組按照固定大小進行拆分成數(shù)組的方法。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2016-11-11
這篇文章主要為大家詳細介紹了Java實現(xiàn)導入csv的相關知識,文中的示例代碼講解詳細,具有一定的借鑒價值,有需要的小伙伴可以跟隨小編一起學習一下2024-03-03
關于idea-web.xml版本過低怎么生成新的（web.xml報錯）問題
今天通過本文給大家分享idea-web.xml版本過低怎么生成新的（web.xml報錯）問題，通過更換web.xml版本解決此問題，感興趣的朋友跟隨小編一起看看吧2021-07-07
我們在走ingress的java程序的時候,往往會有導出數(shù)據(jù)的功能,這個時候就會有因網絡慢、后臺處理時間過長導致下載超時,也有因下載文件太大,導致下載失敗,下面給分享k8s解決java服務下載超時問題,感興趣的朋友跟隨小編一起看看吧2024-06-06
本文主要介紹了spring中Mapstruct屬性映射的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2024-12-12
mybatisplus如何解決分頁最多500條數(shù)據(jù)
這篇文章主要介紹了mybatisplus如何解決分頁最多500條數(shù)據(jù)的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-07-07
Watcher，異步通知客戶端，并且刪除哈希表中對應的 Key-Value，這篇文章主要介紹了zookeeper的watch機制詳細講解,需要的朋友可以參考下2022-06-06
使用Spring事件監(jiān)聽機制實現(xiàn)跨模塊調用的步驟詳解
Spring 事件監(jiān)聽機制是 Spring 框架中用于在應用程序的不同組件之間進行通信的一種機制,Spring 事件監(jiān)聽機制基于觀察者設計模式,使得應用程序的各個部分可以解耦,提高模塊化和可維護性,本文給大家介紹了使用Spring事件監(jiān)聽機制實現(xiàn)跨模塊調用,需要的朋友可以參考下2024-06-06
RestFul風格 — 使用@PathVariable傳遞參數(shù)報錯404的解決
這篇文章主要介紹了RestFul風格 — 使用@PathVariable傳遞參數(shù)報錯404的解決，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-10-10
詳解利用SpringMVC攔截器控制Controller返回值
這篇文章主要介紹了詳解利用SpringMVC攔截器控制Controller返回值，通過定義一個StringResult注解，在訪問方法的時候返回StringResult中的內容，有興趣的可以了解一下。2017-01-01