restful zip请求直接解析和下载

package com.example.demo.controller; import org.apache.http.HttpResponse; import org.apache.http.NameValuePair; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.HttpClient; import org.apache.http.client.entity.UrlEncodedFormEntity; import org.apache.http.client.methods.HttpDelete; import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpPost; import org.apache.http.client.utils.URIBuilder; import org.apache.http.config.ConnectionConfig; import org.apache.http.config.Registry; import org.apache.http.config.RegistryBuilder; import org.apache.http.config.SocketConfig; import org.apache.http.conn.socket.ConnectionSocketFactory; import org.apache.http.conn.socket.LayeredConnectionSocketFactory; import org.apache.http.conn.socket.PlainConnectionSocketFactory; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.conn.ssl.SSLContexts; import org.apache.http.conn.ssl.TrustStrategy; import org.apache.http.cookie.Cookie; import org.apache.http.cookie.CookieOrigin; import org.apache.http.entity.StringEntity; import org.apache.http.entity.mime.FormBodyPart; import org.apache.http.entity.mime.HttpMultipartMode; import org.apache.http.entity.mime.MultipartEntityBuilder; import org.apache.http.impl.client.BasicCookieStore; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import org.apache.http.impl.cookie.BasicClientCookie; import org.apache.http.impl.cookie.BestMatchSpec; import org.apache.http.message.BasicNameValuePair; import org.apache.tomcat.util.http.fileupload.IOUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.net.ssl.SSLContext; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.URISyntaxException; import java.nio.charset.Charset; import java.security.KeyManagementException; import java.security.KeyStore; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.*; /** * Http帮助类，用于发送http请求 */ public class HttpHelper { private static final Logger log = LoggerFactory.getLogger(HttpHelper.class); private static final int bufferSize = 1024; private static final String defaultEncoding = "UTF-8"; private static volatile HttpHelper instance; /** * 单例方法 * * @return HttpHelper */ public static HttpHelper getInstance() { synchronized (HttpHelper.class) { if (HttpHelper.instance == null) { instance = new HttpHelper(); } return instance; } } /** * 重新创建新的单例方法 * * @return HttpHelper */ public static HttpHelper newInstance() { synchronized (HttpHelper.class) { HttpHelper.instance = new HttpHelper(); } return instance; } private volatile HttpClient client; private volatile BasicCookieStore cookieStore; private Map<String, String> headerParams = new HashMap<>(); public HttpHelper() { // 设置连接参数 ConnectionConfig connConfig = ConnectionConfig.custom().setCharset(Charset.forName(defaultEncoding)).build(); SocketConfig socketConfig = SocketConfig.custom().setSoTimeout(100000).build(); RegistryBuilder<ConnectionSocketFactory> registryBuilder = RegistryBuilder.create(); ConnectionSocketFactory plainSF = new PlainConnectionSocketFactory(); registryBuilder.register("http", plainSF); // 指定信任密钥存储对象和连接套接字工厂 try { KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType()); SSLContext sslContext = SSLContexts.custom().useTLS().loadTrustMaterial(trustStore, new AnyTrustStrategy()).build(); LayeredConnectionSocketFactory sslSF = new SSLConnectionSocketFactory(sslContext, SSLConnectionSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER); registryBuilder.register("https", sslSF); } catch (NoSuchAlgorithmException | KeyStoreException | KeyManagementException e) { throw new RuntimeException(e); } Registry<ConnectionSocketFactory> registry = registryBuilder.build(); // 设置连接管理器 PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(registry); connManager.setDefaultConnectionConfig(connConfig); connManager.setDefaultSocketConfig(socketConfig); // 指定cookie存储对象 cookieStore = new BasicCookieStore(); // 构建客户端 client = HttpClientBuilder.create().setDefaultCookieStore(cookieStore).setConnectionManager(connManager).build(); } public void setHeaderParam(String key, String value) { if (key != null && value != null) { headerParams.put(key, value); } } public void clearHeaderParams() { this.headerParams.clear(); } private static List<NameValuePair> paramsConverter(Map<String, String> params) { List<NameValuePair> nvps = new LinkedList<>(); Set<Map.Entry<String, String>> paramsSet = params.entrySet(); for (Map.Entry<String, String> paramEntry : paramsSet) { nvps.add(new BasicNameValuePair(paramEntry.getKey(), paramEntry.getValue())); } return nvps; } public static String readStream(InputStream in, String encoding) { if (in == null) { return null; } InputStreamReader inReader = null; try { if (encoding == null) { inReader = new InputStreamReader(in, defaultEncoding); } else { inReader = new InputStreamReader(in, encoding); } char[] buffer = new char[bufferSize]; int readLen; StringBuilder sb = new StringBuilder(); while ((readLen = inReader.read(buffer)) != -1) { sb.append(buffer, 0, readLen); } return sb.toString(); } catch (IOException e) { log.error(e.getMessage(), e); } finally { IOUtils.closeQuietly(inReader); } return null; } // ============================================================================================================== // ============================================ GET ============================================================= // ============================================================================================================== public InputStream doGet(String url) throws URISyntaxException, ClientProtocolException, IOException { HttpResponse response = this.doGet(url, null); return response != null ? response.getEntity().getContent() : null; } public HttpResponse doGet(String url, Map<String, String> queryParams) throws URISyntaxException, ClientProtocolException, IOException { HttpGet gm = new HttpGet(); URIBuilder builder = new URIBuilder(url); //填入查询参数 if (queryParams != null && !queryParams.isEmpty()) { builder.setParameters(HttpHelper.paramsConverter(queryParams)); } // header if (this.headerParams != null && this.headerParams.size() > 0) { for (String key : this.headerParams.keySet()) { gm.setHeader(key, this.headerParams.get(key)); } } gm.setURI(builder.build()); return client.execute(gm); } public String doGetForString(String url) throws URISyntaxException, ClientProtocolException, IOException { return HttpHelper.readStream(this.doGet(url), null); } public InputStream doGetForStream(String url, Map<String, String