Apache Camel CXF:以编程方式添加TlsClientParameters

Question

我使用Apache Camel CXF作为生产者来调用SOAP Webservice。我不使用Spring配置，而是以编程方式完成所有工作（我是初学者，希望防止同时学习Spring和Apache Camel）。Webservice使用带有自签名证书的SSL。我将其添加到信任库中，并希望能够将其添加到CxfEndpoint，就像我使用http 4所做的那样：

KeyStoreParameters ksp = new KeyStoreParameters();
ksp.setResource("src/main/resources/truststore.jks");
ksp.setPassword("...");

KeyManagersParameters kmp = new KeyManagersParameters();
kmp.setKeyStore(ksp);
kmp.setKeyPassword("...");

SSLContextParameters scp = new SSLContextParameters();
scp.setKeyManagers(kmp);

CamelContext context = new DefaultCamelContext();
context.addRoutes(routeBuilder);

HttpComponent httpComponent = context.getComponent("https4", HttpComponent.class);
httpComponent.setSslContextParameters(scp);

– 但这似乎不适用于 CxfComponent。我找到了很多关于使用 Spring 添加 TlsClientParameters 和配置 CxfEndpoint 的文档，例如：apache camel cxf https 不起作用，这里使用 CXF 和 Camel 调用安全 Web 服务。但是，我没有找到任何关于如何简单地向组件添加信任库的提示，就像我对 https4 所做的那样，甚至在路由定义中，即：

from(ENDPOINT_URI)
.setProperty(SecurityConstants.PASSWORD, constant(PASSWORD))
.setProperty(SecurityConstants.USERNAME, constant(USERNAME))
.to("cxf://" + SERVICE_URL + "?" +
     "wsdlURL=" + WSDL_URL + "&" +
      "serviceName=" + SERVICE_NAME + "&" +
      "portName=" + PORT_NAME + "&" +
      "dataFormat=CXF_MESSAGE&" +
      "synchronous=true&" +
      "defaultOperationName=" + DEFAULT_OPERATION_NAME)
.streamCaching();

我认为这一定是一个非常简单的问题，所以我仍然希望有一些巧妙的方法可以简单地添加信任库（甚至接受任何证书，因为它与我们的用例并不真正相关）。如果有一个简单的程序化方式，我会很高兴。有人知道吗？

Answer 1

我通过将证书添加到jre/lib/cacert中的JVM信任库来解决这个问题。这是可行的，因为我可以访问运行应用程序的机器上的JVM。这似乎是最简单的解决方案。

更新

如果有人对更合适的解决方案感兴趣：CxfEndpoint提供了一种影响HTTPConduct及其TLS参数的方法。这是修订后的代码：

>

将“cxfEndpointConfigurer=SageEndpointConfigurer”添加到cxfendpoint参数

创建endpoint时，将使用TypeConverters解析“SageEndpointConfigurer”

将TypeConverter添加到上下文的TypeConverter注册表中，即直接在RouteBuildergetContext（）.getTypeConverterRegistry（）.addTypeConverter（CxfEndpointConfigurer.class，String.class，newSageEndpointConfigurerConverter（））中

配置TLSParameters，只需从TypeConverter返回CxfEndpointConfigurer

private class SageEndpointConfigurerConverter extends TypeConverterSupport {

@Override
public <T> T convertTo(Class<T> type, Exchange exchange, Object value) throws TypeConversionException {
    CxfEndpointConfigurer configurer = new CxfEndpointConfigurer() {
        @Override
        public void configure(AbstractWSDLBasedEndpointFactory factoryBean) {
            // do nothing
        }

        @Override
        public void configureClient(Client client) {
            URLConnectionHTTPConduit conduit = (URLConnectionHTTPConduit) client.getConduit();
            TLSClientParameters tlsParams = new TLSClientParameters();
            tlsParams.setDisableCNCheck(true);
            tlsParams.setTrustManagers(new TrustManager[]{new TrustAllTrustManager()});
            conduit.setTlsClientParameters(tlsParams);
        }

        @Override
        public void configureServer(Server server) {
            //do nothing
        }
    };
    return (T) configurer;
}
}

TrustAllManager 是这样实现的

public class TrustAllTrustManager implements X509TrustManager {

private static Logger LOG = LoggerFactory.getLogger(TrustAllTrustManager.class);

@Override
public void checkClientTrusted(X509Certificate[] x509Certificates, String authType) throws CertificateException {
//do nothing, trust all certificates
logMessage(x509Certificates, authType);
}

@Override
public void checkServerTrusted(X509Certificate[] x509Certificates, String authType) throws CertificateException {
//do nothing, trust all certificates
logMessage(x509Certificates, authType);
}

@Override
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[0];
}

private void logMessage(X509Certificate[] x509Certificates, String authType) {
StringBuilder message = new StringBuilder();
String lineSeparator = System.getProperty("line.separator");
message.append("Trusted following certificates for authentication type '").append(authType).append("'").append(lineSeparator);
for (X509Certificate certificate : x509Certificates) {
    message.append(certificate).append(lineSeparator);
}
LOG.trace(message.toString());
}
}