如何在连接https URL和TLS Certificate时使用Apache camel http4组件设置代理

Question

我一直在工作的Apache骆驼连接https URLS'通过提供TLS证书通过代理，但得到错误org.apache.http.conn.不支持的模式异常：超文本传输协议不支持

下面是驼峰路由和带有代理的ssl上下文

公共类HttpProxyRouter扩展了RouteBuilder{

@Override
public void configure() throws Exception { 
    configureSslForHttp4(getContext());
    from("direct:httpproxy") 
    .log("Invoking dhttpproxy")
    .setHeader("CamelHttpMethod") 
    .simple("GET").setHeader("Accept")
    .simple(Constants.JSON_MEDIA_TYPE_VALUE) 
    .setHeader(Exchange.HTTP_PATH)
    .simple("{{http.proxy.path}}") 
    .setHeader(Exchange.REST_HTTP_QUERY)
    .simple("{{http.proxy.query.param}}") 
    .to("{{http.proxy.url}}")
    .log("The Retrival of CCO subscription API response code is: ${header.CamelHttpResponseCode}, JSON Response ${body}") 
    .end(); 
}

private void configureSslForHttp4(CamelContext camelContext) {
    KeyStore truststore = KeyStore.getInstance("JKS");
    truststore.load(getClass().getClassLoader().getResourceAsStream("H:\config/AL/certpath/cert/keystore.jks"), "njfeijiiii".toCharArray()); 

    TrustManagerFactory trustFactory = TrustManagerFactory.getInstance("SunX509"); 
    trustFactory.init(truststore);
    SSLContext sslcontext = SSLContext.getInstance("TLS");
    sslcontext.init(null, trustFactory.getTrustManagers(), null);
    SSLSocketFactory factory = new SSLSocketFactory(sslcontext, SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER);
    SchemeRegistry registry = new SchemeRegistry(); 
    final Scheme scheme = new Scheme("https4", 443, factory);
    registry.register(scheme);
    HttpComponent http4 = camelContext.getComponent("https4", HttpComponent.class); 
    http4.setHttpClientConfigurer(new HttpClientConfigurer() {
        @Override 
        public void configureHttpClient(HttpClientBuilder builder) {
            builder.setSSLSocketFactory(factory); 
            HttpHost proxy = new HttpHost("MYcompany.proxy",8080); 
            builder.setProxy(proxy); 
            builder.setRoutePlanner(new DefaultProxyRoutePlanner(proxy)); 
            Registry registry = RegistryBuilder.create().register("https", factory).build(); 
            HttpClientConnectionManager connectionManager = new BasicHttpClientConnectionManager(registry);
            builder.setConnectionManager(connectionManager); 
        }}); 
}

}

遇到错误

org.apache.catalina.core.Application Context logINFO：初始化Spring FrameworkServlet'调度Servlet'43953[超文本传输协议-nio-6723-exec-2]INFOorg.springframework.web.servlet.DispatcherServlet'调度Servlet'：初始化开始44033[超文本传输协议-nio-6723-exec-2]INFOorg.springframework.web.servlet.DispatcherServlet-FrameworkServlet'调度Servlet'：初始化完成80 ms44126[超文本传输协议-nio-6723-exec-2]INFOcom.db.gtbb.adapter.controller.HttpProxyRestController-httpProxyHandler已启动！44152[超文本传输协议-nio-6723-exec-2]INFO route1-调用dhttpprox44291[超文本传输协议-nio-6723-exec-2]INFOorg.apache.http.impl.execchain.RetryExec-I/O异常（org.apache.http.conn.Unsupport tedSchemeException）在处理{tls}的请求时捕获-

Answer 1

您需要将http协议添加到注册表：

SSLConnectionSocketFactory sslSocketFactory = new SSLConnectionSocketFactory(sslctxt, hnv);

Registry<ConnectionSocketFactory> lookup = RegistryBuilder.<ConnectionSocketFactory>create()
                .register("http", PlainConnectionSocketFactory.INSTANCE)
                .register("https", sslSocketFactory).build();