SpringBoot（二十一）SpringBoot自定义CURL请求类

devtools/2024/11/14 12:05:47/

在测试SpringAi的时候，发现springAI比较人性化的地方，他为开发者提供了多种请求方式，如下图所示：

1.png.jpg

上边的三种方式里边，我还是喜欢CURL，巧了，我还没在Springboot框架中使用过CURL呢。正好封装一个CURL工具类。

我这里使用httpclient来实现CURL请求。

一：添加依赖

不需要任何第三方依赖，对，就是这样。

二：实现请求

1：封装POST请求，代码如下：

java">/*** @name CURL POST 请求* @param url     接口地址* @param list    NameValuePair（简单名称值对节点类型）类似html中的input* @param headers 请求头（默认Content-Type：application/x-www-form-urlencoded; charset=UTF-8）* 请求示例// 设置请求头Map<String, String> headers = new HashMap<>();headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 设置请求参数ArrayList<NameValuePair> list = new ArrayList<>();list.add(new BasicNameValuePair("indexName", "test"));// 发送请求String s = CurlRequest.curlPost("http://localhost:7001/java/elastic/indexIsExists", list, headers);System.out.println(s);*/
public static Map<String, Object> curlPost(String url, ArrayList<NameValuePair> list, Map<String, String> headers)
{String StringResult = "";CloseableHttpClient closeableHttpClient = HttpClients.createDefault();HttpPost httpPost = new HttpPost(url);if (list != null && !list.isEmpty()){UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(list, Consts.UTF_8);httpPost.setEntity(formEntity);}httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpPost.addHeader(head, headers.get(head));}}CloseableHttpResponse response = null;try{response = closeableHttpClient.execute(httpPost);HttpEntity entity = response.getEntity();StringResult = EntityUtils.toString(entity, StandardCharsets.UTF_8);EntityUtils.consume(entity);}catch (Exception e){StringResult = "errorException:" + e.getMessage();e.printStackTrace();}finally{checkObjectIsNull(closeableHttpClient, response);}return Function.convertJsonToMap(StringResult);
}
/*** 判断对象是否为Null* @param closeableHttpClient* @param response*/
private static void checkObjectIsNull(CloseableHttpClient closeableHttpClient, CloseableHttpResponse response)
{if(response != null){try{response.close();}catch (IOException e){e.printStackTrace();}}if (closeableHttpClient != null){try{closeableHttpClient.close();}catch (IOException e){e.printStackTrace();}}
}

调用测试：

java">@GetMapping("index/testsss")
public void testsss()
{// 测试CURLPOST// 设置请求头Map<String, String> headers = new HashMap<>();headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 设置请求参数ArrayList<NameValuePair> list = new ArrayList<>();list.add(new BasicNameValuePair("indexName", "test"));// 发送请求String s = CurlRequest.curlPost("http://localhost:7001/java/elastic/indexIsExists", list, headers);System.out.println(s);
}

2：封装GET请求，代码如下：

