java后端远程调用文件上传接口(multipart/form-data类型)的方法

multipart/form-data是一种用作传输多个文件/表单项的数据格式。

一、http请求配置

/*** HttpClientConfig http请求配置*/
public class HttpClientConfig {/*** 连接时间 ms*/protected int CONNECT_TIMING_OUT = 300000;/*** 请求响应时间 ms*/protected int RESPONSE_TIMING_OUT = 300000;/*** 发起请求时间 ms*/protected int REQUEST_TIMING_OUT = 300000;public HttpClientConfig(int CONNECT_TIMING_OUT, int RESPONSE_TIMING_OUT, int REQUEST_TIMING_OUT) {this.CONNECT_TIMING_OUT = CONNECT_TIMING_OUT;this.RESPONSE_TIMING_OUT = RESPONSE_TIMING_OUT;this.REQUEST_TIMING_OUT = REQUEST_TIMING_OUT;}public HttpClientConfig(){}public static HttpClientConfig defaultConfig(){return new HttpClientConfig();}public int getCONNECT_TIMING_OUT() {return CONNECT_TIMING_OUT;}public void setCONNECT_TIMING_OUT(int CONNECT_TIMING_OUT) {this.CONNECT_TIMING_OUT = CONNECT_TIMING_OUT;}public int getRESPONSE_TIMING_OUT() {return RESPONSE_TIMING_OUT;}public void setRESPONSE_TIMING_OUT(int RESPONSE_TIMING_OUT) {this.RESPONSE_TIMING_OUT = RESPONSE_TIMING_OUT;}public int getREQUEST_TIMING_OUT() {return REQUEST_TIMING_OUT;}public void setREQUEST_TIMING_OUT(int REQUEST_TIMING_OUT) {this.REQUEST_TIMING_OUT = REQUEST_TIMING_OUT;}
}

二、http请求工具类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import org.apache.http.HttpEntity;
import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.config.RequestConfig;
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.client.methods.HttpPut;
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
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.HttpClientBuilder;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;import javax.net.ssl.*;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;public class HttpClientUtil {private static Logger LOGGER = LoggerFactory.getLogger(HttpClientUtil.class);private static final String DEFAULT_CHARSET_UTF8 = "UTF-8";private static final String DEFAULT_CONTENT_TYPE_JSON = "application/json";/*** @param url    请求路径* @param params 请求参数* @return* @throws Exception*/public static String get(String url, Map<String, Object> params, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));if (params != null) {StringBuilder sb = new StringBuilder();for (Map.Entry<String, Object> entry : params.entrySet()) {sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());}if (sb.length() > 0) {if (url.indexOf("?") > -1) {url = url + sb.toString();} else {sb.delete(0, 1);url = url + "?" + sb.toString();}}}HttpGet httpGet = new HttpGet(url);
//            httpGet.addHeader("Content-Type", "application/json");
//            httpGet.addHeader("User-Agent", name);HttpResponse httpResponse = httpClient.execute(httpGet);HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** @param url    请求路径* @param params 请求参数* @return* @throws Exception*/public static InputStream getFile(InputStream inputStream,String url, Map<String, Object> params, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));if (params != null) {StringBuilder sb = new StringBuilder();for (Map.Entry<String, Object> entry : params.entrySet()) {sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());}if (sb.length() > 0) {if (url.indexOf("?") > -1) {url = url + sb.toString();} else {sb.delete(0, 1);url = url + "?" + sb.toString();}}}HttpGet httpGet = new HttpGet(url);
//            httpGet.addHeader("Content-Type", "application/json");
//            httpGet.addHeader("User-Agent", name);HttpResponse httpResponse = httpClient.execute(httpGet);HttpEntity httpEntity = httpResponse.getEntity();inputStream = httpResponse.getEntity().getContent();
//            return EntityUtils.toString(httpEntity, "UTF-8")return inputStream;} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {
//            if (httpClient != null) {
//                try {
                    httpClient.close();
