面向对象封装一个http工具

article - @houyu 2019/08/22 阅读: 1678 点赞: 1

> 作为一个爬虫业余爱好者， 网络编程是最基本的知识点，如果想玩爬虫，没有一个方便使用的网络请求工具类, 别谈什么爱好了, 业余都有点业余了, 为此, 我把我之前的一个工具类, 结合我对[面向对象]的理解封装了一下, 如果封装得不好, 有可能我对[面向对象], 有误解吧。
> ***
> python作为爬虫领域的语音佼佼者，其中有一个比较重要的原因就是有很多丰富简单调用的库， 比如在网络编程方面， urllib2以及requests, 以及在图表报表，语音分析等方面的第三方库也是有很多优秀的第三方库的。

* 那么使用java进行网络请求(这里指的是基于http协议)是不是很难呢？其实java也提供了一个比较原生的包【java.net.*】进行网络请求， 当然也可以使用其他的第三方包，比如HttpClient、OKHttp和Volley

* 但是我个人比较倾向于HttpURLConnection， 一种多用途、轻量极的HTTP客户端，使用它来进行HTTP操作可以适用于大多数的应用程序。虽然HttpURLConnection的API提供的比较简单，但是同时这也使得我们可以更加容易地去使用和扩展它。

> 接下来我们就来看看没有封装和封装的差异在哪吧

### util形式的封装(参数过多, 使用不方便, 不易于重构等问题)
```java
// 封装的方法
/**
 * POST请求
 * @param urlString url
 * @param requestHeader 请求头参数
 * @param requestBody 请求体
 * @param requestBodyType POST请求体类型  : 
 *  <br>    1:HttpUtils.PostType.FORM_DATA
 *  <br>    2:HttpUtils.PostType.JSON_DATA (tip:最简单的方式 >> requestBody.put("SEND_DATA",JSONString))
 * @param requestBodyCharset 请求体编码
 * @param htmlCharset 网页编码
 * @param connectionType 连接类型 : 
 *  <br>    1:HttpUtils.ConnectionType.HTTP_URL_CONNECTION
 *  <br>    2:HttpUtils.ConnectionType.HTTP_CLIENT
 * @param proxy 代理对象 : HttpUtils.get().setProxy(host, port, useName, password)
 * @return
 */
public String doPost(String urlString, Map<String, Object> requestHeader, Map<String, Object> requestBody, int requestBodyType, String requestBodyCharset, String htmlCharset, int connectionType, Proxy proxy) {
	// ...
}
    
// 调用者
String url = "https://www.baidu.com";
//
Map<String, Object> header = new HashMap(8);
header.put("Accept-Encoding", "gzip, deflate, br");
header.put("Referer", "https://www.baidu.com");
header.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Safari/537.36 Core/1.70.3722.400 QQBrowser/10.5.3771.400");
header.put("Accept", "text/javascript, application/javascript, application/ecmascript, application/x-ecmascript, */*; q=0.01");
//
String htmlCharset = "UTF-8";
//
Map<String, Object> body = new HashMap(8);
body.put("Accept-Encoding", "gzip, deflate, br");
body.put("Referer", "https://www.baidu.com");
body.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Safari/537.36 Core/1.70.3722.400 QQBrowser/10.5.3771.400");
body.put("Accept", "text/javascript, application/javascript, application/ecmascript, application/x-ecmascript, */*; q=0.01");
// 
// requestBodyCharset, 
// String htmlCharset, 
// int connectionType, 
// Proxy proxy

doPost(url, header,body ,HttpUtils.PostType.FORM_DATA, ......);

```

### 基于面向对象简单封装一下(支持默认值, 支持链式编程等, 好处多多...)
下面就是简单使用的一个demo
```java
String body = HttpUtil.builder("https://www.baidu.com")
                .addHead("Referer", "https://www.baidu.com")// 添加头信息
                .addHead("User-Agent", "Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/70.0.3538.25 Safari/537.36 Core/1.70.3722.400 QQBrowser/10.5.3771.400")//
                .execute()// 执行请求
                .getBodyString();// 获取响应
```
是不是一下子感觉很舒服?

#### 这个工具类我花了好长时间整理出来的, 是我一直以来的xxx.xxx.xxx.util.http包啊[捂脸]
封装的过程中借鉴了很多优秀文章, debug了不少源码
* hutool
* https://github.com/guozhengXia/UrlHttpUtils.
...