java">/*** @param url    获取get请求URL地址(无参数/有参)* @param params 拼接参数集合* @Description get请求URL拼接参数 & URL编码* 请求示例// 设置请求参数Map<String, String> params = new HashMap<>();params.put("search", "服务");// 获取请求链接String appendUrl = CurlRequest.getCurlGetUrl("http://localhost:7001/java/index/getArticleListByCategory?page=1", params);System.out.println(appendUrl);*/
public static String getCurlGetUrl(String url, Map<String, String> params)
{StringBuffer buffer = new StringBuffer(url);if (params != null && !params.isEmpty()){for (String key : params.keySet()){if (buffer.indexOf("?") >= 0){buffer.append("&");}else{buffer.append("?");}String value = "";//value = params.get(key);try{value = URLEncoder.encode(params.get(key), StandardCharsets.UTF_8.name());}catch (UnsupportedEncodingException e){e.printStackTrace();}//*/buffer.append(key).append("=").append(value);}}return buffer.toString();
}/*** @param url     接口地址* @param headers 请求头* @Description get请求* 请求示例// 设置请求头Map<String, String> headers = new HashMap<>();headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 设置请求参数Map<String, String> params = new HashMap<>();params.put("search", "服务");// 获取请求链接String appendUrl = CurlRequest.getCurlGetUrl("http://localhost:7001/java/index/getArticleListByCategory?page=1", params);System.out.println(appendUrl);// 发送请求String postData = CurlRequest.curlGet(appendUrl,headers);System.out.println(postData);*/
public static String curlGet(String url, Map<String, String> headers)
{String StringResult = "";CloseableHttpClient closeableHttpClient = HttpClients.createDefault();HttpGet httpGet = new HttpGet(url);if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpGet.addHeader(head, headers.get(head));}}CloseableHttpResponse response = null;try{response = closeableHttpClient.execute(httpGet);HttpEntity entity = response.getEntity();StringResult = EntityUtils.toString(entity, StandardCharsets.UTF_8).trim();EntityUtils.consume(entity);}catch (Exception e){e.printStackTrace();StringResult = "errorException:" + e.getMessage();}finally{checkObjectIsNull(closeableHttpClient, response);}return StringResult;
}/*** 判断对象是否为Null* @param closeableHttpClient* @param response*/
private static void checkObjectIsNull(CloseableHttpClient closeableHttpClient, CloseableHttpResponse response)
{if(response != null){try{response.close();}catch (IOException e){e.printStackTrace();}}if (closeableHttpClient != null){try{closeableHttpClient.close();}catch (IOException e){e.printStackTrace();}}
}

测试一下：

java">@GetMapping("index/testsss")
public void testsss()
{
// 测试CURLGET
// 设置请求头
Map<String, String> getheaders = new HashMap<>();
getheaders.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");
// 设置请求参数
Map<String, String> params = new HashMap<>();
params.put("search", "服务");
// 获取请求链接
String appendUrl = CurlRequest.getCurlGetUrl("http://localhost:7001/java/index/getArticleListByCategory?page=1", params);
System.out.println(appendUrl);
// 发送请求
String postData = CurlRequest.curlGet(appendUrl,getheaders);
System.out.println(postData);//*/
}

3：POST异步请求

java">/*** @name 异步 CURL POST 请求* @param url     接口地址* @param list    NameValuePair（简单名称值对节点类型）类似html中的input* @param headers 请求头（默认Content-Type：application/x-www-form-urlencoded; charset=UTF-8）* 请求示例ArrayList<NameValuePair> asynclist = new ArrayList<>();asynclist.add(new BasicNameValuePair("indexName", "test"));asynclist.add(new BasicNameValuePair("id", "90"));// 设置请求头Map<String, String> asyncHeaders = new HashMap<>();asyncHeaders.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 发送请求Map<String,Object> async = CurlRequest.asyncCurlPost("http://localhost:7001/java/elastic/documentIsExists", asynclist, asyncHeaders);System.out.println(async);return "我在tessss方法中……";*/
public static Map<String, Object> asyncCurlPost(String url, ArrayList<NameValuePair> list, Map<String, String> headers)
{String responseBody = "";// 创建异步HTTP客户端CloseableHttpAsyncClient httpClient = HttpAsyncClients.createDefault();try{httpClient.start(); // 启动HttpClient// 创建Http Post请求HttpPost httpPost = new HttpPost(url);// 设置请求参数if (list != null && !list.isEmpty()){UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(list, Consts.UTF_8);httpPost.setEntity(formEntity);}// 设置请求头httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpPost.addHeader(head, headers.get(head));}}// 发送请求并获取Future对象Future<HttpResponse> future = httpClient.execute(httpPost, null);// 获取响应HttpResponse response = future.get();responseBody = EntityUtils.toString(response.getEntity());System.out.println("Response: " + responseBody);}catch (Exception e){e.printStackTrace();System.out.println("请求出错了！");}finally{// 关闭HttpClienttry{httpClient.close();}catch (IOException e){e.printStackTrace();}Map<String, Object> result = new HashMap<>();result.put("code", 1);result.put("result", "异步请求发送成功！");result.put("responseBody", responseBody);return result;}
}

