|
@ -9,6 +9,7 @@ import org.apache.camel.component.jetty.JettyHttpComponent;
|
|
import org.apache.camel.util.jsse.KeyManagersParameters;
|
|
import org.apache.camel.util.jsse.KeyManagersParameters;
|
|
import org.apache.camel.util.jsse.KeyStoreParameters;
|
|
import org.apache.camel.util.jsse.KeyStoreParameters;
|
|
import org.apache.camel.util.jsse.SSLContextParameters;
|
|
import org.apache.camel.util.jsse.SSLContextParameters;
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
/**
|
|
/**
|
|
@ -24,22 +25,28 @@ public class GatewayRouterBuilder extends RouteBuilder {
|
|
// + "&dataFormat=CXF_MESSAGE"
|
|
// + "&dataFormat=CXF_MESSAGE"
|
|
;
|
|
;
|
|
|
|
|
|
|
|
@Value("${hos.https.enable}")
|
|
|
|
private Boolean httpsEnable;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void configure() throws Exception {
|
|
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");
|
|
|
|
|
|
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);
|
|
|
|
|
|
SSLContextParameters scp = new SSLContextParameters();
|
|
|
|
scp.setKeyManagers(kmp);
|
|
|
|
|
|
JettyHttpComponent jettyComponent = getContext().getComponent("jetty", JettyHttpComponent.class);
|
|
|
|
jettyComponent.setSslContextParameters(scp);
|
|
|
|
|
|
JettyHttpComponent jettyComponent = getContext().getComponent("jetty", JettyHttpComponent.class);
|
|
|
|
jettyComponent.setSslContextParameters(scp);
|
|
|
|
}
|
|
|
|
|
|
//EHR ag-admin网关代理
|
|
//EHR ag-admin网关代理
|
|
from("jetty:http://0.0.0.0:9998?matchOnUriPrefix=true").routeId("proxy")
|
|
from("jetty:http://0.0.0.0:9998?matchOnUriPrefix=true").routeId("proxy")
|
|
@ -62,7 +69,7 @@ public class GatewayRouterBuilder extends RouteBuilder {
|
|
.routingSlip(method(GatewayProcessor.class, "route"))
|
|
.routingSlip(method(GatewayProcessor.class, "route"))
|
|
.to("bean:wsProcessor?method=responseWs");
|
|
.to("bean:wsProcessor?method=responseWs");
|
|
|
|
|
|
from("direct:errorHandle")
|
|
|
|
|
|
from("direct:errorHandle")
|
|
.choice()
|
|
.choice()
|
|
.when(header(Exchange.HTTP_URI).contains("paramError")).bean(new ErrorHandle(), "paramError")
|
|
.when(header(Exchange.HTTP_URI).contains("paramError")).bean(new ErrorHandle(), "paramError")
|
|
.when(header(Exchange.HTTP_URI).contains("outdateError")).bean(new ErrorHandle(), "outdateError")
|
|
.when(header(Exchange.HTTP_URI).contains("outdateError")).bean(new ErrorHandle(), "outdateError")
|