路由编排调试

hos-broker/src/main/java/com/yihu/hos/common/listener/ApplicationStartListener.java

@@ -49,7 +49,7 @@ public class ApplicationStartListener implements ApplicationListener<ContextRefr
        for (SystemServiceFlowClass systemServiceFlowClass : systemServiceFlowClassList) {
            Integer flowId = systemServiceFlowClass.getFlowId();
            String type = systemServiceFlowClass.getType();
            if (systemServiceFlowClassGroupMap.containsKey(flowId)) {
            if (systemServiceFlowClassGroupMap.containsKey(type + flowId.toString())) {
                List<SystemServiceFlowClass> classList = systemServiceFlowClassGroupMap.get(type + flowId);
                classList.add(systemServiceFlowClass);
                systemServiceFlowClassGroupMap.put(type + flowId.toString(), classList);

hos-camel/src/main/java/com/yihu/hos/camel/crawler/processor/Processor0.java

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

hos-camel/src/main/java/com/yihu/hos/camel/crawler/route/CrawlerRouteBulider.java

@@ -1,6 +1,6 @@
package com.yihu.hos.camel.crawler.route;
package crawler.route;
import com.yihu.hos.camel.crawler.processor.Processor0;
import crawler.processor.Processor0;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;

hos-camel/src/main/java/com/yihu/hos/camel/qlc/processor/Processor0.java

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

hos-camel/src/main/java/com/yihu/hos/camel/qlc/processor/Processor1.java

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

hos-camel/src/main/java/com/yihu/hos/camel/qlc/processor/Processor2.java

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

hos-camel/src/main/java/com/yihu/hos/camel/qlc/route/QlcRouteBulider.java

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

hos-rest/pom.xml

@@ -55,6 +55,17 @@
			<groupId>com.yihu.hos</groupId>
			<artifactId>hos-web-framework</artifactId>
			<version>1.1.1-SNAPSHOT</version>
			<exclusions>
				<exclusion>
					<groupId>org.springframework.boot</groupId>
					<artifactId>spring-boot-starter-data-jpa</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-orm</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>com.yihu.core</groupId>

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

@@ -19,11 +19,11 @@ qlc:
    port: 2181
crawler:
  upload:
    ip: 172.19.103.89
    ip: localhost
    port: 8088
    api: crawler/patient
  storage:
    ip: 172.19.103.89
    ip: localhost
    port: 8088
    api: crawler/datapush

hos-rest/src/main/resources/spring/applicationContext.xml

@@ -65,7 +65,6 @@
        <property name="sessionFactory" ref="sessionFactory"/>
    </bean>
    <tx:annotation-driven transaction-manager="txManager" proxy-target-class="true"/>
    <aop:aspectj-autoproxy/>
    <!--文件上传支持-->
    <bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver"/>

hos-web-framework-dependencies/pom.xml

@@ -115,6 +115,16 @@
            <artifactId>camel-http4</artifactId>
            <version>${camel.version}</version> <!-- use the same version as your Camel core version -->
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jetty</artifactId>
            <version>${camel.version}</version> <!-- use the same version as your Camel core version -->
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jms</artifactId>
            <version>${camel.version}</version> <!-- use the same version as your Camel core version -->
        </dependency>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-jms</artifactId>