Class ToolSendHttp

http/src/main/java/pro/tools/http/okhttp/ToolSendHttp.java:30–161

Created on 17/9/3 13:57 星期日. @author sd

 * @author sd
 */
public class ToolSendHttp {

    private static final Logger log = LoggerFactory.getLogger(ToolSendHttp.class);

    public static HttpReceive get(String url) {
        return send(HttpSend.of(url).setMethod(HttpMethod.GET));
    }

    public static HttpReceive post(String url) {
        return send(HttpSend.of(url).setMethod(HttpMethod.POST));
    }

    public static HttpReceive post(String url, Map<String, Object> params) {
        return send(HttpSend.of(url, params).setMethod(HttpMethod.POST));
    }

    public static HttpReceive send(HttpSend httpSend) {
        return send(httpSend, ToolHttpBuilder.getDefaultClient());
    }

    public static HttpReceive send(HttpSend httpSend, OkHttpClient.Builder okHttpClientBuilder) {
        return send(httpSend, okHttpClientBuilder.build());
    }

    public static HttpReceive send(HttpSend httpSend, OkHttpClient okHttpClient) {
        final HttpReceive httpReceive = new HttpReceive();
        httpReceive.setHaveError(true);
        try {
            Request request = convertRequest(httpSend);
            Call call = okHttpClient.newCall(request);
            Response response = call.execute();
            ResponseBody body = response.body();

            if (body == null) {
                throw new HttpException("发送http失败，响应体为空");
            }

            final Map<String, String> responseHeaders = Maps.newHashMap();
            if (httpSend.getNeedReceiveHeaders()) {
                final Headers headers = response.headers();
                final Set<String> headerNameSet = headers.names();
                headerNameSet.forEach(oneHeaderName -> {
                    final String oneHeaderValue = headers.get(oneHeaderName);
                    responseHeaders.put(oneHeaderName, oneHeaderValue);
                });
            }

            int responseStatusCode = response.code();
            if (responseStatusCode != 200) {
                throw new HttpException("本次请求响应码不是200，是" + responseStatusCode);
            }

            String responseBody = body.string();
            if (log.isDebugEnabled()) {
                log.debug(responseBody);
            }
            httpReceive.setResponseBody(responseBody)
                    .setHaveError(false)