java使用HttpClient发送数据的几种情况

1.发送Http 携带 json格式的数据

import org.apache.commons.compress.utils.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import javax.net.ssl.*;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.nio.charset.Charset;
import java.security.KeyStore;
import java.security.SecureRandom;
import java.util.HashMap;public class HttpClienUtil {private static Logger logger = LoggerFactory.getLogger(HttpClienUtil.class);public static String sandHttpClien(String jsonDataStr,String url){HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();// 请求的 地址HttpPost post = new HttpPost(url);String result = "";try (CloseableHttpClient closeableHttpClient = httpClientBuilder.build()) {// 设置 post 请求参数 json 字符串 形式的//String jsonDataStr = JSON.toJSONString(deviceRegisterVO);// 修复 POST json 导致中文乱码HttpEntity entity = new StringEntity(jsonDataStr,"UTF-8");post.setEntity(entity);post.setHeader("Content-type", "application/json");//发送 请求HttpResponse resp = closeableHttpClient.execute(post);InputStream respIs = resp.getEntity().getContent();byte[] respBytes = IOUtils.toByteArray(respIs);// 接受 并转换 回调的数据result = new String(respBytes, Charset.forName("UTF-8"));//DeviceRegistVO deviceRegistVO = JSON.parseObject(result, DeviceRegistVO.class);} catch (Exception e) {logger.error("HttpClienUtil post报错", e);} finally {return result;}}}

2.发送Http 携带 表单 格式 带 token 的数据

import com.ruoyi.common.utils.uuid.IdUtils;
import org.apache.commons.compress.utils.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.entity.mime.FormBodyPart;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.InputStream;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.util.Map;
import java.util.Set;public class HttpClienUtil {private static Logger logger = LoggerFactory.getLogger(HttpClienUtil.class);private static final Logger reportLogger = LoggerFactory.getLogger("report-info");// 登录 接口public static String sandHttpClien(Map<String,String> mapData, String url,String token){//        reportLogger.info("进入sandHttpClien方法");
//        reportLogger.info("参数mapData：" + mapData);
//        reportLogger.info("参数url：" + url);
//        reportLogger.info("参数token：" + token);String boundary = IdUtils.simpleUUID();HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();// 请求的 地址HttpPost post = new HttpPost(url);String result = "";try (CloseableHttpClient closeableHttpClient = httpClientBuilder.build()) {// 设置 post 请求参数 json 字符串 形式的//String jsonDataStr = JSON.toJSONString(deviceRegisterVO);// 修复 POST json 导致中文乱码
//            HttpEntity entity = new StringEntity(jsonDataStr,"UTF-8");
//            post.setEntity(entity);
//            post.setHeader("Content-type", "application/json");post.addHeader("Content-type", "multipart/form-data; charset=UTF-8; boundary=" + boundary);post.addHeader("Accept", "*/*");post.addHeader("Accept-Encoding", "UTF-8");post.addHeader("User-Agent", " Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/123.0.0.0 Safari/537.36");if(token != null){post.addHeader("Authorization", "Bearer " + token);}MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create().setCharset(StandardCharsets.UTF_8).setBoundary(boundary);ContentType contentType = ContentType.create("text/plain",Charset.forName("UTF-8"));Set keySet = mapData.keySet();for (Object key : keySet) {// 设置请求参数multipartEntityBuilder.addTextBody(key.toString(), mapData.get(key),contentType);}HttpEntity postFormDataBody = multipartEntityBuilder.build();// 请求参数post.setEntity(postFormDataBody);//发送 请求
//            reportLogger.info("sandHttpClien方法 发送请求前 ");HttpResponse resp = closeableHttpClient.execute(post);
//            reportLogger.info("sandHttpClien方法 发送请求后 ");InputStream respIs = resp.getEntity().getContent();byte[] respBytes = IOUtils.toByteArray(respIs);// 接受 并转换 回调的数据result = new String(respBytes, Charset.forName("UTF-8"));//DeviceRegistVO deviceRegistVO = JSON.parseObject(result, DeviceRegistVO.class);} catch (Exception e) {logger.error("HttpClienUtil post报错", e);reportLogger.error("HttpClienUtil post报错", e);} finally {reportLogger.info("sandHttpClien方法 收到的返回结果： " +result );return result;}}}

3.发送 Http 通过绑定 代理IP和端口的 数据

import org.apache.commons.compress.utils.IOUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.impl.conn.BasicHttpClientConnectionManager;
import org.apache.http.impl.conn.DefaultProxyRoutePlanner;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;public class HttpUtil {private static Logger logger = LoggerFactory.getLogger(HttpClienUtil.class);public static String sandHttpClien(String jsonDataStr,String url){// HttpHost proxy = new HttpHost("192.168.110.253",60601);String result = "";// 代理服务器信息HttpHost proxy = new HttpHost("192.168.110.253",60601);// 创建连接管理器并设置代理BasicHttpClientConnectionManager connManager = new BasicHttpClientConnectionManager();DefaultProxyRoutePlanner routePlanner = new DefaultProxyRoutePlanner(proxy);// 创建HttpClient并设置连接管理器和路由规划器try (CloseableHttpClient httpClient = HttpClients.custom().setConnectionManager(connManager).setRoutePlanner(routePlanner).build()) {// 创建HTTP GET请求HttpPost request = new HttpPost(url);HttpEntity entity = new StringEntity(jsonDataStr,"UTF-8");request.setEntity(entity);request.setHeader("Content-type", "application/json");// 执行请求并获取响应try (CloseableHttpResponse response = httpClient.execute(request)) {InputStream respIs = response.getEntity().getContent();byte[] respBytes = IOUtils.toByteArray(respIs);// 接受 并转换 回调的数据result = new String(respBytes, Charset.forName("UTF-8"));}} catch (IOException e) {e.printStackTrace();}finally {return result;}}
}

3.发送 Https 带 p12 证书的 数据

import com.ruoyi.common.utils.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.NameValuePair;
import org.apache.http.ParseException;
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.conn.ssl.SSLConnectionSocketFactory;
import org.apache.http.conn.ssl.TrustStrategy;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.ssl.SSLContexts;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.ClassPathResource;import javax.net.ssl.SSLContext;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.nio.charset.UnsupportedCharsetException;
import java.security.*;
import java.security.cert.CertificateException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;public class HttpsUtil {private Logger logger = LoggerFactory.getLogger(HttpsUtil.class);/**客户端证书路径*/private static final ClassPathResource KEY_STORE_CLIENT_PATH = new ClassPathResource("ca/client.p12");/** keystore类型JKS*/private static final String KEY_STORE_TYPE_JKS = "JKS";/** keystore密码*/private static final String KEYSTORE_PASSWORD = "123456";private CloseableHttpClient httpClient;/*** @throws Exception*/public HttpsUtil()  {try {KeyStore keyStore = KeyStore.getInstance(KEY_STORE_TYPE_JKS);KeyStore trustKeyStore = KeyStore.getInstance(KeyStore.getDefaultType());InputStream instream = KEY_STORE_CLIENT_PATH.getInputStream();try {//密钥库口令keyStore.load(instream, KEYSTORE_PASSWORD.toCharArray());} catch (CertificateException e) {logger.error("加载客户端端可信任证书出错了", e);} finally {try {instream.close();} catch (Exception ignore) {}}SSLContext sslcontext = SSLContexts.custom()//忽略掉对服务器端证书的校验.loadTrustMaterial(new TrustStrategy() {@Overridepublic boolean isTrusted(java.security.cert.X509Certificate[] chain, String authType) throws CertificateException {return true;}}).loadKeyMaterial(keyStore, KEYSTORE_PASSWORD.toCharArray()).build();SSLConnectionSocketFactory sslConnectionSocketFactory = new SSLConnectionSocketFactory(sslcontext,new String[]{"TLSv1.1"},null,SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);this.httpClient = HttpClients.custom().setSSLSocketFactory(sslConnectionSocketFactory).build();} catch (KeyStoreException e) {logger.error("HttpsUtil初始化报错", e);} catch (IOException e) {logger.error("HttpsUtil初始化报错", e);} catch (NoSuchAlgorithmException e) {logger.error("HttpsUtil初始化报错", e);} catch (KeyManagementException e) {logger.error("HttpsUtil初始化报错", e);} catch (UnrecoverableKeyException e) {logger.error("HttpsUtil初始化报错", e);}}/*** 发送post请求** @param url* @param map* @throws Exception*/public String post(String url, Map<String, Object> map) throws Exception {// 声明POST请求HttpPost httpPost = new HttpPost(url);// 判断map不为空if (null != map) {// 声明存放参数的List集合List<NameValuePair> params = new ArrayList<NameValuePair>();// 遍历map，设置参数到list中for (Map.Entry<String, Object> entry : map.entrySet()) {params.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));}// 创建form表单对象UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(params, "utf-8");formEntity.setContentType("Content-Type:application/json");// 把表单对象设置到httpPost中httpPost.setEntity(formEntity);}// 使用HttpClient发起请求，返回responseCloseableHttpResponse response = this.httpClient.execute(httpPost);// 获取实体HttpEntity entity = response.getEntity();// 将实体装成字符串String res = EntityUtils.toString(entity, Charset.defaultCharset());EntityUtils.consume(entity);return res;}/*** 发送POST请求** @param url* @param map* @return* @throws Exception*/public String get(String url, Map<String, Object> map) throws Exception {String params = null;if (null != map) {// 声明存放参数的List集合List<NameValuePair> list = new ArrayList<NameValuePair>();// 遍历map，设置参数到list中for (Map.Entry<String, Object> entry : map.entrySet()) {list.add(new BasicNameValuePair(entry.getKey(), entry.getValue().toString()));}// 转化参数params = EntityUtils.toString(new UrlEncodedFormEntity(list, "utf-8"));}url += StringUtils.isNotBlank(params) ? ("?" + params) : "";HttpGet httpGet = new HttpGet(url);// 使用HttpClient发起请求，返回responseCloseableHttpResponse response = this.httpClient.execute(httpGet);// 获取实体HttpEntity entity = response.getEntity();// 将实体装成字符串String res = EntityUtils.toString(entity, Charset.defaultCharset());EntityUtils.consume(entity);response.close();return res;}/*** 发送POST请求（JSON参数）** @param url* @param json* @return* @throws IOException*/public String post(String url, String json) {String res = null;try {// 声明POST请求HttpPost httpPost = new HttpPost(url);// 表示客户端发送给服务器端的数据格式httpPost.setHeader("Content-Type", "application/json;charset=UTF-8");httpPost.setHeader("Accept", "application/json");StringEntity param = new StringEntity(json, ContentType.APPLICATION_JSON);httpPost.setEntity(param);CloseableHttpResponse resp = this.httpClient.execute(httpPost);HttpEntity entity = resp.getEntity();// 将实体装成字符串res = EntityUtils.toString(entity, Charset.defaultCharset());EntityUtils.consume(entity);resp.close();} catch (UnsupportedCharsetException e) {logger.error("HttpsUtil post报错", e);} catch (IOException e) {logger.error("HttpsUtil post报错", e);} catch (ParseException e) {logger.error("HttpsUtil post报错", e);}return res;}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/62952.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

稳定运行的以Azure Synapse Dedicated SQL Pool数据仓库为数据源和目标的ETL性能变差时提高性能方法和步骤

稳定运行的以Azure Synapse Dedicated SQL Pool数据仓库为数据源和目标的ETL性能变差时提高性能方法和步骤

在Azure Synapse Dedicated SQL Pool&#xff08;以前称为SQL Data Warehouse&#xff09;的ETL性能变差时&#xff0c;可以通过以下方法和步骤来提高性能&#xff1a; 1. 分析和监控性能瓶颈 查看执行计划&#xff1a;使用SQL的SET STATISTICS IO ON和SET STATISTICS TIME O…
阅读更多...
华为、华三交换机纯Web下如何创关键VLANIF、操作STP参数

华为、华三交换机纯Web下如何创关键VLANIF、操作STP参数

华为交换机WEB操作 使用的是真机S5735&#xff0c;目前主流的版本都适用&#xff08;V1R5~V2R1的就不在列了&#xff0c;版本太老了&#xff0c;界面完全不一样&#xff0c;这里调试线接的console口&#xff0c;电脑的网络接在ETH口&#xff09; 「模拟器、工具合集」复制整段内…
阅读更多...
OpenCL介绍

OpenCL介绍

OpenCL&#xff08;Open Computing Language&#xff09;详解 OpenCL 是一个开源的框架&#xff0c;用于编写在异构平台&#xff08;包括中央处理单元&#xff08;CPU&#xff09;、图形处理单元&#xff08;GPU&#xff09;、数字信号处理器&#xff08;DSP&#xff09;和其他…
阅读更多...
项目搭建：springboot，mybatis, maven

项目搭建：springboot，mybatis, maven

创建一个基于Spring Boot、MyBatis和Maven的项目可以简化很多配置&#xff0c;因为Spring Boot自带了很多自动配置的功能。下面我将给出一个简单的示例来展示如何搭建这样一个项目。 ### 1. 创建一个新的Spring Boot项目 你可以通过Spring Initializr&#xff08;https://sta…
阅读更多...
详解Java数据库编程之JDBC

详解Java数据库编程之JDBC

目录 首先创建一个Java项目 在Maven中央仓库下载mysql connector的jar包 针对MySQL版本5 针对MySQL版本8 下载之后&#xff0c;在IDEA中创建的项目中建立一个lib目录&#xff0c;然后把刚刚下载好的jar包拷贝进去&#xff0c;然后右键刚刚添加的jar包&#xff0c;点击‘添…
阅读更多...
网络（TCP）

网络（TCP）

目录 TCP socket API 详解 套接字有哪些类型&#xff1f;socket有哪些类型&#xff1f; 图解TCP四次握手断开连接 图解TCP数据报结构以及三次握手&#xff08;非常详细&#xff09; socket缓冲区以及阻塞模式详解 再谈UDP和TCP bind(): 我们的程序中对myaddr参数是这样…
阅读更多...
【笔记】离散数学 1-3 章

【笔记】离散数学 1-3 章

1. 数理逻辑 1.1 命题逻辑的基本概念 1.1.1 命题的概念 命题&#xff08;Proposition&#xff09;&#xff1a;是一个陈述句&#xff0c;它要么是真的&#xff08;true&#xff09;&#xff0c;要么是假的&#xff08;false&#xff09;&#xff0c;但不能同时为真和假。例如…
阅读更多...
【Linux篇】权限管理 - 用户与组权限详解

【Linux篇】权限管理 - 用户与组权限详解

一. 什么是权限&#xff1f; 首先权限是限制人的。人 真实的人 身份角色 权限 角色 事物属性 二. 认识人–用户 Linux下的用户分为超级用户和普通用户 root :超级管理员&#xff0c;几乎不受权限的约束普通用户 :受权限的约束超级用户的命令提示符是#&#xff0c;普通用…
阅读更多...
【机器学习】机器学习的基本分类-监督学习-决策树-C4.5 算法

【机器学习】机器学习的基本分类-监督学习-决策树-C4.5 算法

C4.5 是由 Ross Quinlan 提出的决策树算法&#xff0c;是对 ID3 算法的改进版本。它在 ID3 的基础上&#xff0c;解决了以下问题&#xff1a; 处理连续型数据&#xff1a;支持连续型特征&#xff0c;能够通过划分点将连续特征离散化。处理缺失值&#xff1a;能够在特征值缺失的…
阅读更多...
运维之网络安全抓包—— WireShark 和 tcpdump

运维之网络安全抓包—— WireShark 和 tcpdump

为什么要抓包&#xff1f;何为抓包&#xff1f; 抓包&#xff08;packet capture&#xff09;就是将网络传输发送与接收的数据包进行截获、重发、编辑、转存等操作&#xff0c;也用来检查网络安全。抓包也经常被用来进行数据截取等。为什么要抓包&#xff1f;因为在处理 IP网络…
阅读更多...
MongoDB 索引类型详解

MongoDB 索引类型详解

MongoDB 索引类型详解 在 MongoDB 中&#xff0c;索引是提高查询效率、优化数据库性能的重要手段。MongoDB 支持多种类型的索引&#xff0c;每种索引类型适用于不同的查询需求和场景。本文将详细介绍 MongoDB 中几种常见的索引类型、示例及其限制。 1. 单字段索引&#xff08…
阅读更多...
2023年MathorCup高校数学建模挑战赛—大数据竞赛B题电商零售商家需求预测及库存优化问题求解全过程文档及程序

2023年MathorCup高校数学建模挑战赛—大数据竞赛B题电商零售商家需求预测及库存优化问题求解全过程文档及程序

2023年MathorCup高校数学建模挑战赛—大数据竞赛 B题 电商零售商家需求预测及库存优化问题 原题再现&#xff1a; 电商平台存在着上千个商家&#xff0c;他们会将商品货物放在电商配套的仓库&#xff0c;电商平台会对这些货物进行统一管理。通过科学的管理手段和智能决策&…
阅读更多...
cocotb pytest

cocotb pytest

打印python中的print &#xff0c; 应该使用 pytest -s pytest --junitxmltest_report.xml --htmlreport.html
阅读更多...
【Linux】进程间关系与守护进程

【Linux】进程间关系与守护进程

&#x1f30e;进程间关系与守护进程 文章目录&#xff1a; 进程间关系与守护进程 进程组     会话       认识会话       会话ID       创建会话 控制终端     作业控制       作业(job)和作业控制(Job Control)       作业号及作业过程…
阅读更多...
RuoYi-Vue部署到Linux服务器(Jar+Nginx)

RuoYi-Vue部署到Linux服务器(Jar+Nginx)

一、本地环境准备 源码下载、本地Jdk及Node.js环境安装，参考以下文章。 附：RuoYi-Vue下载与运行 二、服务器环境准备 1.安装Jdk 附：JDK8下载安装与配置环境变量(linux) 2.安装MySQL 附：MySQL8免安装版下载安装与配置(linux) 3.安装Redis 附：Redis下载安装与配置(…
阅读更多...
QT5.14 QML串口助手

QT5.14 QML串口助手

基于 QML的 串口调试助手 这个代码有缺失&#xff0c;补了部分代码 ASCII HEX 工程共享&#xff0c; Qt版本 5.14.1 COM_QML 通过百度网盘分享的文件&#xff1a;COM_QML.zip 链接&#xff1a;https://pan.baidu.com/s/1MH2d6gIPDSoaX-syVWZsww?pwd5tge 提取码&#xff1a;…
阅读更多...
IOS ARKit进行图像识别

IOS ARKit进行图像识别

先讲一下基础控涧&#xff0c;资源的话可以留言&#xff0c;抽空我把它传到GitHub上&#xff0c;这里没写收积分&#xff0c;竟然充值才能下载&#xff0c;我下载也要充值&#xff0c;牛&#xff01; ARSCNView 可以理解画布或者场景 1 配置 ARWorldTrackingConfiguration AR追…
阅读更多...
常用排查工具使用

常用排查工具使用

1.spy++ Microsoft Spy++是一个非常好的查看Windows操作系统的窗口、消息、进程、线程信息的工具，简单易用，功能强大。 在vs的工具中默认安装，还可以监控到隐层窗口，通过查看窗口的属性可以获得更多信息，包括规格、窗口、类、进程等信息，可以帮助排查相关窗口的问题。 2…
阅读更多...
“Encrypt”属性设置为“true”且 “trustServerCertificate”属性设置为“false”，但驱动程序无法使用安全套接字层 (SSL) 加密与 SQL Server 建立安全

“Encrypt”属性设置为“true”且 “trustServerCertificate”属性设置为“false”，但驱动程序无法使用安全套接字层 (SSL) 加密与 SQL Server 建立安全

com.microsoft.sqlserver.jdbc.SQLServerException: “Encrypt”属性设置为“true”且 “trustServerCertificate”属性设置为“false”&#xff0c;但驱动程序无法使用安全套接字层 (SSL) 加密与 SQL Server 建立安全连接:错误:PKIX path building failed: sun.security.provi…
阅读更多...
【RK3588 Linux 5.x 内核编程】-内核高分辨率定时器

【RK3588 Linux 5.x 内核编程】-内核高分辨率定时器

内核高分辨率定时器 文章目录 内核高分辨率定时器1、高分辨率定时器介绍2、高分辨率定时器API2.1 初始化定时器2.2 启动定时器2.3 停止定时器2.4 改变定时器超时时间2.5 定时器状态检查3、驱动实现4、驱动验证在前面的文章中，我们知道了如果在Linux内核中使用定时器。本文将详…
阅读更多...
最新文章

Copyright @ 2022~2023