Springboot自带的RestTemplate发送请求与上传

首先创建一个RestTemplate对象

@Bean
public RestTemplate restTemplate(){
    RestTemplate restTemplate = new RestTemplate();
    HttpComponentsClientHttpRequestFactory requestFactory = new HttpComponentsClientHttpRequestFactory();

    /**
     * 使用客户端类API调用远程交易时必须设置相应的超时时间，如果远程交易有问题如长时间未响应，若未设置超时时间，则会耗尽客户端所在服务器的资源
     */
    // 连接超时
    requestFactory.setConnectTimeout(5000);
    //读超时
    requestFactory.setReadTimeout(10000);
    //连接池获取连接超时时间
    requestFactory.setConnectionRequestTimeout(5000);

    HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();
    //Httpclient连接池的方式，同时支持netty，okHttp以及其他http框架
    PoolingHttpClientConnectionManager connectionManager = new PoolingHttpClientConnectionManager();
    // 最大连接数
    connectionManager.setMaxTotal(200);
    // 同路由并发数
    connectionManager.setDefaultMaxPerRoute(50);
    //配置连接池
    httpClientBuilder.setConnectionManager(connectionManager);

    // 最大连接数
    connectionManager.setMaxTotal(500);
    // 同路由并发数（每个主机的并发）
    connectionManager.setDefaultMaxPerRoute(100);
    httpClientBuilder.setConnectionManager(connectionManager);
    requestFactory.setHttpClient(httpClientBuilder.build());
    restTemplate.setRequestFactory(requestFactory);
    return restTemplate;
}

封装请求工具HttpUtil

package com.demo;

import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.util.ObjectUtils;
import org.springframework.web.client.RestTemplate;

import java.util.Collections;
import java.util.List;
import java.util.Map;

/** HttpUtil
 * author chics
 * 2023/8/22
 */
@Slf4j
@Component
public class HttpUtil {

    public static final String API_KEY_PREFIX = "Api_key";

    public static RestTemplate restTemplate;

    @Autowired
    public void setRestTemplate(RestTemplate restTemplate) {
        HttpUtil.restTemplate = restTemplate;
    }

    /**
     * get请求
     * @param apiKey
     * @param uri
     * @param clazz
     * @return
     */
    public static <T>T get(String apiKey,String uri,Class<T> clazz){
        return get(apiKey,uri,null,null,clazz);
    }

    /**
     * get请求
     * @param apiKey
     * @param uri
     * @param body
     * @param clazz
     * @return
     */
    public static <T>T get(String apiKey,String uri,Object body,Class<T> clazz){
        return get(apiKey,uri,body,null,clazz);
    }

    /**
     * get请求
     * @param apiKey
     * @param uri
     * @param formParams
     * @param clazz
     * @return
     */
    public static <T>T get(String apiKey,String uri,Map<String,Object> formParams,Class<T> clazz){
        return get(apiKey,uri,null,formParams,clazz);
    }

    /**
     * get请求
     * @param apiKey
     * @param uri
     * @param body
     * @param formParams
     * @param clazz
     * @return
     */
    public static <T>T get(String apiKey,String uri,Object body,Map<String,Object> formParams,Class<T> clazz){
        HttpEntity<Object> httpEntity = new HttpEntity<Object>(null, getHttpHeaders(apiKey));
        if (!ObjectUtils.isEmpty(body)){
            httpEntity = new HttpEntity<Object>(body, getHttpHeaders(apiKey));
        }
        if (ObjectUtils.isEmpty(formParams)){
            ResponseEntity<String> result = restTemplate.exchange(uri, HttpMethod.GET, httpEntity, String.class);
            return JSON.parseObject(result.getBody(),clazz);
        }
        ResponseEntity<String> result = restTemplate.exchange(uri, HttpMethod.GET,httpEntity,String.class,formParams);
        return JSON.parseObject(result.getBody(),clazz);
    }

    /**
     * post请求
     * @param apiKey
     * @param uri
     * @param clazz
     * @return
     */
    public static <T>T post(String apiKey,String uri,Class<T> clazz){
        return post(apiKey,uri,null,null,clazz);
    }

    /**
     * post请求
     * @param apiKey
     * @param uri
     * @param body
     * @param clazz
     * @return
     */
    public static <T>T post(String apiKey,String uri,Object body,Class<T> clazz){
        return post(apiKey,uri,body,null,clazz);
    }

    /**
     * post请求
     * @param apiKey
     * @param uri
     * @param formParams
     * @param clazz
     * @return
     */
    public static <T>T post(String apiKey,String uri,Map<String,Object> formParams,Class<T> clazz){
        return post(apiKey,uri,null,formParams,clazz);
    }

    /**
     * post请求
     * @param apiKey
     * @param uri
     * @param body
     * @param formParams
     * @param clazz
     * @return
     */
    public static <T>T post(String apiKey,String uri,Object body,Map<String,Object> formParams,Class<T> clazz){
        HttpEntity<Object> httpEntity = new HttpEntity<Object>(null, getHttpHeaders(apiKey));
        if (!ObjectUtils.isEmpty(body)){
            httpEntity = new HttpEntity<Object>(body, getHttpHeaders(apiKey));
        }
        if (ObjectUtils.isEmpty(formParams)){
            ResponseEntity<String> result = restTemplate.postForEntity(uri, httpEntity, String.class);
            return JSON.parseObject(result.getBody(),clazz);
        }
        ResponseEntity<String> result = restTemplate.postForEntity(uri, httpEntity, String.class,formParams);
        return JSON.parseObject(result.getBody(),clazz);
    }