//                } catch (IOException e) {
                    throw new Exception(e.getMessage(), e);
//                }
//            }}}/*** @param url    请求路径* @param params 请求参数* @return* @throws Exception*/public static String getForHeader(String url, Map<String, Object> params, Map<String, String> headerParam, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));if (params != null) {StringBuilder sb = new StringBuilder();for (Map.Entry<String, Object> entry : params.entrySet()) {sb.append("&").append(entry.getKey()).append("=").append(entry.getValue());}if (sb.length() > 0) {if (url.indexOf("?") > -1) {url = url + sb.toString();} else {sb.delete(0, 1);url = url + "?" + sb.toString();}}}HttpGet httpGet = new HttpGet(url);//header参数if (headerParam != null && headerParam.size() > 0) {for (String key : headerParam.keySet()) {httpGet.addHeader(key, headerParam.get(key));}}
//            httpGet.addHeader("Content-Type", "application/json");
//            httpGet.addHeader("User-Agent", name);HttpResponse httpResponse = httpClient.execute(httpGet);HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** @param url    请求路径* @param params 请求参数* @return*/public static String post(String url, Map<String, Object> params, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPost httpPost = new HttpPost(url);if (params != null && params.size() > 0) {List<NameValuePair> pairs = new ArrayList<>();for (Map.Entry<String, Object> entry : params.entrySet()) {NameValuePair pair = new BasicNameValuePair(entry.getKey(), String.valueOf(entry.getValue()));pairs.add(pair);}HttpEntity httpEntity = new UrlEncodedFormEntity(pairs, "UTF-8");httpPost.setEntity(httpEntity);}HttpResponse httpResponse = httpClient.execute(httpPost);if (httpResponse.getStatusLine().getStatusCode() < 400) {HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode() + "," + httpResponse.getEntity().toString());}} catch (Exception e) {throw e;} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** 参数JSON格式 Post** @param url 请求路径* @return*/public static String jsonPost(String url, Object paramVO, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;String result = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPost httpPost = new HttpPost(url);
//            System.out.println("请求参数："+JSON.toJSONString(paramVO));
//            LOGGER.info("请求参数："+ JSON.toJSONString(paramVO));StringEntity requestEntity = new StringEntity(JSON.toJSONString(paramVO), "UTF-8");requestEntity.setContentType("application/json");httpPost.setEntity(requestEntity);CloseableHttpResponse httpResponse = httpClient.execute(httpPost);HttpEntity httpEntity = httpResponse.getEntity();result = EntityUtils.toString(httpEntity, "UTF-8");EntityUtils.consume(httpEntity);if (httpResponse.getStatusLine().getStatusCode() < 400) {return result;} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode() + "," + result);}} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** 参数JSON格式 Post，带header的** @param url 请求路径* @return*/public static String jsonPostHeader(String url, Object paramVO,Map<String, String> headerParam, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;String result = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPost httpPost = new HttpPost(url);//header参数if (headerParam != null && headerParam.size() > 0) {for (String key : headerParam.keySet()) {httpPost.addHeader(key, headerParam.get(key));}}
//            LOGGER.info("请求参数："+ JSON.toJSONString(paramVO));StringEntity requestEntity = new StringEntity(JSON.toJSONString(paramVO), "UTF-8");requestEntity.setContentType("application/json");httpPost.setEntity(requestEntity);CloseableHttpResponse httpResponse = httpClient.execute(httpPost);HttpEntity httpEntity = httpResponse.getEntity();result = EntityUtils.toString(httpEntity, "UTF-8");EntityUtils.consume(httpEntity);if (httpResponse.getStatusLine().getStatusCode() < 400) {return result;} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode() + "," + result);}} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** @param url    请求路径* @param params 请求参数* @return*/public static String put(String url, Map<String, Object> params, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPut httpPut = new HttpPut(url);if (params != null && params.size() > 0) {List<NameValuePair> pairs = new ArrayList<>();for (Map.Entry<String, Object> entry : params.entrySet()) {NameValuePair pair = new BasicNameValuePair(entry.getKey(), String.valueOf(entry.getValue()));pairs.add(pair);}HttpEntity httpEntity = new UrlEncodedFormEntity(pairs, "UTF-8");httpPut.setEntity(httpEntity);}HttpResponse httpResponse = httpClient.execute(httpPut);if (httpResponse.getStatusLine().getStatusCode() < 400) {HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode());}} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** put带请求头* @return*/public static String putForHeader(String url, Object paramVO, Map<String, String> headerParam, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPut httpPut = new HttpPut(url);//header参数if (headerParam != null && headerParam.size() > 0) {LOGGER.info("put请求Header：" + JSON.toJSONString(headerParam));for (String key : headerParam.keySet()) {httpPut.addHeader(key, headerParam.get(key));}}LOGGER.info("请求参数："+ JSON.toJSONString(paramVO));StringEntity requestEntity = new StringEntity(JSON.toJSONString(paramVO), "UTF-8");requestEntity.setContentType("application/json");httpPut.setEntity(requestEntity);HttpResponse httpResponse = httpClient.execute(httpPut);if (httpResponse.getStatusLine().getStatusCode() < 400) {HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode());}} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** 发送带head的请求** @param url* @param headerParam* @param bodyParam* @param contentType* @param charSet* @return* @throws Exception*/public static String post(String url, Map<String, String> headerParam, Map<Object, Object> bodyParam, String contentType, String charSet, HttpClientConfig... configList) throws Exception {String content_type = contentType;if (content_type == null || "".equals(content_type)) content_type = DEFAULT_CONTENT_TYPE_JSON;String char_set = charSet;if (char_set == null || "".equals(char_set)) char_set = DEFAULT_CHARSET_UTF8;HttpPost httpPost = new HttpPost(url);//header参数if (headerParam != null && headerParam.size() > 0) {LOGGER.info("Post请求Header：" + JSON.toJSONString(headerParam));for (String key : headerParam.keySet()) {httpPost.addHeader(key, headerParam.get(key));}}//entity数据if (bodyParam != null) {//x-www-form-urlencoded类型if (ContentType.APPLICATION_FORM_URLENCODED.getMimeType().equals(contentType)) {if (bodyParam instanceof Map) {@SuppressWarnings("unchecked")Map<Object, Object> params = bodyParam;if (!CollectionUtils.isEmpty(params)) {List<NameValuePair> pairs = new ArrayList<>();for (Map.Entry<Object, Object> entry : params.entrySet()) {NameValuePair pair = new BasicNameValuePair(String.valueOf(entry.getKey()), String.valueOf(entry.getValue()));pairs.add(pair);}HttpEntity httpEntity = new UrlEncodedFormEntity(pairs, "UTF-8");httpPost.setEntity(httpEntity);LOGGER.info("post请求body：" + httpEntity.toString());}}} else {//json或其他类型LOGGER.info("Post请求Body：" + JSON.toJSONString(bodyParam));StringEntity entity = new StringEntity(JSON.toJSONString(bodyParam), char_set);entity.setContentEncoding(char_set);entity.setContentType(content_type);httpPost.setEntity(entity);}}String resultStr = "";CloseableHttpResponse response = null;try {response = createClient(url, getHttpConfig(configList)).execute(httpPost);resultStr = EntityUtils.toString(response.getEntity(), char_set);} catch (IOException e) {e.printStackTrace();} finally {try {response.close();httpPost.releaseConnection();} catch (IOException e) {e.printStackTrace();}}LOGGER.info("Post请求返回：" + resultStr);return resultStr;}/*** 发送Gzip压缩请求** @param sendurl* @param bytes* @param headMap* @return* @throws Exception*/public static byte[] postGzip(String sendurl, byte[] bytes, Map<String, String> headMap, HttpClientConfig... configList) throws Exception {HttpClientConfig httpClientConfig = getHttpConfig(configList);HttpURLConnection con = null;ByteArrayOutputStream baos = null;GZIPInputStream reader = null;GZIPOutputStream zip = null;try {con = getConnection(sendurl);if (headMap != null) {for (Map.Entry<String, String> en : headMap.entrySet()) {con.setRequestProperty(en.getKey(), en.getValue());}}con.setConnectTimeout(httpClientConfig.CONNECT_TIMING_OUT);con.setReadTimeout(httpClientConfig.RESPONSE_TIMING_OUT);con.setDoInput(true);con.setDoOutput(true);con.setAllowUserInteraction(true);con.setUseCaches(false);con.setRequestMethod("POST");con.setRequestProperty("Content-type", "application/gzip");zip = new GZIPOutputStream(con.getOutputStream());zip.write(bytes);zip.flush();zip.close();reader = new GZIPInputStream(con.getInputStream());baos = new ByteArrayOutputStream();byte[] buffer = new byte[4096];int len = -1;while ((len = reader.read(buffer)) != -1) {baos.write(buffer, 0, len);}con.disconnect();baos.close();return baos.toByteArray();} catch (Exception e) {LOGGER.error("GzipPost:{}, 出现异常，error: {}", sendurl, e.getMessage());throw new RuntimeException("请求异常：" + e.getMessage());} finally {if (reader != null) {reader.close();}if (zip != null) {zip.close();}if (baos != null) {baos.close();}if (con != null) {con.disconnect();}}}public static String post2(String url, Map<String, Object> params,String contentType ,HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPost httpPost = new HttpPost(url);if (params != null && params.size() > 0) {List<NameValuePair> pairs = new ArrayList<>();for (Map.Entry<String, Object> entry : params.entrySet()) {NameValuePair pair = new BasicNameValuePair(entry.getKey(), String.valueOf(entry.getValue()));pairs.add(pair);}HttpEntity httpEntity = new UrlEncodedFormEntity(pairs, "UTF-8");
//                requestEntity.setContentType("application/json");httpPost.setEntity(httpEntity);}HttpResponse httpResponse = httpClient.execute(httpPost);if (httpResponse.getStatusLine().getStatusCode() < 400) {HttpEntity httpEntity = httpResponse.getEntity();return EntityUtils.toString(httpEntity, "UTF-8");} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode() + "," + httpResponse.getEntity().toString());}} catch (Exception e) {throw e;} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}/*** 参数对象 格式 Post，带header的** @param url 请求路径* @return*/public static String postHeader(String url, JSONArray paramVO, Map<String, String> headerParam, HttpClientConfig... configList) throws Exception {CloseableHttpClient httpClient = null;String result = null;try {httpClient = createClient(url, getHttpConfig(configList));HttpPost httpPost = new HttpPost(url);//header参数if (headerParam != null && headerParam.size() > 0) {for (String key : headerParam.keySet()) {httpPost.addHeader(key, headerParam.get(key));}}LOGGER.info("请求参数："+ JSON.toJSONString(paramVO));StringEntity requestEntity = new StringEntity(JSON.toJSONString(paramVO), "UTF-8");requestEntity.setContentType("application/json");httpPost.setEntity(requestEntity);CloseableHttpResponse httpResponse = httpClient.execute(httpPost);HttpEntity httpEntity = httpResponse.getEntity();result = EntityUtils.toString(httpEntity, "UTF-8");EntityUtils.consume(httpEntity);if (httpResponse.getStatusLine().getStatusCode() < 400) {return result;} else {throw new Exception("http请求错误：" + httpResponse.getStatusLine().getStatusCode() + "," + result);}} catch (Exception e) {throw new Exception(e.getMessage(), e);} finally {if (httpClient != null) {try {httpClient.close();} catch (IOException e) {throw new Exception(e.getMessage(), e);}}}}private static CloseableHttpClient createHttpsClient(HttpClientConfig config) throws Exception {X509TrustManager xtm = new X509TrustManager() {@Overridepublic X509Certificate[] getAcceptedIssuers() {return new X509Certificate[]{};}@Overridepublic void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {}@Overridepublic void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {}};SSLContext ctx = SSLContext.getInstance("SSL");ctx.init(null, new TrustManager[]{xtm}, null);SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(ctx, new HostnameVerifier() {@Overridepublic boolean verify(String hostname, SSLSession session) {return true;}});RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(config.CONNECT_TIMING_OUT).setConnectionRequestTimeout(config.REQUEST_TIMING_OUT).setSocketTimeout(config.RESPONSE_TIMING_OUT).build();CloseableHttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).setSSLSocketFactory(sslsf).build();return httpClient;}private static CloseableHttpClient createHttpClient(HttpClientConfig config) {RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(config.CONNECT_TIMING_OUT).setConnectionRequestTimeout(config.REQUEST_TIMING_OUT)//.setProxy(new HttpHost("xxx.xx.xx.xxx", xxxx)).setSocketTimeout(config.RESPONSE_TIMING_OUT).build();CloseableHttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build();return httpClient;}public static CloseableHttpClient createHttpClientPublic(HttpClientConfig config) {RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(config.CONNECT_TIMING_OUT).setConnectionRequestTimeout(config.REQUEST_TIMING_OUT)//.setProxy(new HttpHost("xxx.xx.xx.xxx", xxxx)).setSocketTimeout(config.RESPONSE_TIMING_OUT).build();CloseableHttpClient httpClient = HttpClientBuilder.create().setDefaultRequestConfig(requestConfig).build();return httpClient;}private static CloseableHttpClient createClient(String url, HttpClientConfig config) throws Exception {if (url.startsWith("https")) {    //https请求return createHttpsClient(config);} else {    //http请求return createHttpClient(config);}}private static HttpURLConnection getConnection(String reqUrl) throws Exception {if (reqUrl.startsWith("https")) {return getHttpsConnection(reqUrl);} else {return getHttpConnection(reqUrl);}}private static HttpURLConnection getHttpsConnection(String reqUrl) throws IOException, KeyManagementException, NoSuchAlgorithmException {SSLContext sc = SSLContext.getInstance("SSL");sc.init(null, new TrustManager[]{new TrustAnyTrustManager()}, new java.security.SecureRandom());URL url = new URL(reqUrl);HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();conn.setSSLSocketFactory(sc.getSocketFactory());conn.setHostnameVerifier(new TrustAnyHostnameVerifier());return conn;}private static HttpURLConnection getHttpConnection(String reqUrl) throws IOException {URL url = new URL(reqUrl);HttpURLConnection conn = (HttpURLConnection) url.openConnection();return conn;}private static class TrustAnyTrustManager implements X509TrustManager {public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {}public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {}public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[]{};}}private static class TrustAnyHostnameVerifier implements HostnameVerifier {public boolean verify(String hostname, SSLSession session) {return true;}}private static HttpClientConfig getHttpConfig(HttpClientConfig[] configList) {if (ObjectUtils.isEmpty(configList)) {return HttpClientConfig.defaultConfig();}return configList[0];}
}

