快捷導(dǎo)航

RestTemplate如何獲取HTTP狀態(tài)碼

更新時(shí)間：2026年01月06日 09:21:37 作者：搬甎小犟

文章介紹了使用RestTemplate請(qǐng)求接口并處理HTTP狀態(tài)碼的方法,為了解決默認(rèn)處理器拋出異常的問題,建議自定義ResponseErrorHandler,自定義處理器不會(huì)拋出異常,從而可以獲取ResponseEntity對(duì)象并獲取HTTP狀態(tài)碼

背景

使用RestTemplate請(qǐng)求特定接口，并根據(jù)獲取的HTTP狀態(tài)碼進(jìn)行具體業(yè)務(wù)操作。

@RestController
public class RestfulController {
    private RestTemplate restTemplate = new RestTemplate();

    @GetMapping("/test1")
    public void test1(HttpServletResponse response) {
        response.setStatus(403);
    }

    @GetMapping("/test2")
    public void test2() {
        ResponseEntity responseEntity = restTemplate.exchange("http://127.0.0.1:8080/test1", HttpMethod.GET, new HttpEntity<String>(null, new HttpHeaders()), String.class);
        int code = responseEntity.getStatusCodeValue();
        // 具體業(yè)務(wù)操作...
    }
}

報(bào)錯(cuò)

?org.springframework.web.client.HttpClientErrorException$Forbidden: 403 null

解決

如果想要使用responseEntity.getStatusCodeValue()等，需要先為RestTemplate對(duì)象設(shè)置ResponseErrorHandler。
需要注意代碼并不符合平常的開發(fā)規(guī)范，只是為了實(shí)現(xiàn)效果。

@RestController
public class RestfulController {
    private RestTemplate restTemplate = new RestTemplate();

    @GetMapping("/test1")
    public void test1(HttpServletResponse response) {
        response.setStatus(403);
    }

    @GetMapping("/test2")
    public void test2() {
        restTemplate.setErrorHandler(new RestfulController.ErrorHandler());
        ResponseEntity responseEntity = restTemplate.exchange("http://127.0.0.1:8080/test1", HttpMethod.GET, new HttpEntity<String>(null, new HttpHeaders()), String.class);
        int code = responseEntity.getStatusCodeValue();
        // 業(yè)務(wù)處理...
    }

    static class ErrorHandler implements ResponseErrorHandler {

        @Override
        public boolean hasError(ClientHttpResponse clientHttpResponse) throws IOException {
            if (200 == clientHttpResponse.getRawStatusCode()) {
                return false;
            }
            return true;
        }

        @Override
        public void handleError(ClientHttpResponse clientHttpResponse) throws IOException {
            // 處理Error...
        }
    }
}

原因

RestTemplate

public class RestTemplate extends InterceptingHttpAccessor implements RestOperations {
	...
    private ResponseErrorHandler errorHandler;
    ...

    public RestTemplate() {
        ...
        // 默認(rèn)的ResponseErrorHandler
        this.errorHandler = new DefaultResponseErrorHandler();
        ...
    }

	...

	@Nullable
    protected <T> T doExecute(URI url, @Nullable HttpMethod method, @Nullable RequestCallback requestCallback, @Nullable ResponseExtractor<T> responseExtractor) throws RestClientException {
        Assert.notNull(url, "URI is required");
        Assert.notNull(method, "HttpMethod is required");
        ClientHttpResponse response = null;

        Object var14;
        try {
            ClientHttpRequest request = this.createRequest(url, method);
            if (requestCallback != null) {
                requestCallback.doWithRequest(request);
            }

            response = request.execute();
            
            // 處理Response, 這里如果拋出異常，就不會(huì)返回ResponseEntity對(duì)象
            this.handleResponse(url, method, response);
            
            var14 = responseExtractor != null ? responseExtractor.extractData(response) : null;
        } catch (IOException var12) {
            String resource = url.toString();
            String query = url.getRawQuery();
            resource = query != null ? resource.substring(0, resource.indexOf(63)) : resource;
            throw new ResourceAccessException("I/O error on " + method.name() + " request for \"" + resource + "\": " + var12.getMessage(), var12);
        } finally {
            if (response != null) {
                response.close();
            }

        }

        return var14;
    }

	protected void handleResponse(URI url, HttpMethod method, ClientHttpResponse response) throws IOException {
        ResponseErrorHandler errorHandler = this.getErrorHandler();
        boolean hasError = errorHandler.hasError(response);
        if (this.logger.isDebugEnabled()) {
            try {
                int code = response.getRawStatusCode();
                HttpStatus status = HttpStatus.resolve(code);
                this.logger.debug("Response " + (status != null ? status : code));
            } catch (IOException var8) {
            }
        }

        if (hasError) {
        	// 處理Http錯(cuò)誤碼
            errorHandler.handleError(url, method, response);
        }

    }

	...
}

DefaultResponseErrorHandler

public class DefaultResponseErrorHandler implements ResponseErrorHandler {
    public DefaultResponseErrorHandler() {
    }

    public boolean hasError(ClientHttpResponse response) throws IOException {
        int rawStatusCode = response.getRawStatusCode();
        HttpStatus statusCode = HttpStatus.resolve(rawStatusCode);
        return statusCode != null ? this.hasError(statusCode) : this.hasError(rawStatusCode);
    }

    protected boolean hasError(HttpStatus statusCode) {
        return statusCode.isError();
    }

    protected boolean hasError(int unknownStatusCode) {
        Series series = Series.resolve(unknownStatusCode);
        return series == Series.CLIENT_ERROR || series == Series.SERVER_ERROR;
    }

    public void handleError(ClientHttpResponse response) throws IOException {
        HttpStatus statusCode = HttpStatus.resolve(response.getRawStatusCode());
        if (statusCode == null) {
            throw new UnknownHttpStatusCodeException(response.getRawStatusCode(), response.getStatusText(), response.getHeaders(), this.getResponseBody(response), this.getCharset(response));
        } else {
            this.handleError(response, statusCode);
        }
    }

    protected void handleError(ClientHttpResponse response, HttpStatus statusCode) throws IOException {
        String statusText = response.getStatusText();
        HttpHeaders headers = response.getHeaders();
        byte[] body = this.getResponseBody(response);
        Charset charset = this.getCharset(response);
        switch(statusCode.series()) {
        case CLIENT_ERROR:
            throw HttpClientErrorException.create(statusCode, statusText, headers, body, charset);
        case SERVER_ERROR:
            throw HttpServerErrorException.create(statusCode, statusText, headers, body, charset);
        default:
            throw new UnknownHttpStatusCodeException(statusCode.value(), statusText, headers, body, charset);
        }
    }
    
    ...
}

RestTemplate中的getForEntity(…)、 getForObject(…)、exchange(…)和delete(…)等方法最終都是調(diào)用doExecute(URI url, @Nullable HttpMethod method, @Nullable RequestCallback requestCallback, @Nullable ResponseExtractor responseExtractor)方法。
從源代碼可以看出來默認(rèn)的處理器DefaultResponseErrorHandler，最后會(huì)拋出三種異常：HttpClientErrorException、HttpServerErrorException、UnknownHttpStatusCodeException。所以在得到ResponseEntity返回值之前，就有異常拋出。
可以自定義錯(cuò)誤處理器，自定義的處理器并沒有拋出異常，所以也就可以返回ResponseEntity對(duì)象，并通過該對(duì)象的getStatusCodeValue()方法獲取HTTP狀態(tài)碼。