Springboot-使用RestTemplate方式發(fā)HTTP請求及上傳文件

RestTemplate是Spring提供的用于訪問Rest服務(wù)的客戶端田柔，RestTemplate提供了多種便捷訪問遠(yuǎn)程Http服務(wù)的方法,能夠大大提高客戶端的編寫效率艾蓝。

我基于RestTemplate編寫了一個(gè)工具類，方便使用粪牲。工具類提供之提供了GET古瓤、POST、DELETE請求方法腺阳，其他方法自行補(bǔ)充

Application啟動(dòng)類中實(shí)例RestTemplate

@SpringBootApplication
@RestController
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(ElasticApplication.class, args);
    }
    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate(new HttpComponentsClientHttpRequestFactory());
    }
}

RestTemplateUtils工具類

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.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

/**
 * RestTemplate工具類
 *
 * @author Colin.Ye
 * @version 1.0
 * @ClassName RestTemplateUtils
 * @date 2019/7/31
 **/
@Component
public class RestTemplateUtils {

    @Autowired
    private RestTemplate restTemplate;

    /**
     * POST請求-JSON參數(shù)
     *
     * @param url
     * @param params
     * @param headers
     * @return
     */
    public <T> T httpPostJson(String url, Map<String, Object> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        // json方式傳參
        return restTemplate.postForObject(url, new HttpEntity(params, httpHeaders), clazz);
    }

    /**
     * POST請求-FROM參數(shù)
     *
     * @param url
     * @param params
     * @param headers
     * @return
     */
    public <T> T httpPostFrom(String url, Map<String, Object> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        params = params == null ? new LinkedHashMap<>() : params;
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        MultiValueMap<String, Object> stringObjectLinkedMultiValueMap = new LinkedMultiValueMap<>();
        params.forEach((o1, o2) -> stringObjectLinkedMultiValueMap.add(o1, o2));
        // 表單方式傳參
        // json方式傳參
        return restTemplate.postForObject(url, new HttpEntity(stringObjectLinkedMultiValueMap, httpHeaders), clazz);
    }

    /**
     * GET請求-?號參數(shù)
     *
     * @param url
     * @param params
     * @param headers
     * @return
     */
    public <T> T httpGetTraditional(String url, Map<String, Object> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        params = params == null ? new LinkedHashMap<>() : params;
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        StringBuilder sb = new StringBuilder(url);
        sb.append("?");
        params.forEach((o1, o2) -> sb.append(o1).append("=").append(o2).append("&"));
        url = sb.toString().replaceAll("&$+|\\?$+", "");
        ResponseEntity<T> exchange = restTemplate.exchange(url, HttpMethod.GET, new HttpEntity(null, httpHeaders), clazz);
        return exchange.getBody();
    }

    /**
     * GET請求-分隔符參數(shù)
     *
     * @param url
     * @param params LinkedHashMap
     * @param headers
     * @return
     */
    public <T> T httpGetPlaceholder(String url, List<String> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        params = params == null ? new ArrayList<>() : params;
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        StringBuilder sb = new StringBuilder(url);
        params.forEach(o2 -> sb.append("/").append(o2));
        url = sb.toString().replaceAll("&$+|\\?$+", "");
        ResponseEntity<T> exchange = restTemplate.exchange(url, HttpMethod.GET, new HttpEntity(null, httpHeaders), clazz);
        return exchange.getBody();
    }

    /**
     * DELETE請求-?號參數(shù)
     *
     * @param url
     * @param params
     * @param headers
     * @return
     */
    public <T> T httpDeleteTraditional(String url, Map<String, Object> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        params = params == null ? new LinkedHashMap<>() : params;
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        StringBuilder sb = new StringBuilder(url);
        sb.append("?");
        params.forEach((o1, o2) -> sb.append(o1).append("=").append(o2).append("&"));
        url = sb.toString().replaceAll("&$+|\\?$+", "");
        ResponseEntity<T> exchange = restTemplate.exchange(url, HttpMethod.DELETE, new HttpEntity(null, httpHeaders), clazz);
        return exchange.getBody();
    }

    /**
     * DELETE請求-分隔符參數(shù)
     *
     * @param url
     * @param params
     * @param headers
     * @return
     */
    public <T> T httpDeletePlaceholder(String url, List<String> params, Map<String, String> headers, Class<T> clazz) {
        HttpHeaders httpHeaders = new HttpHeaders();
        params = params == null ? new ArrayList<>() : params;
        if (headers != null) {
            headers.forEach((o1, o2) -> httpHeaders.add(o1, o2));
        }
        StringBuilder sb = new StringBuilder(url);
        params.forEach(o2 -> sb.append("/").append(o2));
        url = sb.toString().replaceAll("&$+|\\?$+", "");
        ResponseEntity<T> exchange = restTemplate.exchange(url, HttpMethod.DELETE, new HttpEntity(null, httpHeaders), clazz);
        return exchange.getBody();
    }
}

使用

/**
 * @author Colin.Ye
 * @version 1.0
 * @ClassName LowCreateIndexDemo
 * @date 2019/3/13
 **/
@RestController
@RequestMapping("/lowClient/v1/")
@CrossOrigin
@DefaultProperties(defaultFallback = "defaultFallback")
public class LowCreateIndexDemo extends BaseController {

    @Autowired
    private RestTemplateUtils restTemplateUtils;

    @RequestMapping("/index")
    @Log
    @HystrixCommand(commandProperties = @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "2000"))

    public String index() {
        Map<String, Object> params = new HashMap<>();
        //  上傳文件
        FileSystemResource resource = new FileSystemResource(new File("/Users/yezhuang/Documents/data/oracle命令的副本.txt"));
        params.put("deviceId", "123424");
        params.put("file", resource);
        Object o = restTemplateUtils.httpPostFrom("http://localhost:10005/lowClient/v1/test", params, null, String.class);
        return o.toString();
    }

    @RequestMapping("/test")
    public String remoteUpdteTest(String deviceId, @RequestParam MultipartFile file) {
        System.out.println(deviceId);
        System.out.println(file.getName());
        return "success";
    }

    private String fallback() {
        return "網(wǎng)絡(luò)開小差了落君，請稍后重試···";
    }

    private String defaultFallback() {
        return "defaultFallback: 網(wǎng)絡(luò)開小差了，請稍后重試···";
    }
}