Spring Integration HTTP 代理配置详解

⚠️ 在需要访问外部 API 的服务中，代理配置是常见需求。本教程将详细介绍在 Spring Integration 中配置 HTTP 代理的两种核心方法。

一、HTTP 代理配置概述

为什么需要代理配置

当您的应用部署在企业内网环境或云服务私有网络中时，访问外部 HTTP/HTTPS 服务通常需要通过代理服务器。没有正确配置代理会导致连接超时错误：

java.net.ConnectException: Connection timed out

两种配置方法对比

方法	适用场景	优点	缺点
Java 系统属性	简单代理需求	全局生效，配置简单	灵活性低，影响所有 HTTP 连接
Spring RequestFactory	复杂代理需求	细粒度控制，支持多代理	需要额外编码，配置复杂

最佳实践建议

对于简单应用优先使用 Java 系统属性配置，对于企业级应用推荐使用 Spring 的 SimpleClientHttpRequestFactory 方案

二、标准 Java 代理配置

基础配置属性

通过 JVM 启动参数配置代理是最简单的方法：

# HTTP 代理配置
-Dhttp.proxyHost=proxy.example.com 
-Dhttp.proxyPort=8080

# HTTPS 代理配置
-Dhttps.proxyHost=secure-proxy.example.com
-Dhttps.proxyPort=8443

排除特定地址

使用 http.nonProxyHosts 排除不需要代理的内部地址：

# 排除 .internal 域名和本地地址
-Dhttp.nonProxyHosts="*.internal|localhost|127.*|[::1]"

NOTE

通配符 * 使用规则：

• *.example.com 匹配所有 example.com 子域名
• 192.168.* 匹配 192.168.x.x 所有 IP
• example* 匹配 exampledomain, exampletest 等

配置示例代码

在 Spring Boot 启动类中动态设置：

@SpringBootApplication
class MyApp {
    companion object {
        @JvmStatic
        fun main(args: Array<String>) {
            // 动态设置代理系统属性
            System.setProperty("http.proxyHost", "corp-proxy.company.com")
            System.setProperty("http.proxyPort", "3128")
            System.setProperty("http.nonProxyHosts", "localhost|*.internal")
            
            runApplication<MyApp>(*args)
        }
    }
}

注意事项

1. 系统属性是全局生效的，会影响应用中所有 HTTP 连接
2. 在容器化环境中，建议通过环境变量配置
3. HTTPS 代理需要单独设置 https.proxy* 属性

三、Spring RequestFactory 方案

配置核心组件

使用 Kotlin DSL 配置代理工厂：

@Configuration
class ProxyConfig {

    @Bean
    fun proxiedRequestFactory(): ClientHttpRequestFactory {
        val requestFactory = SimpleClientHttpRequestFactory()
        
        // 创建代理对象
        val proxy = Proxy(
            Proxy.Type.HTTP, 
            InetSocketAddress("proxy.company.com", 8080)
        )
        
        requestFactory.setProxy(proxy)
        return requestFactory
    }
}

在 HTTP 出站网关中使用

@Bean
fun httpOutboundGateway(): IntegrationFlow {
    return IntegrationFlow.from("requestChannel")
        .handle(Http.outboundGateway("/api/data")
            .httpMethod(HttpMethod.GET)
            .requestFactory(proxiedRequestFactory()) // 注入代理配置
            .expectedResponseType(String::class.java))
        .get()
}

多环境配置方案

结合 Spring Profiles 实现环境隔离：

@Configuration
class EnvironmentProxyConfig {

    @Bean
    @Profile("dev")
    fun devRequestFactory(): ClientHttpRequestFactory {
        return SimpleClientHttpRequestFactory().apply {
            setProxy(Proxy(Proxy.Type.HTTP, InetSocketAddress("dev-proxy", 8080)))
        }
    }

