Java请求Http接口-OkHttp(超详细-附带工具类)

简介：OkHttp是一个默认有效的HTTP客户端，有效地执行HTTP可以加快您的负载并节省带宽，如果您的服务有多个IP地址，如果第一次连接失败，OkHttp将尝试备用地址。这对于IPv4 + IPv6和冗余数据中心中托管的服务是必需的。OkHttp启动具有现代TLS功能（SNI，ALPN）的新连接，并在握手失败时回退到TLS 1.0，OkHttp支持Android 2.3及更高版本。对于Java，最低要求是1.7。

操作步骤：

创建OkhttpClient。

mClient执行newCall将Request转化成一个Call。

最后call执行excute同步执行，enqueue异步执行。

Request主要通过Request.Builder来构建。

缓存。

取消请求。

导包

        <dependency>            <groupId>com.squareup.okhttp3groupId>            <artifactId>okhttpartifactId>            <version>4.9.1version>        dependency>        <dependency>            <groupId>commons-iogroupId>            <artifactId>commons-ioartifactId>            <version>2.5version>        dependency>

GET请求

get无参

    public static void doGet1(String url) throws IOException {        OkHttpClient okHttpClient = new OkHttpClient();        final Request request = new Request.Builder()                .url(url)                .get()//默认就是GET请求，可以不写                .build();        Response response = okHttpClient.newCall(request).execute();        String string = response.body().string();        System.out.println(string);    }

get有参

public static void doGet2(String url, Map<String, Object> paramMap) throws IOException {        OkHttpClient okHttpClient = new OkHttpClient();        Request.Builder requestbuilder = new Request.Builder()               .get();//默认就是GET请求，可以不写                StringBuilder urlbuilder = new StringBuilder(url);        if (Objects.nonNull(paramMap)) {            urlbuilder.append("?");            paramMap.forEach((key, value) -> {                try {                    urlbuilder.append(URLEncoder.encode(key, "utf-8")).append("=").append(URLEncoder.encode((String) value, "utf-8")).append("&");                } catch (UnsupportedEncodingException e) {                    e.printStackTrace();                }            });            urlbuilder.deleteCharAt(urlbuilder.length() - 1);        }        Request request = requestbuilder.url(urlbuilder.toString()).build();        Response response = okHttpClient.newCall(request).execute();        String string = response.body().string();        System.out.println(string);    }

get带参数和请求头

      public static void doGet3(String url, Map<String, Object> paramMap,Map<String, String> heardMap) throws IOException {        OkHttpClient okHttpClient = new OkHttpClient();        Request.Builder requestbuilder = new Request.Builder()                .get();//默认就是GET请求，可以不写        //增加参数        StringBuilder urlbuilder = new StringBuilder(url);        if (Objects.nonNull(paramMap)) {            urlbuilder.append("?");            paramMap.forEach((key, value) -> {                try {                    urlbuilder.append(URLEncoder.encode(key, "utf-8")).append("=").append(URLEncoder.encode((String) value, "utf-8")).append("&");                } catch (UnsupportedEncodingException e) {                    e.printStackTrace();                }            });            urlbuilder.deleteCharAt(urlbuilder.length() - 1);        }        //增加请求头        Request.Builder heardBuilder = requestbuilder.url(urlbuilder.toString());        for (Map.Entry<String, String> strinGobjectEntry : heardMap.entrySet()) {            heardBuilder.addHeader(stringObjectEntry.geTKEy(),stringObjectEntry.getValue());        }        Request request = heardBuilder.build();        Response response = okHttpClient.newCall(request).execute();        System.out.println(response.body().string());        System.out.println(response.message());        System.out.println(response.code());    }

get请求 换种方式获取结果

    public static void doGet(String url,Map<String, Object> paramMap,Map<String, String> heardMap) {        OkHttpClient okHttpClient = new OkHttpClient();        Request.Builder requestbuilder = new Request.Builder()                .get();//默认就是GET请求，可以不写        //增加参数        StringBuilder urlbuilder = new StringBuilder(url);        if (Objects.nonNull(paramMap)) {            urlbuilder.append("?");            paramMap.forEach((key, value) -> {                try {                    urlbuilder.append(URLEncoder.encode(key, "utf-8")).append("=").append(URLEncoder.encode((String) value, "utf-8")).append("&");                } catch (UnsupportedEncodingException e) {                    e.printStackTrace();                }            });            urlbuilder.deleteCharAt(urlbuilder.length() - 1);        }        //增加请求头        Request.Builder heardBuilder = requestbuilder.url(urlbuilder.toString());        for (Map.Entry<String, String> stringObjectEntry : heardMap.entrySet()) {            heardBuilder.addHeader(stringObjectEntry.getKey(),stringObjectEntry.getValue());        }        Request request = heardBuilder.build();        Call call = okHttpClient.newCall(request);        call.enqueue(new Callback() {            @Override            public void onFailure(Call call, IOException e) {                System.out.println( "onFailure: ");            }            @Override            public void onResponse(Call call, Response response) throws IOException {                System.out.println(response.body().string());                System.out.println(response.message());                System.out.println(response.code());            }        });    }

POST请求

post-JSON传参

     public static void doPost(String url, String json, Map<String, String> heardMap) throws IOException {        MediaType mediaType = MediaType.parse("application/json; charset=utf-8");        String requestBody = json;        Request.Builder requestbuilder = new Request.Builder()                .url(url)                .post(RequestBody.create(mediaType, requestBody));        //增加请求头        for (Map.Entry<String, String> stringObjectEntry : heardMap.entrySet()) {            requestbuilder.addHeader(stringObjectEntry.getKey(), stringObjectEntry.getValue());        }        Request request = requestbuilder.build();        OkHttpClient okHttpClient = new OkHttpClient();        Response response = okHttpClient.newCall(request).execute();        System.out.println(response.body().string());        System.out.println(response.message());        System.out.println(response.code());    }

post-params传参

     public static void doPost(String url, String json, Map<String, String> heardMap) throws IOException {        MediaType mediaType = MediaType.parse("application/x-www-fORM-urlencoded");        String requestBody = json;        Request.Builder requestbuilder = new Request.Builder()                .url(url)                .post(RequestBody.create(mediaType, requestBody));        //增加请求头        for (Map.Entry<String, String> stringObjectEntry : heardMap.entrySet()) {            requestbuilder.addHeader(stringObjectEntry.getKey(), stringObjectEntry.getValue());        }        Request request = requestbuilder.build();        OkHttpClient okHttpClient = new OkHttpClient();        Response response = okHttpClient.newCall(request).execute();        System.out.println(response.body().string());        System.out.println(response.message());        System.out.println(response.code());    }

     public static void doPost1(String url, Map<String, Object> paramMap,Map<String,String> heardMap) throws IOException {        FormBody.Builder formBody = new FormBody.Builder();        if (Objects.nonNull(paramMap)) {            paramMap.forEach((x, y) -> formBody.add(x, (String) y));        }        RequestBody requestBody = formBody.build();        Request.Builder requestbuilder = new Request.Builder()                .url(url)                .post(requestBody);        //增加请求头        for (Map.Entry<String, String> stringObjectEntry : heardMap.entrySet()) {            requestbuilder.addHeader(stringObjectEntry.getKey(), stringObjectEntry.getValue());        }        Request request = requestbuilder.build();        OkHttpClient okHttpClient = new OkHttpClient();        Response response = okHttpClient.newCall(request).execute();        System.out.println(response.body().string());        System.out.println(response.message());        System.out.println(response.code());    }

post-表单传参-上传文件

达到类似效果

 public static void doPost2(String url,File file) throws IOException {        OkHttpClient client = new OkHttpClient();        RequestBody body = new MultipartBody.Builder()                .setType(MultipartBody.FORM)                .addFormDataPart("id", "111")                .addFormDataPart("content", "{\"do_layout\":1}")                .addFormDataPart("file", file.getName(), RequestBody.create(MediaType.parse("text/plain"), file))                .build();        Request request = new Request.Builder()                .url(url)                .post(body)                .addHeader("x-tilake-app-key", "")                .addHeader("x-tilake-ca-timestamp", "")                .addHeader("x-tilake-ca-signature", "")                .addHeader("Content-Type", body.contentType().toString())                .addHeader("Accept", "*    public static OkHttpClient getOkHttpClient() {        return getOkHttpClient(60, 60, 60);    }    public static OkHttpClient getOkHttpClient(int connectTimeout, int readTimeOut, int writeTimeOut) {        OkHttpClient.Builder builder = new okhttp3.OkHttpClient().newBuilder();        builder.connectTimeout(connectTimeout, TimeUnit.SECONDS);        builder.readTimeout(readTimeOut, TimeUnit.SECONDS);        builder.writeTimeout(writeTimeOut, TimeUnit.SECONDS);        return builder.build();    }        public static String get(OkHttpClient okHttpClient, String url, Headers headers) {        log.info("okHttpClient get url:{}.", url);        Request request = new Request.Builder().url(url).headers(headers).get().build();        String responseData = request(okHttpClient, url, request);        log.info("okHttpClient get url:{},request responseData====> {}", url, responseData);        return responseData;    }    public static String get(OkHttpClient okHttpClient, String url) {        Headers headers = new Headers.Builder().build();        return get( okHttpClient, url, headers);    }        public static String get(String url) {        OkHttpClient okHttpClient = getOkHttpClient();        Headers headers = new Headers.Builder().build();        return get( okHttpClient, url, headers);    }        public static String post(OkHttpClient okHttpClient, String url, JSONObject bodyJson, Headers headers) {        log.info("okHttpClient post url:{}, body====> {}", url, bodyJson);        MediaType mediaTypeJson = MediaType.parse(MEDIA_TYPE_JSON);        RequestBody requestBody = RequestBody.create(mediaTypeJson, JSON.toJSONString(bodyJson));        Request request = new Request.Builder().url(url).headers(headers).post(requestBody).build();        String responseData = request(okHttpClient, url, request);        log.info("okHttpClient post url:{},post responseData====> {}", url, responseData);        return responseData;    }    public static String post(OkHttpClient okHttpClient, String url, JSONObject bodyJson) {        Headers headers = new Headers.Builder().build();        return post( okHttpClient,  url,  bodyJson, headers);    }        public static String post( String url, JSONObject bodyJson) {        //使用默认的 okHttpClient        OkHttpClient okHttpClient = getOkHttpClient();        Headers headers = new Headers.Builder().build();        //如果需要自定义 okHttpClient或headers传参，可以调用以下方法        return post( okHttpClient,  url,  bodyJson, headers);    }        public static String request(OkHttpClient okHttpClient, String url, Request request) {        String responseData = "";        try (Response response = okHttpClient.newCall(request).execute()) {            if (response != null && response.body() != null) {                return response.body().string();            }        } catch (Exception e) {            log.error("okHttpClient getResponse error.url:{}", url, e);        }        return responseData;    }        public static String uploadFile(OkHttpClient okHttpClient, String url,         String fileKey, File file, JSONObject formDataJson, Headers headers) {        log.info("uploadFile url:{}, uploadFile formDataJson====> {}", url, formDataJson);        // 支持传文件的同时，传参数。        MultipartBody requestBody = getMultipartBody(fileKey, file,  formDataJson);        // 构建request请求体        Request request = new Request.Builder().url(url).headers(headers).post(requestBody).build();        String responseData = request(okHttpClient, url, request);        // 会在本地产生临时文件，用完后需要删除        if (file.exists()) {            file.delete();        }        return responseData;    }        public static String uploadFile(String url,        String fileKey, MultipartFile multipartFile, JSONObject formDataJson) {        //使用默认的okHttpClient        OkHttpClient okHttpClient = getOkHttpClient();        Headers headers = new Headers.Builder().build();        return uploadFile(okHttpClient, url, fileKey, getFile(multipartFile), formDataJson, headers);    }    public static String uploadFile(OkHttpClient okHttpClient, String url,        String fileKey, File file, JSONObject formDataJson) {        Headers headers = new Headers.Builder().build();        return uploadFile(okHttpClient, url,  fileKey, file, formDataJson, headers);    }        public static String uploadFile(String url,        String fileKey, File file, JSONObject formDataJson) {        //使用默认的okHttpClient        OkHttpClient okHttpClient = getOkHttpClient();        Headers headers = new Headers.Builder().build();        return uploadFile(okHttpClient, url, fileKey, file, formDataJson, headers);    }        public static MultipartBody getMultipartBody(String fileKey, File file, JSONObject formDataJson) {        RequestBody fileBody = RequestBody.create(MultipartBody.FORM, file);        MultipartBody.Builder bodyBuilder = new MultipartBody.Builder();        // 设置传参为form-data格式        bodyBuilder.setType(MultipartBody.FORM);        bodyBuilder.addFormDataPart(fileKey, file.getName(), fileBody);        // 添加 form-data参数        for (Map.Entry<String, Object> entry : formDataJson.entrySet()) {            //参数通过 bodyBuilder.addFormDataPart(key, value) 添加            bodyBuilder.addFormDataPart(entry.getKey(), Objects.toString(entry.getValue(),""));        }        return bodyBuilder.build();    }        public static File getFile(MultipartFile multipartFile) {        File file = new File(Objects.requireNonNull(multipartFile.getOriginalFilename()));        try {            FileUtils.copyInputStreamToFile(multipartFile.getInputStream(), file);        } catch (IOException e) {            log.error("copyInputStreamToFile error.", e);        }        return file;    }}

来源地址：https://blog.csdn.net/qq_41694906/article/details/132345812