https 暂注释

hos-camel2/src/main/java/camel/central/archives/route/ArchivesMqRouter.java

@@ -11,6 +11,7 @@ import org.springframework.stereotype.Component;
import javax.jms.ConnectionFactory;
/**
 *  档案入库流程
 * @created Airhead 2016/8/1.
 */
@Component

hos-camel2/src/main/java/camel/central/gateway/processor/GatewayProcessor.java

@@ -49,26 +49,26 @@ public class GatewayProcessor implements Processor {
        Map<String, Object> params = exchange.getIn().getHeaders();
        if (params.get("appKey") == null) {
            exchange.getOut().setHeader(Exchange.HTTP_URI,"paramError");
            return "direct:errorHandle";    //TODO:
            return "direct:errorHandle";
        }
        String appKey = params.get("appKey").toString();
        String secret = getSecret(appKey);
        if (secret.equals("")) {
            exchange.getOut().setHeader(Exchange.HTTP_URI,"paramError");
            return "direct:errorHandle";    //TODO:
            return "direct:errorHandle";
        }
        boolean pass = checkParams(params);
        if (!pass) {
            exchange.getOut().setHeader(Exchange.HTTP_URI,"paramError");
            return "direct:errorHandle";    //TODO:
            return "direct:errorHandle";
        }
        pass = checkTimeStamp(params);
        if (!pass) {
            exchange.getOut().setHeader(Exchange.HTTP_URI,"outdateError");
            return "direct:errorHandle";    //TODO:
            return "direct:errorHandle";
        }
        //获取secret接口，不做sign验证
@@ -76,14 +76,14 @@ public class GatewayProcessor implements Processor {
            pass = checkSign(params, secret);
            if (!pass) {
                exchange.getOut().setHeader(Exchange.HTTP_URI,"signValidError");
                return "direct:errorHandle";    //TODO:
                return "direct:errorHandle";
            }
        }
        pass = checkAuthorized(params);
        if (!pass) {
            exchange.getOut().setHeader(Exchange.HTTP_URI,"unauthorizedError");
            return "direct:errorHandle";    //TODO:
            return "direct:errorHandle";
        }
        return genEndpoint(params, exchange);

hos-camel2/src/main/java/camel/central/gateway/route/GatewayRouterBuilder.java

@@ -5,10 +5,6 @@ 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.stereotype.Component;
/**
@@ -27,19 +23,19 @@ public class GatewayRouterBuilder extends RouteBuilder {
    @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);
//        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);
        //EHR ag-admin网关代理
        from("jetty:http://0.0.0.0:9998?matchOnUriPrefix=true").routeId("proxy")
@@ -62,7 +58,8 @@ public class GatewayRouterBuilder extends RouteBuilder {
                .routingSlip(method(GatewayProcessor.class, "route"))
                .to("bean:wsProcessor?method=responseWs");
                from("direct:errorHandle")
        //统一网关错误代码返回
        from("direct:errorHandle")
                .choice()
                .when(header(Exchange.HTTP_URI).contains("paramError")).bean(new ErrorHandle(), "paramError")
                .when(header(Exchange.HTTP_URI).contains("outdateError")).bean(new ErrorHandle(), "outdateError")