三、封装真正的调用方法

前面的一和二都是为了让http请求高可用，这里是真正的发起请求的方法封装：

import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.HttpMultipartMode;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.util.ObjectUtils;import java.nio.charset.Charset;public class PostFileMutipartTools {public static String postFileMultiPart(String url, byte[] bt, String fileName, String baseName) throws Exception {// 创建一个Multipart请求实例HttpPost postRequest = new HttpPost(url);MultipartEntityBuilder builder = MultipartEntityBuilder.create().setMode(HttpMultipartMode.RFC6532);builder.addBinaryBody("files", bt, ContentType.DEFAULT_BINARY, fileName);/*StringBody contentBody = new StringBody(jsonContent,ContentType.APPLICATION_JSON);builder.addPart("data", contentBody);*/ContentType contentType = ContentType.create("text/plain", Charset.forName("UTF-8"));builder.addTextBody("knowledge_base_name", baseName, contentType);// 将请求实体设置到请求中postRequest.setEntity(builder.build());// 创建一个HttpClient实例//CloseableHttpClient httpClient = HttpClients.createDefault();CloseableHttpClient httpClient = HttpClientUtil.createHttpClientPublic(getHttpConfig(null));// 发送请求并获取响应CloseableHttpResponse response = httpClient.execute(postRequest);try {// 获取响应实体HttpEntity responseEntity = response.getEntity();if (responseEntity != null) {// 处理响应实体String responseString = EntityUtils.toString(responseEntity);System.out.println(responseString);return responseString;}} finally {// 关闭响应和HttpClient实例response.close();httpClient.close();}return null;}private static HttpClientConfig getHttpConfig(HttpClientConfig[] configList) {if (ObjectUtils.isEmpty(configList)) {return HttpClientConfig.defaultConfig();}return configList[0];}
}

四、调用例子

//先去文件中心把文件内容拿出来byte[] byteArray = xxx.Download(dto.getFileId(), CommonConsts.USER_AGENT_DOWNLOAD);//logger.info(Arrays.toString(byteArray));//远程上传文件String result = null;try {result = PostFileMutipartTools.postFileMultiPart(xxxBaseUrl + "xxx/xx", byteArray, dto.getFileName(), dto.getBelongTo());} catch (Exception e) {e.printStackTrace();}if(result !=null) {JSONObject jsonObject = JSONObject.parseObject(result);String code = jsonObject.getString("code");if(Objects.equals(code,"200")) {//远程上传文件成功，更新本地库表数据删除状态}}....

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

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

相关文章

【图形学】双三次贝塞尔曲线绘制方法

【图形学】双三次贝塞尔曲线绘制方法

双三次贝塞尔曲线的定义 双三次贝塞尔曲面是由16个控制点定义的曲面&#xff0c;通常表示为4x4矩阵。 曲面的公式如下&#xff1a; p ( u , v ) ∑ i 0 3 ∑ j 0 3 P i , j B i , 3 ( u ) B j , 3 ( v ) , ( u , v ) ∈ [ 0 , 1 ] [ 0 , 1 ] p(u,v)\sum_{i0}^3\sum_{j0}…
阅读更多...
【程序员英语】【美语从头学】初级篇（入门）（笔记）Lesson10（电话会话Ⅱ）

【程序员英语】【美语从头学】初级篇（入门）（笔记）Lesson10（电话会话Ⅱ）

《美语从头学初级入门篇》 注意&#xff1a;被 删除线 划掉的不一定不正确&#xff0c;只是不是标准答案。 文章目录 Lesson 10 Telephone Conversation Ⅱ 电话会话&#xff08;二&#xff09;会话A会话B笔记I would like to do&#xff08;Id like to to do&#xff09;我想…
阅读更多...
如何从视频号中提取视频的文案？抖音文案也可提取

如何从视频号中提取视频的文案？抖音文案也可提取

最近不少小伙伴刷抖音看看视频一个一个的进行抄&#xff0c;太慢了。​今天分享一个工具搞定怎么提取视频文案的方法&#xff01; 提取文案小助手 提取文案小助手是专注视频创作者的利器&#xff0c;帮助用户一键提取视频号中的文案&#xff0c;获取的方式比较简单&#xff0c…
阅读更多...
知过去，预未来，相信AI计算的力量

知过去，预未来，相信AI计算的力量

过去几十年来&#xff0c;人工智能&#xff08;AI&#xff09;领域取得了巨大的进展&#xff0c;从最初的概念逐渐演变为影响各个行业的核心技术。回顾过去&#xff0c;我们可以看到AI计算在推动科技创新和社会变革方面的无可比拟的力量。而更为令人振奋的是&#xff0c;这种力…
阅读更多...
Sui TVL跻身全链前十名｜全面详解Sui原生功能如何促使DeFi蓬勃发展

Sui TVL跻身全链前十名｜全面详解Sui原生功能如何促使DeFi蓬勃发展

根据DefiLlama数据显示&#xff0c;1月28日Sui TVL超过4.02亿美元&#xff0c;跻身所有区块链TVL前十名&#xff01; Sui的创新应用原生功能为DeFi应用铺平了道路&#xff0c;为用户提供了良好的体验。每个原生功能&#xff0c;从促进高效的共享流动性到简化用户互动&#xff0…
阅读更多...
js中contextmenu、click和mousedown的区别在哪？

js中contextmenu、click和mousedown的区别在哪？

contextmenu、click和mousedown的定义 contextmenu&#xff1a;在鼠标右键点击时触发。可以在此事件中执行特定的操作&#xff0c;比如显示自定义的右键菜单或者阻止浏览器默认的上下文菜单弹窗。它是为了满足特定场景下对右键点击的定制化处理需求。 click事件是通用的鼠标点…
阅读更多...
印章制作办法

印章制作办法

印章制作办法&#xff1a; 最近在做单位技术支持的培训&#xff0c;需要增加个培训章&#xff0c;自己内容完成即可。 一、excel表格中 &#xff0c;插入-形状-圆&#xff08;按住shift按键&#xff09; 操作三步&#xff1a; 1.填充 无 &#xff1a; 2.形状轮廓 ---“红色…
阅读更多...
Linux之常见的管理命令

Linux之常见的管理命令

目录 1. whoami 2. hostname 3. uname 4. date 5. alias 6. history 7. sudo 8. systemctl 9. ps 1. whoami 作用&#xff1a; 显示出当前有效的用户名称语法&#xff1a;whoami(选项)选项&#xff1a; --help&#xff1a;在线帮助--version&#xff1a;显示版本信息…
阅读更多...
CF1920F1 Smooth Sailing (Easy Version) 题解

CF1920F1 Smooth Sailing (Easy Version) 题解

魔幻暴力题。 题意简述 给你一张 n m n\times m nm 的地图&#xff0c;每个点是海 .&#xff0c;岛屿 # 或者火山 v。保证岛屿和非岛屿均可以形成恰好一个四连通块且岛屿不与地图边界接壤&#xff0c;至少有一个岛屿点与一个火山点。 定义一条合法的路径为&#xff0c;从一…
阅读更多...
代码随想录算法训练营day15|104.二叉树的最大深度、111.二叉树的最小深度、222.完全二叉树的节点个数

代码随想录算法训练营day15|104.二叉树的最大深度、111.二叉树的最小深度、222.完全二叉树的节点个数

104.二叉树的最大深度 559.n叉树的最大深度 111.二叉树的最小深度 222.完全二叉树的节点个数 104.二叉树的最大深度 &#xff08;优先掌握递归&#xff09; 什么是深度&#xff0c;什么是高度&#xff0c;如何求深度&#xff0c;如何求高度&#xff0c;这里有关系到二叉树的遍…
阅读更多...
MPNN、GCN、DenseNet blocks之间的关系，GNN中“层”是什么意思？

MPNN、GCN、DenseNet blocks之间的关系，GNN中“层”是什么意思？

关于GCN的普及理解&#xff1a;简单粗暴带你快速理解GNN_哔哩哔哩_bilibili GNN中层是什么意思&#xff1f; GNN中的层的意思是每次消息传递一次就叫一个层&#xff0c;在图神经网络&#xff08;GNN&#xff09;中&#xff0c;每进行一次消息传递和更新操作通常被称为一个“…
阅读更多...
数据结构—栈实现后缀表达式的计算

数据结构—栈实现后缀表达式的计算

后缀表达式计算 过程分析 中缀表达式 &#xff08;15&#xff09;*3 > 后缀表达式 153* (可参考这篇文章&#xff1a;中缀转后缀) 第一步&#xff1a;我们从左至右扫描 后缀表达式(已经存放在一个字符数组中)&#xff0c;遇到第一个数字字符 ‘1’ 放入栈中第二步&#xf…
阅读更多...
幻兽帕鲁服务器出租，腾讯云PK阿里云怎么收费？

幻兽帕鲁服务器出租，腾讯云PK阿里云怎么收费？

幻兽帕鲁服务器价格多少钱&#xff1f;4核16G服务器Palworld官方推荐配置&#xff0c;阿里云4核16G服务器32元1个月、96元3个月&#xff0c;腾讯云换手帕服务器服务器4核16G14M带宽66元一个月、277元3个月&#xff0c;8核32G22M配置115元1个月、345元3个月&#xff0c;16核64G3…
阅读更多...
存储技术架构演进

存储技术架构演进

一. 演进过程 存储技术架构的演进主要是从集中式到分布式的一种呈现&#xff0c;集中式存储模式凭借其在稳定性和可靠性方面的优势成为许多业务数据库的数据存储首选&#xff0c;顾名思义&#xff0c;集中式存储主要体现在集中性&#xff0c;一套集中式管理的存储系统&#xff…
阅读更多...
python：socket基础操作（4）-《tcp客户端基础》

python：socket基础操作（4）-《tcp客户端基础》

tcp就和udp不一样了&#xff0c;tcp是客户端和服务器端&#xff0c;如果想通过tcp发送数据&#xff0c;要先让tcp进行连接服务器端 tcp客户端 先让服务器端进行启动 import socketdef main():# 创建套接字tcp_client_socket socket.socket(socket.AF_INET,socket.SOCK_STREAM…
阅读更多...
RSTP的P/A机制

RSTP的P/A机制

如图所示根桥S1和S2之间新添加了一条链路，在当前状态下S2的另外几个端口p2是Alternate端口，p3是指定端口且处于Forwarding状态，p4是边缘端口。新链路连接成功后，P/A机制协商过程如下。 1．P0和P1两个端口马上都先成为指定端口发送RS TBPDU。 2．S2的P1口收到更优的RST BPD…
阅读更多...
Google Chrome 中出现 ERR_SSL_KEY_USAGE_INCOMPATIBLE 错误

Google Chrome 中出现 ERR_SSL_KEY_USAGE_INCOMPATIBLE 错误

证书的方式发生了变化&#xff0c;出现了这个新错误&#xff0c;导致我无法浏览该网站。 可以右键属性获取位置 关闭导航器chrome并转到文件夹&#xff0c;找到Local State文件并删除 执行指令结束进程&#xff0c;重新打开浏览器即可 taskkill /im "chrome.exe"…
阅读更多...
Qt程序设计-自动关闭对话框的实现

Qt程序设计-自动关闭对话框的实现

本文讲解如何实现Qt自动关闭对话框。 创建项目，添加按钮 添加资源文件。 添加QDialog，该名称为WaitDialog。 头文件 #ifndef WAITDIALOG_H #define WAITDIALOG_H#include <QDialog>#include <QTimer> enum WaitDialogType {Unknown =0,Err =1,//警告Ok =2//…
阅读更多...
fastapi报错

fastapi报错

初始化报错&#xff0c;非常低级错&#xff0c;扇自己10八张 app FastApi()
阅读更多...
sqli.labs靶场（第18~22关）

sqli.labs靶场（第18~22关）

18、第十八关 经过测试发现User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:122.0) Gecko/20100101 Firefox/122.0加引号报错 这里我们闭合一下试试 User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:122.0) Gecko/20100101 Firefox/122.0,127.0.0.1,adm…
阅读更多...
最新文章

Copyright @ 2022~2023