|
@ -5,6 +5,11 @@ import camel.central.gateway.processor.GatewayProcessor;
|
|
|
import camel.central.gateway.processor.WsProcessor;
|
|
|
import org.apache.camel.Exchange;
|
|
|
import org.apache.camel.builder.RouteBuilder;
|
|
|
import org.apache.camel.component.jetty.JettyHttpComponent;
|
|
|
import org.apache.camel.util.jsse.KeyManagersParameters;
|
|
|
import org.apache.camel.util.jsse.KeyStoreParameters;
|
|
|
import org.apache.camel.util.jsse.SSLContextParameters;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
/**
|
|
@ -20,22 +25,28 @@ public class GatewayRouterBuilder extends RouteBuilder {
|
|
|
// + "&dataFormat=CXF_MESSAGE"
|
|
|
;
|
|
|
|
|
|
@Value("${hos.https.enable}")
|
|
|
private Boolean httpsEnable;
|
|
|
|
|
|
@Override
|
|
|
public void configure() throws Exception {
|
|
|
//全局ssl设置
|
|
|
// KeyStoreParameters ksparams = new KeyStoreParameters();
|
|
|
// ksparams.setResource("D:/tomcat.keystore");
|
|
|
// ksparams.setPassword("123456");
|
|
|
//
|
|
|
// KeyManagersParameters kmp = new KeyManagersParameters();
|
|
|
// kmp.setKeyStore(ksparams);
|
|
|
// kmp.setKeyPassword("123456");
|
|
|
//
|
|
|
// SSLContextParameters scp = new SSLContextParameters();
|
|
|
// scp.setKeyManagers(kmp);
|
|
|
//
|
|
|
// JettyHttpComponent jettyComponent = getContext().getComponent("jetty", JettyHttpComponent.class);
|
|
|
// jettyComponent.setSslContextParameters(scp);
|
|
|
|
|
|
if (httpsEnable) {
|
|
|
//全局ssl设置
|
|
|
KeyStoreParameters ksparams = new KeyStoreParameters();
|
|
|
ksparams.setResource("tomcat.keystore");
|
|
|
ksparams.setPassword("123456");
|
|
|
|
|
|
KeyManagersParameters kmp = new KeyManagersParameters();
|
|
|
kmp.setKeyStore(ksparams);
|
|
|
kmp.setKeyPassword("123456");
|
|
|
|
|
|
SSLContextParameters scp = new SSLContextParameters();
|
|
|
scp.setKeyManagers(kmp);
|
|
|
|
|
|
JettyHttpComponent jettyComponent = getContext().getComponent("jetty", JettyHttpComponent.class);
|
|
|
jettyComponent.setSslContextParameters(scp);
|
|
|
}
|
|
|
|
|
|
//EHR ag-admin网关代理
|
|
|
from("jetty:http://0.0.0.0:9998?matchOnUriPrefix=true").routeId("proxy")
|