    /**
     * post文件上传请求
     * @param apiKey
     * @param uri
     * @param formParams
     * @param clazz
     * @return
     */
    public static <T>T postUpload(String apiKey, String uri, MultiValueMap<String,Object> formParams,Class<T> clazz){
        //设置请求头
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.MULTIPART_FORM_DATA);
        headers.add(API_KEY_PREFIX,apiKey);
        /*MultiValueMap<String,Object> form = new LinkedMultiValueMap<>();
        for (int i = 0; i < files.size(); i++) {
            MultipartFile file = files.get(i);
            form.add("files", file.getResource());
        }*/
        HttpEntity<Object> httpEntity = new HttpEntity<>(formParams, headers);
        ResponseEntity<String> result = restTemplate.postForEntity(uri, httpEntity, String.class);
        return JSON.parseObject(result.getBody(),clazz);
    }

    /**
     * 创建上传文件createForm
     * @return
     */
    public static MultiValueMap<String,Object> createForm(){
        return new LinkedMultiValueMap<>();
    }

    /**
     * 获取文件流
     * @param apiKey
     * @param uri
     * @return
     */
    public static byte[] getFileStream(String apiKey,String uri){
        HttpHeaders headers = new HttpHeaders();
        headers.add(API_KEY_PREFIX,apiKey);
        headers.setAccept(Collections.singletonList(MediaType.APPLICATION_OCTET_STREAM));
        HttpEntity<String> entity = new HttpEntity<String>(headers);
        ResponseEntity<byte[]> response = restTemplate.exchange(uri, HttpMethod.GET, entity, byte[].class);
        return response.getBody();
    }

    /**
     * 获取请求头
     * @param apiKey
     * @return
     */
    private static HttpHeaders getHttpHeaders(String apiKey){
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        headers.add(API_KEY_PREFIX,apiKey);
        return headers;
    }

    /**
     * 序列化成集合
     * @param data
     * @param clazz
     * @param <T>
     * @return
     */
    public static <T>List<T> toList(Object data,Class<T> clazz){
        return JSON.parseArray(JSON.toJSONString(data)).toJavaList(clazz);
    }
}

使用就是根据方法参数传值就行。如下：

/**
* 上传
* @param requestBody
* @return
*/
public static OSSResponseBody upload(OSSRequestBody requestBody){
    MultiValueMap<String, Object> form = HttpUtil.createForm();
    form.add("file",requestBody.getFile().getResource());
    form.add("dir",requestBody.getDir());
    R r = HttpUtil.postUpload(null, instance.uploadHost + "/zyq/file/upload", form, R.class);
    log.info("上传:{}", JSONUtil.toJsonStr(r));
    return JSONUtil.toBean(JSONUtil.toJsonStr(r.getData()),OSSResponseBody.class);
}

 // 调用
public R<String> upload(MultipartFile file) {
   OSSRequestBody ossRequestBody = new OSSRequestBody();
   ossRequestBody.setFile(file);
   OSSResponseBody responseBody = FileUploadUtil.upload(ossRequestBody);
   if (responseBody.isSuccess()){
       // ....
   }
}

是不是调用就简单多了。用到的类
OSSRequestBody

package com.zyq.vo;

import org.springframework.web.multipart.MultipartFile;

import java.util.List;

/** OSSRequestBody
 * author xiaochi
 * date 2024/5/28 17:03
 */
public class OSSRequestBody {

    private List<MultipartFile> files;// 多文件上传
    private MultipartFile file;// 单文件上传
    private String filePath;// 可不传
    private String dir;// 可不传

    public List<MultipartFile> getFiles() {
        return files;
    }

    public void setFiles(List<MultipartFile> files) {
        this.files = files;
    }

    public MultipartFile getFile() {
        return file;
    }

    public void setFile(MultipartFile file) {
        this.file = file;
    }

    public String getFilePath() {
        return filePath;
    }

    public void setFilePath(String filePath) {
        this.filePath = filePath;
    }

    public String getDir() {
        return dir;
    }

    public void setDir(String dir) {
        this.dir = dir;
    }
}

OSSResponseBody

package com.zyq.vo;

import lombok.Data;

/** OSSResponseBody
 * author xiaochi
 * date 2024/5/28 16:28
 */
@Data
public class OSSResponseBody {

    private String viewPath;
    private String path;

    private boolean success;
    private String errorMsg;
    private String errorCode;

    public boolean isSuccess() {
        return success;
    }

    public void setSuccess(boolean success) {
        this.success = success;
    }

    public String getErrorMsg() {
        return errorMsg;
    }

    public void setErrorMsg(String errorMsg) {
        this.errorMsg = errorMsg;
    }

    public String getErrorCode() {
        return errorCode;
    }

    public void setErrorCode(String errorCode) {
        this.errorCode = errorCode;
    }
}

到此完成。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 212,222评论 6赞 493
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,455评论 3赞 385
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 157,720评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,568评论 1赞 284
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,696评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,879评论 1赞 290
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,028评论 3赞 409
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,773评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,220评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,550评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,697评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,360评论 4赞 332
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 40,002评论 3赞 315
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,782评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,010评论 1赞 266
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,433评论 2赞 360
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,587评论 2赞 350