camel 测试添加

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

@@ -0,0 +1,14 @@
package api1.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api1");
    }
}

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

@@ -0,0 +1,13 @@
package api1.route;
import 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("api1")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api10/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api10.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api10");
    }
}

hos-camel/src/main/java/api10/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api10.route;
import api10.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/v10").routeId("api10")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api2/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api2.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api2");
    }
}

hos-camel/src/main/java/api2/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api2.route;
import api2.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/v2").routeId("api2")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api3/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api3.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api3");
    }
}

hos-camel/src/main/java/api3/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api3.route;
import api3.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/v3").routeId("api3")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api4/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api4.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api4");
    }
}

hos-camel/src/main/java/api4/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api4.route;
import api4.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/v4").routeId("api4")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api5/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api5.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api5");
    }
}

hos-camel/src/main/java/api5/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api5.route;
import api5.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/v5").routeId("api5")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api6/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api6.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api6");
    }
}

hos-camel/src/main/java/api6/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api6.route;
import api6.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/v6").routeId("api6")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api8/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api8.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api8");
    }
}

hos-camel/src/main/java/api8/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api8.route;
import api8.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/v8").routeId("api8")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

hos-camel/src/main/java/api9/processor/ApiProcessor.java

@@ -0,0 +1,14 @@
package api9.processor;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
public class ApiProcessor implements Processor {
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        System.out.println("测试，helloWorld 打印camel接口");
        outMessage.setBody("hello,api9");
    }
}

hos-camel/src/main/java/api9/route/ApiRouteBulider.java

@@ -0,0 +1,13 @@
package api9.route;
import api9.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/v9").routeId("api9")
                .process(new ApiProcessor()).log("servers: 0,code: ,order: 0").log("servers: 0,code: ,order: 0");
    }
}

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

@@ -27,16 +27,16 @@ public class ParamVerifyBean {
    private String appKey = "esb-key";
    private String token;
    public static void main(String[] args) throws Exception {
        ParamVerifyBean paramSignUtil = new ParamVerifyBean();
        paramSignUtil.setApi("collect");
        paramSignUtil.addParam("patientId", "11111", true);
        paramSignUtil.addParam("eventNo", "2222222", true);
        paramSignUtil.genParam();
        String s = paramSignUtil.signParam("secret");
        System.out.println(s);
    }
//    public static void main(String[] args) throws Exception {
//        ParamVerifyBean paramSignUtil = new ParamVerifyBean();
//        paramSignUtil.setApi("collect");
//        paramSignUtil.addParam("patientId", "11111", true);
//        paramSignUtil.addParam("eventNo", "2222222", true);
//        paramSignUtil.genParam();
//        String s = paramSignUtil.signParam("secret");
//        System.out.println(s);
//
//    }
    public void setApi(String api) {
        this.api = api;

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

@@ -0,0 +1,77 @@
package camel.gateway.processor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.yihu.hos.core.datatype.StringUtil;
import com.yihu.hos.core.http.HTTPResponse;
import com.yihu.hos.core.http.HttpClientKit;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import java.io.IOException;
import java.util.Map;
/**
 * 测试使用，用户获取sign
 */
public class SignProcessor implements Processor {
    static final String agUrl = "http://192.168.1.221:10000";
    public void process(Exchange exchange) throws Exception {
        Message outMessage = exchange.getOut();
        Message inMessage = exchange.getIn();
        String appKey = inMessage.getHeaders().get("appKey").toString();
        String secret = getSecret(appKey);
        if (StringUtil.isEmpty(secret)){
            outMessage.setBody("获取secret失败，APPKey不存在对应的应用");
        }else {
            Map<String, Object> params = inMessage.getHeaders();
            String sign = getSign(params, secret);
            outMessage.setBody("sign,"+sign);
        }
    }
    private String getSecret(String appKey) {
        ObjectMapper objectMapper = new ObjectMapper();
        //TODO 设置固定的验证入口地址
        HTTPResponse response = HttpClientKit.get(agUrl + "/api/v1.0/admin/apps/" + appKey);
        if (response.getStatusCode() != 200) {
            System.out.println("获取app的secret请求失败！");
            return "";
        }
        try {
            Map map = objectMapper.readValue(response.getBody(), Map.class);
            if ((Boolean) map.get("successFlg")) {
                Map<String, Object> obj = (Map) map.get("obj");
                if (obj == null) {
                    return "";
                }
                String secret = obj.get("secret").toString();
                return secret;
            } else {
                System.out.println("验证失败：" + map.get("errorMsg"));
                return "";
            }
        } catch (IOException e) {
            e.printStackTrace();
            return "";
        }
    }
    private String getSign(Map<String, Object> params, String secret) {
        try {
            ParamVerifyBean paramSign = new ParamVerifyBean();
            paramSign.addParam(params);
            String md5Sign = paramSign.signParam(secret);
            System.out.println("生成的签名：" + md5Sign);
            return md5Sign;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

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

@@ -2,6 +2,7 @@ package camel.gateway.route;
import camel.gateway.processor.ErrorHandle;
import camel.gateway.processor.GatewayProcessor;
import camel.gateway.processor.SignProcessor;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@@ -36,6 +37,9 @@ public class GatewayRouterBuilder extends RouteBuilder {
        from("jetty:http://0.0.0.0:9999/healthy").routeId("healthy")
                .log("=========================心跳测试=====================");
        from("jetty:http://0.0.0.0:9999/sign").routeId("sign")
        .process(new SignProcessor());
    }
}