    @Bean
    @Profile("prod")
    fun prodRequestFactory(): ClientHttpRequestFactory {
        return SimpleClientHttpRequestFactory().apply {
            setProxy(Proxy(Proxy.Type.HTTP, InetSocketAddress("prod-proxy", 3128)))
        }
    }
}

带认证的代理配置

fun authenticatedProxyFactory(): ClientHttpRequestFactory {
    return SimpleClientHttpRequestFactory().apply {
        setProxy(Proxy(Proxy.Type.HTTP, InetSocketAddress("auth-proxy", 8080)))
        
        // 添加代理认证
        this.setAsyncExecutor(AsyncListenableTaskExecutor().apply {
            setCredentialsProvider(object : CredentialsProvider {
                override fun getCredentials(authscope: AuthScope?): Credentials {
                    return UsernamePasswordCredentials("proxyuser", "proxypass")
                }
            })
        })
    }
}

四、方案对比与选择指南

决策流程图

性能对比

指标	Java 系统属性	Spring RequestFactory
启动速度	⚡️ 快（无需初始化Bean）	⏳ 中等（需要初始化）
运行时性能	⚖️ 稳定	⚖️ 稳定
连接复用	✅ 支持	✅ 支持
配置灵活性	❌ 有限	✅ 极高

关键注意事项

1. 代理协议选择：确保 Proxy.Type 匹配实际协议（HTTP/HTTPS/SOCKS）
2. DNS 解析：代理主机名必须能被正确解析
3. 防火墙设置：确保应用服务器能访问代理端口
4. 连接池配置：高并发场景需要调整连接池参数

五、常见问题解决方案

问题1：代理配置不生效

解决方案：

// 添加调试代码验证配置
fun logProxySettings() {
    println("HTTP Proxy: ${System.getProperty("http.proxyHost")}:${System.getProperty("http.proxyPort")}")
    println("Non-Proxy Hosts: ${System.getProperty("http.nonProxyHosts")}")
}

问题2：HTTPS 证书错误

解决方案：定制 SSL 上下文

@Bean
fun sslContext(): SSLContext {
    return SSLContext.getInstance("TLS").apply {
        init(null, arrayOf(trustAllCerts), SecureRandom())
    }
}

private val trustAllCerts = arrayOf<TrustManager>(object : X509TrustManager {
    override fun checkClientTrusted(chain: Array<X509Certificate>, authType: String) {}
    override fun checkServerTrusted(chain: Array<X509Certificate>, authType: String) {}
    override fun getAcceptedIssuers(): Array<X509Certificate> = arrayOf()
})

问题3：连接超时

解决方案：优化超时设置

requestFactory.setConnectTimeout(5000)  // 5秒连接超时
requestFactory.setReadTimeout(10000)    // 10秒读取超时

TIP

使用连接池提升性能：

val pool = PoolingHttpClientConnectionManager().apply {
    maxTotal = 100
    defaultMaxPerRoute = 20
}
val client = HttpClients.custom().setConnectionManager(pool).build()

六、最佳实践总结

1. 环境隔离：使用 Spring Profiles 区分不同环境的代理配置
2. 安全存储：将代理凭据存储在安全的配置中心（如 Vault）
3. 健康检查：添加代理服务器健康监测

   @Scheduled(fixedRate = 300000)
   fun checkProxyHealth() {
       try {
           Socket().use { socket ->
               socket.connect(InetSocketAddress(proxyHost, proxyPort), 5000)
           }
       } catch (e: Exception) {
           logger.error("Proxy server unreachable!", e)
       }
   }

4. 故障转移：实现多代理自动切换机制
5. 监控指标：通过 Micrometer 暴露代理相关指标

最终建议

对于生产环境，推荐组合使用两种方案：

• 基础代理通过系统属性配置
• 特殊需求通过 RequestFactory 定制 这样既保证灵活性又减少复杂配置

✅ 掌握这些代理配置技巧后，您的 Spring 应用将能无缝接入企业网络环境，安全高效地访问外部 HTTP 服务！