#### 封装了这个这个工具类那么辛苦都有些什么骚操作呢?
* 原生 / 无依赖 / 超轻量
* 8级重定向(理论可以无限极)
* 重定向url记录
* 甜品链式调用(就好像吃甜品一样, 甜甜的,很舒服)
* 高效率请求(和网站以及自己网络有关, 我试过200个请求https://www.sogou.com/ 平均21ms一个请求, 速度超级快)
* 可设置代理(主要用于爬虫)
* 自动识别html响应编码(可以手动设置)
* 自动补全url(比如:baidu.com => http://baidu.com)
* api调用极其简单
* cookie管理(主要用于爬虫以及登录等操作)
* 支持restful接口请求
* 信任所有https站点(只要该站点不需要双向证书, 你都可以很愉快的玩, 也保留参数hostnameVerifier sslSocketFactory进行设置)
* 所有的操作都是低加载
* 一个类走天下, 封装对象都是static类, 总代码量一个900+行, 其中也是用了一些奇技淫巧的骚操作。

#### 主要有以下几个类

```java
/**
 * @description 请求对象
 * @date 2018-08-18 10:10:13
 * @author houyu for.houyu@foxmail.com
 */
public static class Request {}

/**
 * @description 响应对象
 * @date 2018-08-18 10:10:13
 * @author houyu for.houyu@foxmail.com
 */
public static class Response {}

/**
 * @description 代理对象
 * @date 2018-08-18 10:10:13
 * @author houyu for.houyu@foxmail.com
 */
public static class Proxy {}

/**
 * @description 请求方法
 * @date 2018-08-18 10:10:13
 * @author houyu for.houyu@foxmail.com
 */
public enum Method {GET, POST, PUT, DELETE}

/**
 * @description 常量
 * @date 2018-08-18 10:10:13
 * @author houyu for.houyu@foxmail.com
 */
public interface Constant {}

```

#### 主要API
请求API

![在这里插入图片描述](https://ihouyu.cn/view/image?src=https://img-blog.csdnimg.cn/20190822190603943.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ppbmdsb25nU291cmNl,size_16,color_FFFFFF,t_70)
响应API

![在这里插入图片描述](https://ihouyu.cn/view/image?src=https://img-blog.csdnimg.cn/20190822190632300.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ppbmdsb25nU291cmNl,size_16,color_FFFFFF,t_70)

#### 源码部分

```java
import java.io.ByteArrayOutputStream;
import java.io.Closeable;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.Base64;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.StringJoiner;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.zip.GZIPInputStream;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;

/**
 * @description: 网络请求工具类
 * @author: houyu for.houyu@foxmail.com
 * @create: 2018-08-18 09:10:13
 */
public class HttpURLConnectionUtil {

public static Request builder(String site) {
        return new Request(site);
    }

public static Request builderPost(String site) {
        return new Request(site).setMethod(Method.POST);
    }

public static boolean isEmpty(Object o) {
        return null == o || (o instanceof String && ((String) o).length() == 0);
    }

public static boolean nonEmpty(Object o) {
        return !isEmpty(o);
    }

/**
     * @description 请求对象
     * @date 2019-08-21 11:00:49
     * @author houyu for.houyu@foxmail.com
     */
    public static class Request {

private String site;                                // 请求网站地址
        private Method method = Method.GET;                 // 请求方法(默认是GET)
        private Map<String, Object> header;                 // 请求头
        private Map<String, Object> param;                  // 请求参数
        private Map<String, Object> extra;                  // 携带参数(可使用于响应之后的操作)
        private Proxy proxy;                                // 代理
        private String charset = Constant.UTF_8;            // 参数编码(默认UTF-8)
        private boolean ifEncodeUrl = false;                // 是否编码URL
        private boolean ifCache = false;                    // 是否缓存
        private String json;                                // JSON文本
        private int timeout = -1;                           // 连接超时(单位:毫秒)
        private String cookie;                              // 携带cookie(优先) ex: key1=val1; key2=val2
        private boolean ifStableRedirection = true;         // 是否稳定重定向
        private List<String> redirectUrlList;               // 重定向的url列表
        private HttpURLConnection http = null;              // HttpURLConnection对象
        private HostnameVerifier hostnameVerifier;          // 主机名验证程序
        private SSLSocketFactory sslSocketFactory;          // SocketFactory
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

private static Map<String, Object> DEFAULT_HEADER;  // 默认的请求头
        private static HostnameVerifier HOSTNAME_VERIFIER;  // 设置主机名验证程序
        private static SSLSocketFactory SSL_SOCKET_FACTORY; // SocketFactory

static {
            /** 初始化默认请求头 */
            DEFAULT_HEADER = new HashMap<>(8);
            DEFAULT_HEADER.put("Accept", "text/html,application/xhtml+xml,application/xml,application/json;q=0.9,*/*;q=0.8");
            DEFAULT_HEADER.put("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.84 Safari/537.36 Hutool");
            DEFAULT_HEADER.put("Accept-Encoding", "gzip");
            DEFAULT_HEADER.put("Accept-Language", "zh-CN,zh;q=0.8");
            // DEFAULT_HEADER.put("Content-Type", "application/x-www-form-urlencoded");
            //
            DEFAULT_HEADER = Collections.unmodifiableMap(DEFAULT_HEADER); // 设置不可以修改
            //
            /** 初始化全局主机名验证程序 */
            HOSTNAME_VERIFIER = (s, sslSession) -> true;
            /** 初始化全局主机名验证程序 */
            SSLContext sslContext = null;
            try {
                sslContext = SSLContext.getInstance("TLS");
                sslContext.init(null, new TrustManager[] {new X509TrustManager() {
                    @Override
                    public void checkClientTrusted(X509Certificate[] x509Certificates, String s) {
                    }

@Override
                    public void checkServerTrusted(X509Certificate[] x509Certificates, String s) {
                    }

@Override
                    public X509Certificate[] getAcceptedIssuers() {
                        return new X509Certificate[0];
                    }
                }}, new SecureRandom());
            } catch(NoSuchAlgorithmException | KeyManagementException e) {
                e.printStackTrace();
            }
            SSL_SOCKET_FACTORY = sslContext.getSocketFactory();
            //
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

public Request(String site) {
            this.site = site;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 执行 请求 */
        public Response execute() {
            // 初始化GET param
            this.handleGETParamWithUrl();
            // 初始化连接
            this.initConnection();
            // 发送数据包裹
            this.send();
            // 处理重定向
            boolean ifRedirect = this.handleRedirect();
            if(ifRedirect) {
                return this.execute();// 递归实现重定向
            }
            // 返回响应
            return new Response(this.http, this.redirectUrlList, this.extra);
        }

/** 处理重定向 */
        private boolean handleRedirect() {
            if(this.ifStableRedirection) {
                // 采用稳定重定向方式, 需要处理重定向问题
                int responseCode;
                try {
                    responseCode = this.http.getResponseCode();
                } catch(IOException var3) {
                    responseCode = 0;
                }
                if(responseCode == Constant.REDIRECT_CODE_301 || responseCode == Constant.REDIRECT_CODE_302
                        || responseCode == Constant.REDIRECT_CODE_303) {
                    this.site = this.http.getHeaderField(Constant.LOCATION);
                    this.redirectUrlList = this.redirectUrlList == null ? new ArrayList<>(8) : this.redirectUrlList;
                    this.redirectUrlList.add(this.site);
                    if(this.redirectUrlList.size() < 8) {
                        this.http.disconnect();     // 断开本次连接, 然后重新请求
                        return true;
                    }
                }
            } else {
                // 使用默认的重定向规则处理, 无序手动处理, 但是有可能出现重定向失败
                // do non thing
            }
            return false;
        }

/** 发送数据 */
        private void send() {
            try {
                if(!Method.POST.equals(this.method) && !Method.PUT.equals(this.method)) {
                    this.http.connect();
                } else {
                    // POST...
                    this.handleContentTypeAndBody();
                }
            } catch(IOException e) {
                throw new RuntimeException(e);
            }
        }

/** 处理 ContentType 和 传输内容 */
        private void handleContentTypeAndBody() throws IOException {
            if(!Method.GET.equals(this.method)) {
                // non GET
                /* handle ContentType */
                String contentType = Objects.toString(this.header.get(Constant.CONTENT_TYPE), null);
                if(contentType == null) {
                    // 没有 Content-Type
                    if(this.json != null) {
                        this.addAndRefreshHead(Constant.CONTENT_TYPE, Constant.CONTENT_TYPE_WITH_JSON + this.charset);
                    } else {
                        this.addAndRefreshHead(Constant.CONTENT_TYPE, Constant.CONTENT_TYPE_WITH_FORM + this.charset);
                    }
                } else {
                    if(!contentType.contains(Constant.CHARSET)) {
                        // 存在 Content-Type ,没有 ;charset, 处理方式是添加 ;charset=this.charset
                        this.addAndRefreshHead(Constant.CONTENT_TYPE, contentType + "; " + Constant.CONTENT_TYPE_WITH_CHARSET + this.charset);
                    }
                }
                // 需要重新赋值一下, 否则导致下面有 NPE 危险
                contentType = String.valueOf(this.header.get(Constant.CONTENT_TYPE));
                /* handle body */
                boolean ifJson = contentType.contains("json");
                byte[] body;
                if(ifJson) {
                    if(this.json != null) {
                        body = this.json.getBytes(this.charset);
                    } else {
                        // can handle param to json
                        body = new byte[0];
                    }
                } else {
                    //
                    String paramString = parseParamMapToString(this.param, this.charset);// 必须编码, 否则个别网站获取不到数据
                    paramString = Objects.toString(paramString, "");
                    body = paramString.getBytes(this.charset);
                }
                try(OutputStream outputStream = this.http.getOutputStream()) {
                    // 使用 try-resource 方式处理流, 无需手动关闭流操作
                    outputStream.write(body);
                    outputStream.flush();
                }
            }
        }

/** 初始化连接 */
        private void initConnection() throws RuntimeException {
            URL url;
            try {
                url = new URL(this.site);
            } catch(MalformedURLException e) {
                throw new RuntimeException("创建URL出错" + e.getMessage());
            }
            //
            try {
                this.http = this.openConnection(url, this.proxy);
                //
                if(this.timeout > 0) {
                    // 设置超时
                    this.http.setConnectTimeout(this.timeout);
                    this.http.setReadTimeout(this.timeout);
                }
                // 设置请求方法
                this.method = this.method == null ? Method.GET : this.method;
                this.http.setRequestMethod(this.method.name());
            } catch(IOException e) {
                throw new RuntimeException("打开连接出错" + e.getMessage());
            }
            //
            this.http.setDoInput(true);
            if(!Method.GET.equals(this.method)) {
                // 非GET方法需要设置可输入
                http.setDoOutput(true);
                http.setUseCaches(false);
            }
            // 初始化设置默认请求头
            this.initAndSetDefaultHeader();
            //
            if(this.cookie != null) {
                // 设置cookie
                this.setCookie();
            }
            // 设置缓存
            if(ifCache) {
                this.http.setUseCaches(true);
            }
            // 设置是否自动重定向
            this.http.setInstanceFollowRedirects(!(this.ifStableRedirection));
        }

/** 设置 Cookie到连接中 */
        private void setCookie() {
            if(HttpURLConnectionUtil.nonEmpty(this.cookie)) {
                this.addAndRefreshHead(Constant.REQUEST_COOKIE, this.cookie);
            }
        }

/** 刷新 请求头信息 */
        private void addAndRefreshHead(String key, Object value) {
            this.addHead(key, value);
            http.setRequestProperty(key, String.valueOf(value));
        }

/** 初始化和设置默认请求头 */
        private void initAndSetDefaultHeader() {
            HashMap<String, Object> initMap = new HashMap<>(16);
            initMap.putAll(DEFAULT_HEADER);
            if(this.header != null) {
                initMap.putAll(this.header);
            }
            this.header = initMap;
            this.header.forEach((k, v) -> this.http.setRequestProperty(k, String.valueOf(v)));
        }

/** 打开连接 */
        private HttpURLConnection openConnection(URL url, Proxy proxy) throws IOException {
            URLConnection connection;
            if(this.proxy == null) {
                connection = url.openConnection();
            } else if(HttpURLConnectionUtil.nonEmpty(proxy.getUsername())) {                            // 设置代理服务器
                java.net.Proxy javaNetProxy = new java.net.Proxy(java.net.Proxy.Type.HTTP, new InetSocketAddress(this.proxy.getHost(), this.proxy.getPort()));
                connection = url.openConnection(javaNetProxy);
                String authString = this.proxy.getUsername() + ":" + this.proxy.getPassword();
                String auth = "Basic " + Base64.getEncoder().encodeToString(authString.getBytes(this.charset));
                connection.setRequestProperty(Constant.PROXY_AUTHORIZATION, auth);
            } else if(HttpURLConnectionUtil.nonEmpty(proxy.getHost())) {                                // 设置代理主机和端口
                java.net.Proxy javaNetProxy = new java.net.Proxy(java.net.Proxy.Type.HTTP, new InetSocketAddress(this.proxy.getHost(), this.proxy.getPort()));
                connection = url.openConnection(javaNetProxy);
            } else {                                                                                // 不设置代理
                connection = url.openConnection();
            }
            if(connection instanceof HttpsURLConnection) {
                HttpsURLConnection httpsConn = (HttpsURLConnection) connection;
                httpsConn.setHostnameVerifier(this.hostnameVerifier == null ? HOSTNAME_VERIFIER : this.hostnameVerifier);   // 设置主机名验证程序
                httpsConn.setSSLSocketFactory(this.sslSocketFactory == null ? SSL_SOCKET_FACTORY : this.sslSocketFactory);      // 设置ssl factory
            }
            return (HttpURLConnection) connection;
        }

/** 设置 如果是GET, 则将参数写入url中 */
        private void handleGETParamWithUrl() {
            // 校验url地址
            Objects.requireNonNull(this.site, "网站地址不可以为空");
            // 校验url协议 要求url必须是http / https协议, 默认使用http协议
            if(!this.site.toLowerCase().startsWith(Constant.HTTP)) {
                this.site = Constant.HTTP + "://" + this.site;
            }
            if(Method.GET.equals(this.method)) {
                String query = parseParamMapToString(this.param, ifEncodeUrl ? this.charset : null);
                if(query != null) {
                    this.site = this.site.contains("?") ? (this.site + "&" + query) : (this.site + "?" + query);
                }
            }
        }

/**
         * @description Map => key1=val1&key2=val2
         * @date 2019-08-20 20:42:59
         * @author houyu for.houyu@foxmail.com
         */
        public static String parseParamMapToString(Map<String, Object> paramMap, String charset) {
            if(paramMap != null && paramMap.size() > 0) {
                StringBuilder builder = new StringBuilder(128);
                if(charset == null) {
                    paramMap.forEach((k, v) -> builder.append(k).append(Constant.EQU).append(v).append(Constant.AND_SIGN));// key1=val1&key2=val2
                } else {
                    paramMap.forEach((k, v) -> builder.append(encode(k, charset)).append(Constant.EQU).append(encode(String.valueOf(v), charset))
                            .append(Constant.AND_SIGN));
                }
                return builder.delete(builder.length() - 1, builder.length()).toString();
            }
            return null;
        }

/** url 编码 */
        public static String encode(String text, String charset) {
            if(text != null && Charset.isSupported(charset)) {
                // 不为空 并且charset可用
                try {
                    return URLEncoder.encode(text, charset);
                } catch(UnsupportedEncodingException e) {
                    // do non thing
                }
            }
            return text;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 设置 网站地址 */
        public Request setSite(String site) {
            this.site = site;
            return this;
        }

/** 设置 请求方法 */
        public Request setMethod(Method method) {
            this.method = method;
            return this;
        }

/** 设置 请求头 */
        public Request setHeader(Map<String, Object> header) {
            this.header = header;
            return this;
        }

/** 设置 请求参数 */
        public Request setParam(Map<String, Object> param) {
            this.param = param;
            return this;
        }

/** 设置 携带参数 */
        public Request setExtra(Map<String, Object> extra) {
            this.extra = extra;
            return this;
        }

/** 设置 参数编码 */
        public Request setCharset(String charset) {
            if(Charset.isSupported(charset)) {
                // 只设置支持的编码, 否则有可能导致整体的错误
                this.charset = charset;
            }
            return this;
        }

/** 设置 是否需要编码 */
        public Request setIfEncodeUrl(boolean ifEncodeUrl) {
            this.ifEncodeUrl = ifEncodeUrl;
            return this;
        }

/** 设置 是否缓存 */
        public Request setIfCache(boolean ifCache) {
            this.ifCache = ifCache;
            return this;
        }

/** 设置 JSON文本 */
        public Request setJson(String json) {
            this.json = json;
            return this;
        }

/** 设置 连接超时 */
        public Request setTimeout(int timeout) {
            this.timeout = timeout;
            return this;
        }

/** 设置 携带cookie */
        public Request setCookie(String cookie) {
            this.cookie = cookie;
            return this;
        }

/** 设置 携带cookie */
        public Request setCookie(Map<String, String> cookie) {
            StringBuilder builder = new StringBuilder(128);
            cookie.forEach((k, v) -> builder.append(k).append(Constant.EQU).append(v).append(Constant.COOKIE_SPLIT));
            return this.setCookie(builder.toString());
        }

/** 设置 是否稳定重定向 */
        public Request setIfStableRedirection(boolean ifStableRedirection) {
            this.ifStableRedirection = ifStableRedirection;
            return this;
        }

/** 添加 请求头 */
        public Request addHead(String key, Object value) {
            this.header = this.header == null ? new HashMap<>(8) : this.header;
            this.header.put(key, value);
            return this;
        }

/** 添加 请求参数 */
        public Request addParam(String key, Object value) {
            this.param = this.param == null ? new HashMap<>(16) : this.param;
            this.param.put(key, value);
            return this;
        }

/** 添加 携带参数 */
        public Request addExtra(String key, Object value) {
            this.extra = this.extra == null ? new HashMap<>(16) : this.extra;
            this.extra.put(key, value);
            return this;
        }

/** 设置 代理 */
        public Request setProxy(String host, Integer port) {
            this.proxy = this.proxy == null ? new Proxy(host, port) : this.proxy;
            return this;
        }

/** 设置 代理 */
        public Request setProxy(String host, Integer port, String username, String password) {
            this.proxy = this.proxy == null ? new Proxy(host, port, username, password) : this.proxy;
            return this;
        }

/** 设置 主机名验证程序 */
        public Request setHostnameVerifier(HostnameVerifier hostnameVerifier) {
            this.hostnameVerifier = hostnameVerifier;
            return this;
        }

/** 设置 sslSocketFactory */
        public Request setSslSocketFactory(SSLSocketFactory sslSocketFactory) {
            this.sslSocketFactory = sslSocketFactory;
            return this;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 获取 网站地址 */
        public String getSite() {
            return this.site;
        }

/** 获取 请求方法 */
        public Method getMethod() {
            return this.method;
        }

/** 获取 请求头 */
        public Map<String, Object> getHeader() {
            return this.header;
        }

/** 获取 请求参数 */
        public Map<String, Object> getParam() {
            return this.param;
        }

/** 获取 携带参数 */
        public Map<String, Object> getExtra() {
            return this.extra;
        }

/** 获取 代理 */
        public Proxy getProxy() {
            return this.proxy;
        }

/** 获取 参数编码 */
        public String getCharset() {
            return this.charset;
        }

/** 获取 JSON文本 */
        public String getJson() {
            return this.json;
        }

/** 获取 连接超时 */
        public int getTimeout() {
            return this.timeout;
        }

/** 获取 是否稳定重定向 */
        public boolean getIfStableRedirection() {
            return this.ifStableRedirection;
        }

/** 获取 主机名验证程序 */
        public HostnameVerifier getHostnameVerifier() {
            return this.hostnameVerifier;
        }

/** 获取 sslSocketFactory */
        public SSLSocketFactory getSslSocketFactory() {
            return this.sslSocketFactory;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

}

/**
     * @description 响应对象
     * @date 2019-08-21 11:01:03
     * @author houyu for.houyu@foxmail.com
     */
    public static class Response {
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

private String site;                                // 请求url
        private Map<String, List<String>> header;           // 响应头信息
        private Map<String, Object> extra;                  // request携带参数(可使用于响应之后的操作)
        private String cookie;                              // cookie ex:key2=val2; key1=val1
        private String charset;                             // 响应编码
        private String defaultCharset;                      // 默认编码
        private byte[] body;                                // 响应体
        private List<String> redirectUrlList;               // 重定向的url列表
        private HttpURLConnection http;                     // HttpURLConnection
        private Integer code;                               // http响应状态码(HttpURLConnection.HTTP_OK)
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 私有化构造 */
        protected Response() {}

/** 获取html 响应的 charset */
        private static final Pattern PATTERN_FOR_CHARSET = Pattern.compile("charset\\s*=\\s*['\"]*([^\\s;'\"]*)", Pattern.CASE_INSENSITIVE);
        private static Response EMPTY_RESPONSE;

static {
            EMPTY_RESPONSE = new Response();
            EMPTY_RESPONSE.site = Constant.EMPTY_STRING;
            EMPTY_RESPONSE.header = Collections.emptyMap();
            EMPTY_RESPONSE.extra = Collections.emptyMap();
            EMPTY_RESPONSE.cookie = Constant.EMPTY_STRING;
            EMPTY_RESPONSE.charset = Constant.UTF_8;
            EMPTY_RESPONSE.defaultCharset = Constant.UTF_8;
            EMPTY_RESPONSE.body = new byte[0];
            EMPTY_RESPONSE.redirectUrlList = Collections.emptyList();
            EMPTY_RESPONSE.http = null;
            EMPTY_RESPONSE.code = 0;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 构造 Response */
        protected Response(HttpURLConnection http, List<String> redirectUrlList, Map<String, Object> extra) {
            //
            this.http = http;
            this.redirectUrlList = redirectUrlList;
            this.extra = extra;
            //
            this.init();
        }

/** 初始化数据 */
        private void init() {
            try {
                this.site = this.http.getURL().toString();
                this.header = this.http.getHeaderFields();
                this.code = this.http.getResponseCode();
                this.defaultCharset = detectCharset(this.http.getContentType());
                InputStream inputStream = this.code < 400 ? this.http.getInputStream() : this.http.getErrorStream();
                this.initParseInputSteam(inputStream);
            } catch(IOException e) {
                throw new RuntimeException(e);
            }
        }

/** 初始化解析inputStream */
        private void initParseInputSteam(InputStream inputStream) throws IOException {
            // 获取响应头是否有Content-Encoding=gzip
            String gzip = Optional.ofNullable(this.header.get(Constant.CONTENT_ENCODING))//
                    .filter(v -> v.size() > 0)//
                    .map(v -> v.get(0))//
                    .map(String::toLowerCase)//
                    .filter(Constant.GZIP::equals).orElse(null);
            if(gzip != null) {
                inputStream = new GZIPInputStream(inputStream);
            }
            ByteArrayOutputStream outputStream = null;
            try {
                outputStream = new ByteArrayOutputStream();
                byte[] bytes = new byte[1024 * 3];
                for(int length = 0; length > -1; length = inputStream.read(bytes)) {
                    outputStream.write(bytes, 0, length);
                    outputStream.flush();
                }
                this.body = outputStream.toByteArray();
            } catch(IOException e) {
                throw new RuntimeException(e);
            } finally {
                this.close(inputStream);
                this.close(outputStream);
                this.http.disconnect();
            }
        }

private void close(Closeable closeable) {
            try {
                if(closeable != null) {
                    closeable.close();
                }
            } catch(IOException e) {
                // non do thing
            } finally {
                closeable = null;
            }
        }

/*public static Response ofEmpty() {
            return Response.EMPTY_RESPONSE;
        }*/
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 获取 url链接 */
        public String getSite() {
            return this.site;
        }

/** 获取 响应头信息 */
        public Map<String, List<String>> getHeader() {
            return this.header;
        }

/** 获取 携带参数 */
        public Map<String, Object> getExtra() {
            return this.extra;
        }

/** 获取 携带参数值 */
        public Object getExtraValue(String key) {
            return this.extra == null ? null : this.extra.get(key);
        }

/** 获取 cookie */
        public String getCookie() {
            if(this.cookie == null) {
                List<String> cookieList = this.header.get(Constant.RESPONSE_COOKIE);
                if(cookieList != null) {
                    StringJoiner joiner = new StringJoiner(Constant.COOKIE_SPLIT);
                    for(String cookieObj : cookieList) {
                        joiner.add(cookieObj.split(Constant.COOKIE_SPLIT)[0]);
                    }
                    this.cookie = joiner.toString();
                }
            }
            return this.cookie;
        }

/** 获取 cookieMap */
        public Map<String, String> getCookieMap() {
            Map<String, String> cookieMap = null;
            String cookieString = this.getCookie();
            if(cookieString != null) {
                String[] cookieKeyValArray = cookieString.split(Constant.COOKIE_SPLIT);
                cookieMap = new HashMap<>(cookieKeyValArray.length);
                for(String cookieKeyVal : cookieKeyValArray) {
                    String[] keyVal = cookieKeyVal.split(Constant.EQU, 2);
                    if(keyVal.length == 2) {
                        cookieMap.put(keyVal[0], keyVal[1]);
                    }
                }
            }
            return cookieMap;
        }

/** 获取 html编码 */
        public String getCharset() {
            return this.charset == null ? this.defaultCharset : this.charset;
        }

/** 获取 响应 */
        public byte[] getBody() {
            return this.body;
        }

/** 获取 响应 */
        public String getBodyString() {
            try {
                return getBodyString(this.charset == null ? this.defaultCharset : this.charset);
            } catch(UnsupportedEncodingException e) {
                return null;
            }
        }

/** 获取 响应 */
        public String getBodyString(String charset) throws UnsupportedEncodingException {
            return new String(this.getBody(), Charset.isSupported(charset) ? charset : this.getCharset());
        }

/** 获取 重定向的url列表 */
        public List<String> getRedirectUrlList() {
            return this.redirectUrlList;
        }

public HttpURLConnection getHttp() {
            return this.http;
        }

public Integer getCode() {
            return this.code;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 自动识别网页编码 */
        private static String detectCharset(String contentType) {
            // contentType = text/html
            // contentType = text/html;charset=ISO-8859-1
            if(contentType != null) {
                int index = contentType.indexOf(Constant.CONTENT_TYPE_WITH_CHARSET);
                if(index > 0) {
                    String parseCharset = contentType.substring(index + Constant.CONTENT_TYPE_WITH_CHARSET.length()).trim();
                    if(Charset.isSupported(parseCharset)) {
                        return parseCharset;
                    }
                    Matcher matcher = PATTERN_FOR_CHARSET.matcher(contentType);
                    if(matcher.find()) {
                        parseCharset = matcher.group(1);
                        if(Charset.isSupported(parseCharset)) {
                            return parseCharset;
                        }
                    }
                }
            }
            return Constant.UTF_8;
        }
        ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

}

/**
     * @description 代理对象
     * @date 2019-08-21 11:00:30
     * @author houyu for.houyu@foxmail.com
     */
    public static class Proxy {

private String host;
        private Integer port;
        private String username;
        private String password;

public Proxy(String host, Integer port) {
            this.host = host;
            this.port = port;
        }

public Proxy(String host, Integer port, String username, String password) {
            this.host = host;
            this.port = port;
            this.username = username;
            this.password = password;
        }

public String getHost() {
            return host;
        }

public Integer getPort() {
            return port;
        }

public String getUsername() {
            return username;
        }

public String getPassword() {
            return password;
        }

}

/**
     * @description 请求方法
     * @date 2019-08-21 11:00:17
     * @author houyu for.houyu@foxmail.com
     */
    public enum Method {GET, POST, PUT, DELETE}

/**
     * @description 常量
     * @date 2019-08-21 10:59:36
     * @author houyu for.houyu@foxmail.com
     */
    public interface Constant {

String CONTENT_TYPE = "Content-Type";
        String RESPONSE_COOKIE = "Set-Cookie";  // 获取响应的COOKIE
        String REQUEST_COOKIE = "Cookie";       // 设置发送的COOKIE
        String REFERER = "Referer";
        String PROXY_AUTHORIZATION = "Proxy-Authorization";
        String CONTENT_ENCODING = "Content-Encoding";
        String LOCATION = "Location";

String CONTENT_TYPE_WITH_FORM = "application/x-www-form-urlencoded; charset=";
        String CONTENT_TYPE_WITH_JSON = "application/json; charset=";
        String GZIP = "gzip";

int REDIRECT_CODE_301 = 301;
        int REDIRECT_CODE_302 = 302;
        int REDIRECT_CODE_303 = 303;

String COOKIE_SPLIT = "; ";
        String EQU = "=";
        String UTF_8 = "UTF-8";
        String HTTPS = "https";
        String HTTP = "http";

String AND_SIGN = "&";

String CONTENT_TYPE_WITH_CHARSET = "charset=";

String EMPTY_STRING = "";
        String CHARSET = "charset";

}

```

你可以猜想我那天封装的时候屏幕是这样子的。
![在这里插入图片描述](https://ihouyu.cn/view/image?src=https://img-blog.csdnimg.cn/20190822172959548.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ppbmdsb25nU291cmNl,size_16,color_FFFFFF,t_70)
![在这里插入图片描述](https://ihouyu.cn/view/image?src=https://img-blog.csdnimg.cn/20190822173325966.jpg?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0ppbmdsb25nU291cmNl,size_16,color_FFFFFF,t_70)

我的博客 https://shaines.cn
我的CSDN https://blog.csdn.net/JinglongSource/article/details/100016899

面向对象封装一个http工具

作者 : houyu [后宇]

评论