测试一下：

java">@GetMapping("index/testsss")
public void testsss()
{// 测试ASYNCCURLPOST// 发送请求Map<String,Object> async = CurlRequest.asyncCurlPost("http://localhost:7001/java/index/tessss", null, null);System.out.println(async);
}/*** 测试CURL POST异步方法*/
@PostMapping("index/tessss")
public String tessss()
{ArrayList<NameValuePair> asynclist = new ArrayList<>();asynclist.add(new BasicNameValuePair("indexName", "test"));asynclist.add(new BasicNameValuePair("id", "90"));// 设置请求头Map<String, String> asyncHeaders = new HashMap<>();asyncHeaders.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 发送请求Map<String,Object> async = CurlRequest.asyncCurlPost("http://localhost:7001/java/elastic/documentIsExists", asynclist, asyncHeaders);System.out.println(async);return "我在tessss方法中……";
}

浏览器访问：http://localhost:7001/java/index/testsss

控制台输出：

我们先请求这个方法tessss，这个tessss方法的返回值反而后边输出，因此，异步请求成功

2.png.jpg

三：完整CURL请求类

java">package com.springbootblog.utils;import org.apache.http.Consts;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.concurrent.FutureCallback;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
import org.apache.http.impl.nio.client.HttpAsyncClients;
import org.apache.http.util.EntityUtils;import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Future;/*** 自定义curl类*/
public class CurlRequest
{/*** @name CURL POST 请求* @param url     接口地址* @param list    NameValuePair（简单名称值对节点类型）类似html中的input* @param headers 请求头（默认Content-Type：application/x-www-form-urlencoded; charset=UTF-8）* 请求示例// 设置请求头Map<String, String> headers = new HashMap<>();headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 设置请求参数ArrayList<NameValuePair> list = new ArrayList<>();list.add(new BasicNameValuePair("indexName", "test"));// 发送请求String s = CurlRequest.curlPost("http://localhost:7001/java/elastic/indexIsExists", list, headers);System.out.println(s);*/public static Map<String, Object> curlPost(String url, ArrayList<NameValuePair> list, Map<String, String> headers){String StringResult = "";CloseableHttpClient closeableHttpClient = HttpClients.createDefault();HttpPost httpPost = new HttpPost(url);if (list != null && !list.isEmpty()){UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(list, Consts.UTF_8);httpPost.setEntity(formEntity);}httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpPost.addHeader(head, headers.get(head));}}CloseableHttpResponse response = null;try{response = closeableHttpClient.execute(httpPost);HttpEntity entity = response.getEntity();StringResult = EntityUtils.toString(entity, StandardCharsets.UTF_8);EntityUtils.consume(entity);}catch (Exception e){StringResult = "errorException:" + e.getMessage();e.printStackTrace();}finally{checkObjectIsNull(closeableHttpClient, response);}return Function.convertJsonToMap(StringResult);}/*** @name 异步 CURL POST 请求* @param url     接口地址* @param list    NameValuePair（简单名称值对节点类型）类似html中的input* @param headers 请求头（默认Content-Type：application/x-www-form-urlencoded; charset=UTF-8）* 请求示例ArrayList<NameValuePair> asynclist = new ArrayList<>();asynclist.add(new BasicNameValuePair("indexName", "test"));asynclist.add(new BasicNameValuePair("id", "90"));// 设置请求头Map<String, String> asyncHeaders = new HashMap<>();asyncHeaders.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 发送请求Map<String,Object> async = CurlRequest.asyncCurlPost("http://localhost:7001/java/elastic/documentIsExists", asynclist, asyncHeaders);System.out.println(async);return "我在tessss方法中……";*/public static Map<String, Object> asyncCurlPost(String url, ArrayList<NameValuePair> list, Map<String, String> headers){String responseBody = "";// 创建异步HTTP客户端CloseableHttpAsyncClient httpClient = HttpAsyncClients.createDefault();try{httpClient.start(); // 启动HttpClient// 创建Http Post请求HttpPost httpPost = new HttpPost(url);// 设置请求参数if (list != null && !list.isEmpty()){UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(list, Consts.UTF_8);httpPost.setEntity(formEntity);}// 设置请求头httpPost.addHeader("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8");if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpPost.addHeader(head, headers.get(head));}}// 发送请求并获取Future对象Future<HttpResponse> future = httpClient.execute(httpPost, null);// 获取响应HttpResponse response = future.get();responseBody = EntityUtils.toString(response.getEntity());System.out.println("Response: " + responseBody);}catch (Exception e){e.printStackTrace();System.out.println("请求出错了！");}finally{// 关闭HttpClienttry{httpClient.close();}catch (IOException e){e.printStackTrace();}Map<String, Object> result = new HashMap<>();result.put("code", 1);result.put("result", "异步请求发送成功！");result.put("responseBody", responseBody);return result;}}/*** @name 组装 GET 请求连接* @param url    获取get请求URL地址(无参数/有参)* @param params 拼接参数集合* @Description get请求URL拼接参数 & URL编码* 请求示例// 设置请求参数Map<String, String> params = new HashMap<>();params.put("search", "服务");// 获取请求链接String appendUrl = CurlRequest.getCurlGetUrl("http://localhost:7001/java/index/getArticleListByCategory?page=1", params);System.out.println(appendUrl);*/public static String getCurlGetUrl(String url, Map<String, String> params){StringBuffer buffer = new StringBuffer(url);if (params != null && !params.isEmpty()){for (String key : params.keySet()){if (buffer.indexOf("?") >= 0){buffer.append("&");}else{buffer.append("?");}String value = "";//value = params.get(key);try{value = URLEncoder.encode(params.get(key), StandardCharsets.UTF_8.name());}catch (UnsupportedEncodingException e){e.printStackTrace();}//*/buffer.append(key).append("=").append(value);}}return buffer.toString();}/*** @name CURL GET 请求* @param url     接口地址* @param headers 请求头* @Description get请求* 请求示例// 设置请求头Map<String, String> headers = new HashMap<>();headers.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36");// 设置请求参数Map<String, String> params = new HashMap<>();params.put("search", "服务");// 获取请求链接String appendUrl = CurlRequest.getCurlGetUrl("http://localhost:7001/java/index/getArticleListByCategory?page=1", params);System.out.println(appendUrl);// 发送请求String postData = CurlRequest.curlGet(appendUrl,headers);System.out.println(postData);*/public static Map<String, Object> curlGet(String url, Map<String, String> headers){String StringResult = "";CloseableHttpClient closeableHttpClient = HttpClients.createDefault();HttpGet httpGet = new HttpGet(url);if (headers != null && !headers.isEmpty()){for (String head : headers.keySet()){httpGet.addHeader(head, headers.get(head));}}CloseableHttpResponse response = null;try{response = closeableHttpClient.execute(httpGet);HttpEntity entity = response.getEntity();StringResult = EntityUtils.toString(entity, StandardCharsets.UTF_8).trim();EntityUtils.consume(entity);}catch (Exception e){e.printStackTrace();StringResult = "errorException:" + e.getMessage();}finally{checkObjectIsNull(closeableHttpClient, response);}return Function.convertJsonToMap(StringResult);}/*** 判断对象是否为Null* @param closeableHttpClient* @param response*/private static void checkObjectIsNull(CloseableHttpClient closeableHttpClient, CloseableHttpResponse response){if(response != null){try{response.close();}catch (IOException e){e.printStackTrace();}}if (closeableHttpClient != null){try{closeableHttpClient.close();}catch (IOException e){e.printStackTrace();}}}}

有好的建议，请在下方输入你的评论。


http://www.ppmy.cn/devtools/133919.html

相关文章

opencv常用api

opencv常用api

opencv常用api 截取图像 cv::Mat pic2; pic(cv::Rect(50, 50, 200, 200)).copyTo(pic2); cv::imshow("Image Display2", pic2);将图像区域复制到图像指定的区域 pic2.copyTo(pic(cv::Rect(200, 200, 200, 200))); cv::imshow("Image Display3", pic);通…
阅读更多...
大模型生成策略参数详解：Top-K、Top-P 和 Temperature

大模型生成策略参数详解：Top-K、Top-P 和 Temperature

文章目录 1. Top-K&#xff1a;限制候选词数量举例总结 2. Top-P&#xff08;核采样&#xff09;&#xff1a;控制候选词的累积概率举例总结 3. Temperature&#xff1a;控制生成的随机性举例总结 综合使用&#xff1a;Top-K、Top-P 和 Temperature 的平衡总结推荐阅读文章 在大…
阅读更多...
uni-app选项卡制作 ⑥

uni-app选项卡制作 ⑥

文章目录 十、选项卡制作一 、组件创建二、scroll-view 组件使用三、点击设置按钮跳转到标签设置界面四、数据获取 十、选项卡制作 1.遇到错误&#xff1a; 2.解决问题&#xff1a; 3.this 指向问题 // 指向&#xff1a; get_label_list uniCloud.callFunction({name: "g…
阅读更多...
Day107：代码审计-PHP模型开发篇MVC层RCE执行文件对比法1day分析0day验证

Day107：代码审计-PHP模型开发篇MVC层RCE执行文件对比法1day分析0day验证

知识点&#xff1a; 1、PHP审计-MVC开发-RCE&代码执行 2、PHP审计-MVC开发-RCE&命令执行 3、PHP审计-MVC开发-RCE&文件对比 MVC 架构 MVC流程&#xff1a; Controller截获用户发出的请求&#xff1b;Controller调用Model完成状态的读写操作&#xff1b;Contr…
阅读更多...
MySQL第七章，项目案例：保险管理系统

MySQL第七章，项目案例：保险管理系统

学了这么久来做一次项目&#xff0c;总结一下吧 保险管理系统首先来规划一下数据表 然后设计步骤 1. 规划数据库表 首先&#xff0c;你需要确定系统需要哪些数据表。一个基本的保险管理系统可能包括以下几个表&#xff1a; 用户表&#xff08;Users&#xff09;&#xff1…
阅读更多...
Spring声明式事务 编程式事务

Spring声明式事务 编程式事务

Spring声明式事务 1.事务的概念 1.1编程式事务 编程式事务是指手动编写程序来管理事务&#xff0c;即通过编写代码的方式直接控制事务的提交和回滚 Connection conn …; ​ try{ //开启事务&#xff1a;关闭事务的自动提交 conn.setAutoCommit(false); //业务代码 … //提交…
阅读更多...
【Linux篇】面试——用户和组、文件类型、权限、进程

【Linux篇】面试——用户和组、文件类型、权限、进程

目录 一、权限管理 1. 用户和组 &#xff08;1&#xff09;相关概念 &#xff08;2&#xff09;用户命令 ① useradd&#xff08;添加新的用户账号&#xff09; ② userdel&#xff08;删除帐号&#xff09; ③ usermod&#xff08;修改帐号&#xff09; ④ passwd&…
阅读更多...
2024年计算机视觉与图像处理国际学术会议 (CVIP 2024)

2024年计算机视觉与图像处理国际学术会议 (CVIP 2024)

目录 大会简介 主办单位&#xff0c;协办单位 组委会 主讲嘉宾 征稿主题 参会方式 会议议程 重要信息 会议官网&#xff1a;iccvip.org 大会时间&#xff1a;2024年11月15日-17日 大会地点&#xff1a;中国 杭州 大会简介 2024年计算机视觉与图像处理国际学术会议(C…
阅读更多...
最新文章

Copyright @ 2022~2023