修改目录结构

hos-broker/src/main/java/com/yihu/hos/broker/controllers/GatewayController.java

@@ -25,7 +25,7 @@ public class GatewayController {
        this.gatewayService = gatewayService;
    }
    @RequestMapping(value = "/camel.gateway", method = RequestMethod.POST)
    @RequestMapping(value = "/camel.central.gateway", method = RequestMethod.POST)
    public void transfer(HttpServletRequest request, HttpServletResponse response) throws Exception {
        request.setCharacterEncoding("UTF-8");
        response.setContentType("application/json;charset=UTF-8");

hos-camel2/src/main/java/camel/gateway/processor/ApiParam.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
/**
 * @author Airhead

hos-camel2/src/main/java/camel/gateway/processor/AppApi.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

hos-camel2/src/main/java/camel/gateway/processor/ErrorHandle.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import org.apache.camel.Exchange;
import org.springframework.stereotype.Component;

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

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

hos-camel2/src/main/java/camel/gateway/processor/ParamVerifyBean.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import com.yihu.hos.core.encrypt.MD5;

hos-camel2/src/main/java/camel/gateway/processor/SignProcessor.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yihu.hos.core.datatype.StringUtil;

hos-camel2/src/main/java/camel/gateway/processor/WsProcessor.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;

hos-camel2/src/main/java/camel/gateway/processor/WsService.java

@@ -1,4 +1,4 @@
package camel.gateway.processor;
package camel.central.gateway.processor;
import javax.jws.WebMethod;
import javax.jws.WebParam;

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

@@ -1,8 +1,8 @@
package camel.gateway.route;
package camel.central.gateway.route;
import camel.gateway.processor.ErrorHandle;
import camel.gateway.processor.GatewayProcessor;
import camel.gateway.processor.WsProcessor;
import camel.central.gateway.processor.ErrorHandle;
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.springframework.stereotype.Component;
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component;
public class GatewayRouterBuilder extends RouteBuilder {
    protected static final String SIMPLE_ENDPOINT_ADDRESS = "http://0.0.0.0:3333/ws/api";
    protected static final String SIMPLE_ENDPOINT_URI = "cxf:" + SIMPLE_ENDPOINT_ADDRESS
            + "?serviceClass=camel.gateway.processor.WsService"
            + "?serviceClass=camel.central.gateway.processor.WsService"
//            + "&dataFormat=CXF_MESSAGE"
            ;

hos-camel2/src/main/java/camel/gateway/route/GatewayToolBuilder.java

@@ -1,6 +1,6 @@
package camel.gateway.route;
package camel.central.gateway.route;
import camel.gateway.processor.SignProcessor;
import camel.central.gateway.processor.SignProcessor;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;

hos-camel2/src/main/java/camel/qlc/processor/Processor0.java

@@ -1,4 +1,4 @@
package camel.qlc.processor;
package camel.central.qlc.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
@@ -12,7 +12,7 @@ public class Processor0 implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        HttpMessage inMessage = (HttpMessage) exchange.getIn();
        String queryString = "api=camel.qlc&param=" + inMessage.getRequest().getParameterValues("data")[0];
        String queryString = "api=camel.central.qlc&param=" + inMessage.getRequest().getParameterValues("data")[0];
        outMessage.setHeader(Exchange.HTTP_QUERY, queryString);
    }

hos-camel2/src/main/java/camel/qlc/processor/Processor1.java

@@ -1,4 +1,4 @@
package camel.qlc.processor;
package camel.central.qlc.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/qlc/processor/Processor2.java

@@ -1,4 +1,4 @@
package camel.qlc.processor;
package camel.central.qlc.processor;
import net.sf.json.JSONObject;
import org.apache.camel.Exchange;

hos-camel2/src/main/java/camel/qlc/route/QlcRouteBulider.java

@@ -1,9 +1,9 @@
package camel.qlc.route;
package camel.central.qlc.route;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import camel.qlc.processor.Processor1;
import camel.qlc.processor.Processor2;
import camel.central.qlc.processor.Processor1;
import camel.central.qlc.processor.Processor2;
/**
 * Created by lingfeng on 2016/7/25.
@@ -12,11 +12,11 @@ public class QlcRouteBulider extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("jetty:http4://172.17.110.178:9088/camel.qlc").routeId("camel/qlc")
        from("jetty:http4://172.17.110.178:9088/camel.central.qlc").routeId("camel/central/qlc")
                .process(new Processor1()).setHeader(Exchange.HTTP_METHOD, constant("POST")).log("servers: 3,code: queryUserInfo,order: 1")
                .to("http4://172.19.103.89:8088/api/v1.0/camel.qlc/queryUserInfo").log("servers: 3,code: queryUserInfo,order: 1")
                .to("http4://172.19.103.89:8088/api/v1.0/camel.central.qlc/queryUserInfo").log("servers: 3,code: queryUserInfo,order: 1")
                .process(new Processor2()).setHeader(Exchange.HTTP_METHOD, constant("POST")).log("servers: 3,code: patientInformation,order: 1")
                .to("http4://172.19.103.89:8088/api/v1.0/camel.qlc/patientInformation").log("servers: 3,code: patientInformation,order: 1")
                .to("http4://172.19.103.89:8088/api/v1.0/camel.central.qlc/patientInformation").log("servers: 3,code: patientInformation,order: 1")
                .process(new Processor2()).setHeader(Exchange.HTTP_METHOD, constant("POST")).to("stream:out"); // 2. 为路由配置组件或终端节点.
    }
}

hos-camel2/src/main/java/camel/api1/processor/ApiProcessor.java

@@ -1,4 +1,4 @@
package camel.api1.processor;
package camel.demo.api1.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/api1/route/ApiRouteBulider.java

@@ -1,13 +1,13 @@
package camel.api1.route;
package camel.demo.api1.route;
import camel.api1.processor.ApiProcessor;
import camel.demo.api1.processor.ApiProcessor;
import org.apache.camel.builder.RouteBuilder;
public class ApiRouteBulider extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("jetty:http://0.0.0.0:9097/api/v7").routeId("camel/api1")
        from("jetty:http://0.0.0.0:9097/api/v7").routeId("camel/demo/api1")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
        from("jetty:http://0.0.0.0:9097/rest").routeId("restTest")

hos-camel2/src/main/java/camel/api7/processor/ApiProcessor.java

@@ -1,4 +1,4 @@
package camel.api7.processor;
package camel.demo.api7.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/api7/processor/TestClient.java

@@ -1,4 +1,4 @@
package camel.api7.processor;
package camel.demo.api7.processor;
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;

hos-camel2/src/main/java/camel/api7/processor/TestWService.java

@@ -1,4 +1,4 @@
package camel.api7.processor;
package camel.demo.api7.processor;
import javax.jws.WebMethod;
import javax.jws.WebParam;

hos-camel2/src/main/java/camel/api7/processor/TestWsConfig.java

@@ -1,4 +1,4 @@
package camel.api7.processor;
package camel.demo.api7.processor;
import org.apache.cxf.Bus;
import org.apache.cxf.bus.spring.SpringBus;

hos-camel2/src/main/java/camel/api7/processor/ToWsProcessor.java

@@ -1,4 +1,4 @@
package camel.api7.processor;
package camel.demo.api7.processor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.dataformat.xml.XmlMapper;

hos-camel2/src/main/java/camel/api7/route/ApiRouteBulider.java

@@ -1,13 +1,13 @@
package camel.api7.route;
package camel.demo.api7.route;
import camel.api7.processor.ApiProcessor;
import camel.demo.api7.processor.ApiProcessor;
import org.apache.camel.builder.RouteBuilder;
public class ApiRouteBulider extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("jetty:http://0.0.0.0:9097/api/v1").routeId("camel/api7")
        from("jetty:http://0.0.0.0:9097/api/v1").routeId("camel/demo/api7")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel2/src/main/java/camel/api7/route/CxfConsumerTest.java

@@ -1,7 +1,7 @@
package camel.api7.route;
package camel.demo.api7.route;
import camel.api7.processor.ToWsProcessor;
import camel.gateway.processor.GatewayProcessor;
import camel.demo.api7.processor.ToWsProcessor;
import camel.central.gateway.processor.GatewayProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
public class CxfConsumerTest extends RouteBuilder {
    protected static final String SIMPLE_ENDPOINT_ADDRESS = "http://127.0.0.1:4445/soap/ws";
    protected static final String SIMPLE_ENDPOINT_URI = "cxf:" + SIMPLE_ENDPOINT_ADDRESS
            + "?serviceClass=camel.api7.processor.TestWService"
            + "?serviceClass=camel.demo.api7.processor.TestWService"
//            + "&dataFormat=CXF_MESSAGE"
            ;

hos-camel2/src/main/java/camel/collect/processor/CollectProcessor0.java

@@ -1,4 +1,4 @@
package camel.collect.processor;
package camel.demo.collect.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/collect/route/CollectQuartzRoute.java

@@ -1,6 +1,6 @@
package camel.collect.route;
package camel.demo.collect.route;
import camel.collect.processor.CollectProcessor0;
import camel.demo.collect.processor.CollectProcessor0;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;

hos-camel2/src/main/java/camel/quartz2/processor/Quartz2Processor.java

@@ -1,4 +1,4 @@
package camel.quartz2.processor;
package camel.demo.quartz2.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/quartz2/route/Quartz2Route.java

@@ -1,6 +1,6 @@
package camel.quartz2.route;
package camel.demo.quartz2.route;
import camel.quartz2.processor.Quartz2Processor;
import camel.demo.quartz2.processor.Quartz2Processor;
import org.apache.camel.builder.RouteBuilder;
public class Quartz2Route  extends RouteBuilder {

hos-camel2/src/main/java/camel/crawler/processor/Aggregate.java

@@ -1,4 +1,4 @@
package camel.crawler.processor;
package camel.terminal.crawler.processor;
import org.apache.camel.Exchange;
import org.apache.camel.processor.aggregate.AggregationStrategy;

hos-camel2/src/main/java/camel/crawler/processor/AggregateProcessor.java

@@ -1,4 +1,4 @@
package camel.crawler.processor;
package camel.terminal.crawler.processor;
import net.sf.json.JSONObject;
import org.apache.camel.Exchange;

hos-camel2/src/main/java/camel/crawler/processor/DefaultHttpProcessor.java

@@ -1,4 +1,4 @@
package camel.crawler.processor;
package camel.terminal.crawler.processor;
import com.yihu.hos.core.datatype.StringUtil;
import net.sf.json.JSONObject;

hos-camel2/src/main/java/camel/crawler/processor/HttpProcessor.java

@@ -1,4 +1,4 @@
package camel.crawler.processor;
package camel.terminal.crawler.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/crawler/processor/Split.java

@@ -1,4 +1,4 @@
package camel.crawler.processor;
package camel.terminal.crawler.processor;
import net.sf.json.JSONArray;
import org.apache.camel.Body;

hos-camel2/src/main/java/camel/crawler/route/CrawlerQuartzRoute.java

@@ -1,6 +1,6 @@
package camel.crawler.route;
package camel.terminal.crawler.route;
import camel.crawler.processor.DefaultHttpProcessor;
import camel.terminal.crawler.processor.DefaultHttpProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;

hos-camel2/src/main/java/camel/crawler/route/CrawlerRouteBulider.java

@@ -1,6 +1,6 @@
package camel.crawler.route;
package camel.terminal.crawler.route;
import camel.crawler.processor.DefaultHttpProcessor;
import camel.terminal.crawler.processor.DefaultHttpProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
@@ -14,18 +14,18 @@ public class CrawlerRouteBulider extends RouteBuilder {
        from("jetty:http://192.168.131.96:8066/crawlerPull").routeId("crawlerPull")
                .process(new DefaultHttpProcessor("{\"jobId\":\"5ad5c11655d443c30155d477a6b10000\"}")).setHeader(Exchange.HTTP_METHOD, constant("POST"))
                .to("http://192.168.131.96:8088/camel.crawler/patientList");
                .to("http://192.168.131.96:8088/camel.terminal.crawler/patientList");
        from("jetty:http://192.168.131.96:8066/crawlerPush").routeId("crawlerPush")
                .process(new DefaultHttpProcessor("{\"jobId\":\"5ad5c11655d443c30155d477a6b10000\"}")).setHeader(Exchange.HTTP_METHOD, constant("POST"))
                .to("http://192.168.131.96:8088/camel.crawler/patient");
                .to("http://192.168.131.96:8088/camel.terminal.crawler/patient");
        from("jetty:http://192.168.131.96:8066/crawlerFlowPull").routeId("crawlerFlowPull")
                .process(new DefaultHttpProcessor("{\"jobId\":\"5ad5c11655d443c30155d477a6b10000\"}")).setHeader(Exchange.HTTP_METHOD, constant("POST"))
                .to("http://192.168.131.96:8088/camel.crawler/patientListFlow");
                .to("http://192.168.131.96:8088/camel.terminal.crawler/patientListFlow");
        from("jetty:http://192.168.131.96:8066/crawlerFlowPush").routeId("crawlerFlowPush")
                .process(new DefaultHttpProcessor("{\"jobId\":\"5ad5c11655d443c30155d477a6b10000\"}")).setHeader(Exchange.HTTP_METHOD, constant("POST"))
                .to("http://192.168.131.96:8088/camel.crawler/patientFlow");
                .to("http://192.168.131.96:8088/camel.terminal.crawler/patientFlow");
    }
}

hos-camel2/src/main/java/camel/crawler/route/QuartzRoute.java

@@ -1,6 +1,6 @@
package camel.crawler.route;
package camel.terminal.crawler.route;
import camel.crawler.processor.DefaultHttpProcessor;
import camel.terminal.crawler.processor.DefaultHttpProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;

hos-camel2/src/main/java/camel/crawler/route/RouteBulider1.java

@@ -1,9 +1,9 @@
package camel.crawler.route;
package camel.terminal.crawler.route;
import camel.crawler.processor.Aggregate;
import camel.crawler.processor.AggregateProcessor;
import camel.crawler.processor.HttpProcessor;
import camel.crawler.processor.Split;
import camel.terminal.crawler.processor.Aggregate;
import camel.terminal.crawler.processor.AggregateProcessor;
import camel.terminal.crawler.processor.HttpProcessor;
import camel.terminal.crawler.processor.Split;
import org.apache.camel.builder.RouteBuilder;
/**

hos-camel2/src/main/java/camel/qcrule/processor/PatientProcessor.java

@@ -1,4 +1,4 @@
package camel.qcrule.processor;
package camel.terminal.qcrule.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;

hos-camel2/src/main/java/camel/qcrule/processor/QcHttpProcessor.java

@@ -1,4 +1,4 @@
package camel.qcrule.processor;
package camel.terminal.qcrule.processor;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;

hos-camel2/src/main/java/camel/qcrule/router/QcCrawlerRoute.java

@@ -1,8 +1,8 @@
package camel.qcrule.router;
package camel.terminal.qcrule.router;
import camel.crawler.processor.Split;
import camel.qcrule.processor.PatientProcessor;
import camel.qcrule.processor.QcHttpProcessor;
import camel.terminal.crawler.processor.Split;
import camel.terminal.qcrule.processor.PatientProcessor;
import camel.terminal.qcrule.processor.QcHttpProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;

hos-camel2/src/main/resources/application.yml

@@ -11,4 +11,13 @@ spring:
eureka:
  client:
    serviceUrl:
      defaultZone: http://192.168.1.221:8761/eureka/
      defaultZone: http://192.168.1.221:8761/eureka/
  data:
    mongodb:
      host: 172.19.103.57
      port: 27017
      username: esb
      password: esb
      authenticationDatabase: admin
      database: log
      gridFsDatabase: dfs

src/main/resources/config/http.properties

@@ -10,5 +10,5 @@ sslPassword = 123456
clientId = 1FtXTrSL8D
clientKey = MUZ0WFRyU0w4RDp1c3ZOeWxWc0ZvdFVlQ2tE
httpGateway=http://192.168.131.6:8081/camel.gateway/transfer
httpGateway=http://192.168.131.6:8081/camel.central.gateway/transfer