public interface ClientHttpRequestInterceptor {
    // request：當(dāng)前請求對象；body：請求體；execution：請求執(zhí)行器（用于觸發(fā)下一個(gè)攔截器或?qū)嶋H請求）
    ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException;
}

/**
 * 日志攔截器：打印請求和響應(yīng)的關(guān)鍵信息
 */
public class LoggingInterceptor implements ClientHttpRequestInterceptor {
    private static final Logger log = LoggerFactory.getLogger(LoggingInterceptor.class);

    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        // 前置處理：記錄請求信息
        long startTime = System.currentTimeMillis();
        log.info("【請求開始】URL：{}，方法：{}，參數(shù)：{}",
                request.getURI(),
                request.getMethod(),
                new String(body, StandardCharsets.UTF_8));

        // 執(zhí)行下一個(gè)攔截器或?qū)嶋H請求
        ClientHttpResponse response = execution.execute(request, body);

        // 后置處理：記錄響應(yīng)信息
        long endTime = System.currentTimeMillis();
        log.info("【請求結(jié)束】URL：{}，狀態(tài)碼：{}，耗時(shí)：{}ms",
                request.getURI(),
                response.getStatusCode(),
                endTime - startTime);

        return response;
    }
}

/**
 * 鑒權(quán)攔截器：為請求添加Token認(rèn)證頭
 */
public class AuthInterceptor implements ClientHttpRequestInterceptor {
    private final String token;

    // 通過構(gòu)造器注入Token（實(shí)際可從配置文件讀?。?    public AuthInterceptor(String token) {
        this.token = token;
    }

    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        // 前置處理：添加Token請求頭
        HttpHeaders headers = request.getHeaders();
        headers.add("Authorization", "Bearer " + token);

        // 執(zhí)行請求
        ClientHttpResponse response = execution.execute(request, body);

        // 后置處理：可根據(jù)響應(yīng)狀態(tài)處理Token過期（如刷新Token）
        if (response.getStatusCode().is4xxClientError() 
                && response.getStatusCode().value() == 401) {
            log.warn("Token已過期，需執(zhí)行刷新邏輯");
            // 實(shí)際場景可調(diào)用刷新Token接口并更新本地Token
        }
        return response;
    }
}

/**
 * 超時(shí)控制攔截器：根據(jù)請求路徑設(shè)置超時(shí)
 */
public class TimeoutInterceptor implements ClientHttpRequestInterceptor {
    // 普通接口超時(shí)（毫秒）
    private static final int NORMAL_TIMEOUT = 3000;
    // 文件上傳接口超時(shí)（毫秒）
    private static final int UPLOAD_TIMEOUT = 30000;

    @Override
    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
        // 前置處理：根據(jù)路徑判斷超時(shí)時(shí)間
        String uri = request.getURI().getPath();
        int timeout = uri.contains("/upload") ? UPLOAD_TIMEOUT : NORMAL_TIMEOUT;

        // 如果是SimpleClientHttpRequestFactory，設(shè)置超時(shí)（需提前確認(rèn)請求工廠類型）
        if (execution instanceof InterceptingClientHttpRequest.InterceptingRequestExecution) {
            try {
                // 通過反射獲取請求工廠（實(shí)際可在配置時(shí)提前綁定）
                Field requestFactoryField = InterceptingClientHttpRequest.class.getDeclaredField("requestFactory");
                requestFactoryField.setAccessible(true);
                SimpleClientHttpRequestFactory requestFactory = 
                    (SimpleClientHttpRequestFactory) requestFactoryField.get(execution);
                requestFactory.setReadTimeout(timeout);
                requestFactory.setConnectTimeout(timeout);
            } catch (Exception e) {
                log.error("設(shè)置超時(shí)時(shí)間失敗", e);
            }
        }

        return execution.execute(request, body);
    }
}

@Configuration
public class RestTemplateConfig {

    @Bean
    public RestTemplate customRestTemplate() {
        // 1. 創(chuàng)建攔截器實(shí)例（可通過@Value注入配置參數(shù)）
        LoggingInterceptor loggingInterceptor = new LoggingInterceptor();
        AuthInterceptor authInterceptor = new AuthInterceptor("fixed-token-123456");
        TimeoutInterceptor timeoutInterceptor = new TimeoutInterceptor();

        // 2. 按執(zhí)行順序添加攔截器（關(guān)鍵！）
        List<ClientHttpRequestInterceptor> interceptors = new ArrayList<>();
        interceptors.add(loggingInterceptor);  // 第1個(gè)：先執(zhí)行前置，最后執(zhí)行后置
        interceptors.add(authInterceptor);    // 第2個(gè)
        interceptors.add(timeoutInterceptor); // 第3個(gè)：最后執(zhí)行前置，最先執(zhí)行后置

        // 3. 創(chuàng)建RestTemplate并設(shè)置攔截器
        RestTemplate restTemplate = new RestTemplate();
        restTemplate.setInterceptors(interceptors);

        // 4. 配置請求工廠（如支持超時(shí)的SimpleClientHttpRequestFactory）
        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
        restTemplate.setRequestFactory(new BufferingClientHttpRequestFactory(requestFactory));

        return restTemplate;
    }
}