camel-http4 post 不工作 我没有得到回应

camel-http4 post not working I get no response

这是我的第一个 camel HTTP4 实现,遇到了麻烦。我没有得到任何回应,就好像到 URI 的路由是错误的并且消息是???它不会使 HTTP4 调用出现?

使用 camel-version 2.17.0.redhat-630310, java 8

我的 pom 有依赖关系

    <dependency>
        <groupId>org.apache.camel</groupId>
        <artifactId>camel-http4</artifactId>
    </dependency>

我的路线

    <route 
        id="core.getToken.route"
        autoStartup="true" >
        <from id="getToken" ref="getToken" />
        <process ref="uAARequestTokenProcessor" />
        <log message="Message after uAARequestTokenProcessor:  ${body}" loggingLevel="INFO"/> 
         <setHeader headerName="CamelHttpMethod">
            <constant>POST</constant>
         </setHeader>
        <to uri="http4://dummyhost" />
        <log message="After HTTP4 POST: ${body}" loggingLevel="INFO"/> 
        <to uri="{{accessToken}}" />    
    </route>    

我调用 uAARequestTokenProcessor 来调整出站消息。

public class UAARequestTokenProcessor implements Processor {

    private static final Logger LOG = LoggerFactory.getLogger(UAARequestTokenProcessor.class);

    @Override
    public void process(Exchange exchange) throws Exception {

        LOG.info("Entering UAA Request Token Processor: start " );

            final String clientId = (String)exchange.getIn().getHeader("CLIENTID");
            final byte[] ClientId = clientId.getBytes("UTF-8");
            final String userName = (String)exchange.getIn().getHeader("USERNAME");
            final String password = (String)exchange.getIn().getHeader("PASSWORD");
            final String tokenUrl = (String)exchange.getIn().getHeader("TOKENURL");

            LOG.info("ClientId: " + new String(ClientId));
            LOG.info("userName: " + userName);
            LOG.info("password: " + password);
            LOG.info("tokenUrl: " + tokenUrl);
            LOG.info("Processing UAA token request for Client ID: " + clientId + " and User Name: " + userName);            

            LOG.info("Before Base64 encryption of Client ID: " + new String(ClientId));
            StringBuilder authHeader = new StringBuilder("Basic "); 
            authHeader.append(Base64.getEncoder().encodeToString(ClientId));

            LOG.info("after Base64 encryption of Client ID: " + authHeader.toString());

            String body = String.format("grant_type=password&username=%s&password=%s",
                      URLEncoder.encode(userName, "UTF-8"), //Translates a string into x-www-form-urlencoded format
                      URLEncoder.encode(password, "UTF-8"));
            LOG.info("HTTP BODY: " + body);
            exchange.getIn().setHeader(Exchange.HTTP_URI, tokenUrl);  
            exchange.getIn().setHeader(Exchange.CONTENT_TYPE, "MediaType.APPLICATION_FORM_URLENCODE");
            exchange.getIn().setHeader("Authorization", authHeader.toString());
            exchange.getIn().setBody(body);

            LOG.info("Exchange.HTTP_URI: " + exchange.getIn().getHeader("Exchange.HTTP_URI"));  
            LOG.info("Exchange.CONTENT_TYPE: " + exchange.getIn().getHeader("Exchange.CONTENT_TYPE"));
            LOG.info("Authorization: " + exchange.getIn().getHeader("Authorization"));

            LOG.info("Exiting UAA Request Token Processor: Finish " );
        }

}

在我看来,除非 HTTP4 的 header 不同,否则 Exchange.HTTP_URI 或 HTTP header 不会被设置?但我正在关注 HTTP4 文档,https://github.com/apache/camel/blob/master/components/camel-http4/src/main/docs/http4-component.adoc

处理器内部发生了什么我尝试读取 HTTP headers,它显示它们在设置后为空。

Entering UAA Request Token Processor: start
ClientId: ingestor.57e72dd3-6f9e-4931-b4bc-cd04eaaff3e3.1f7dbe12-2372-439e-8104-06a5f4098ec9
userName: 5c0642fe-a495-44db-93f7-67056fa2c061_ingestor
password: 154f0252d166f27b5e21ef171b02a79f41a0daf3
tokenUrl: http4://d1e53858-2903-4c21-86c0-95edc7a5cef2.predix-uaa.run.aws-usw02-pr.ice.predix.io/oauth/token
Processing UAA token request for Client ID: ingestor.57e72dd3-6f9e-4931-b4bc-cd04eaaff3e3.1f7dbe12-2372-439e-8104-06a5f4098eff9 and User Name: 5c0232fe-a495-44db-94f7-67156fa2c061_ingestor
Before Base64 encryption of Client ID: ingestor.57e72dd3-6f9e-4931-b4bc-cd04eaaff3e3.1f7dbe12-2372-439e-8104-06a5f4098eff9
after Base64 encryption of Client ID: Basic aW5nZXN0b3IuNTdlNzJkZDMtNmY5ZS00OTMxLWI0YmMtY2QwNGVhYWZmM2UzLjFmN2RiZTEyLTIzNzItNDM5ZS04MTA0LTA2YTVmNDA5OGVjOQ==
HTTP BODY: grant_type=password&username=5c0232fe-a495-44db-94f7-67156fa2c061_ingestor&password=154f0252d166f27b5e21ef171b02beebop
Exchange.HTTP_URI: null
Exchange.CONTENT_TYPE: null
Authorization: Basic aW5nZXN0b3IuNTdlNzJkZDMtNmY5ZS00OTMxLWI0YmMtY2QwNGVhYWZmM2UzLjFmN2RiZTEyLTIzNzItNDM5ZS04MTA0LTA2YTVmNDA5OGVjOQ==
Exiting UAA Request Token Processor: Finish

堆栈跟踪显示 headers 但不是 EXCHANGE.HTTP_URI

    2018-04-23 13:17:29,203 | INFO  | ile://ge-ip/core | Tracer                           | 231 - org.apache.camel.camel-core - 2.17.0.redhat-630310 | ID-alphprdfuse2i-44477-1524503724804-3-52 >>> 
(core.getToken.route) setHeader[CamelHttpMethod, POST] --> http4://predhost <<< Pattern:InOnly, 
Headers:{Authorization=Basic aW5nZXN0b3IuNTdlNzJkZDMtNmY5ZS00OTMxLWI0YmMtY2QwNGVhYWZmM2UzLjFmN2RiZTEyLTIzNzItNDM5ZS04MTA0LTA2YTVmNDA5OGVjOQ==, 
breadcrumbId=ID-alphprdfuse2i-44477-1524503724804-3-50, 
CamelFileAbsolute=false, 
CamelFileAbsolutePath=/app/iprctest/jboss-fuse-6.3.0.redhat-310/ge-ip/core/Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelFileLastModified=1524503800000, 
CamelFileLength=3706, CamelFileName=Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelFileNameConsumed=Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelFileNameOnly=nst_dge-1_2018-04-10_19-55-10.CSV, 
CamelFileNameProduced=ge-ip/upload/Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelFileParent=ge-ip/core/Noble, 
CamelFilePath=ge-ip/core/Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelFileRelativePath=Noble/nst_dge-1_2018-04-10_19-55-10.CSV, CamelHttpMethod=POST, 
CamelHttpUri=http4://d1e53858-2903-4c21-86c0-95edc7a5cef2.pred-uaa.run.aws-usw02-pr.ice.pred.io/oauth/token, 
CLIENTID=ingestor.57e72dd3-6f9e-4931-b4bc-cd04eaaff3e3.1f7dbe12-2372-439e-8104-06a5f4098ec9, 
Content-Type=MediaType.APPLICATION_FORM_URLENCODE, 
CUSTKEY=Noble, PASSWORD=154f0252d166f27b5e21a79f41a0daf3, 
TENANTUUID=c0642fe-a495-44db-93f7-67056fa2c061, 
TOKENURL=http4://d1e53858-2903-4c21-86c0-95edc7f2.pred-uaa.run.aws-usw02-pr.ice.pred.io/oauth/token, 
UPLOADURL=http4://apm-times-query-svc-prod.app-api.aws-usw02-pr.pred.io/v2/time_series/upload, 
USERNAME=5c0642fe-a495-44db-93f7-67056fa2c061_ingestor}, 
BodyType:String, Body:grant_type=password&username=5c0642fe-a495-44db-93f7-2c061_ingestor&password=154f0252d166f2ef171b02a79f41a0daf3

http4://predhost 是 spring XML 中的虚拟 URI,应该被 exchange.getIn().setHeader(Exchange.HTTP_URI, tokenUrl);

我从未到达 URL 端点,并且在创建到 HTTP4://

后从未到达日志消息
        <to uri="http4://predixhost" />
        <log message="After HTTP4 POST: ${body}" loggingLevel="INFO"/> 

我尝试了以下方法,但仍然没有任何反应,没有异常,什么都没有。设置 header CamelHttpUri 以覆盖默认的虚拟 uri 和动态 toD,???

    <route 
        id="core.getToken.route"
        autoStartup="true" >
        <from id="getToken" ref="getToken" />
        <process ref="uAARequestTokenProcessor" />
<!--        <log message="Message after uAARequestTokenProcessor:  ${body}" loggingLevel="INFO"/>   -->
         <setHeader headerName="CamelHttpMethod">
            <constant>POST</constant>
         </setHeader>
<!--         <setHeader headerName="CamelHttpUri">
            <simple>${header.TOKENURL}</simple>
         </setHeader>  -->
        <toD uri="${header.TOKENURL}" />
        <log message="After HTTP4 POST: ${body}" loggingLevel="INFO"/> 
        <to uri="{{accessToken}}" />    
    </route> 

不知道怎么回事?我得不到响应,一个异常,看起来我无法发送到 HTTP4 端点。我现在到了,验证了我在环境中的代理设置,还在骆驼上下文中尝试过,我不知道发生了什么或该做什么,我没有继续的日志信息,...

<camelContext     
  id="com.passthru.coreCamelContext"
  trace="true"
  xmlns="http://camel.apache.org/schema/blueprint"
  allowUseOriginalMessage="false"
  streamCache="true"
  errorHandlerRef="deadLetterErrorHandler" >
 <properties>
       <property key="http.proxyHost" value="PITC-Zscaler-Americas-Cin.proxy.corporate.comp.com"/>
       <property key="http.proxyPort" value="80"/>
  </properties>

<streamCaching  id="CacheConfig" 
                spoolUsedHeapMemoryThreshold="70" 
                anySpoolRules="true"/>

我试过使用 CURL 并且它在命令行下工作,我试过使用 Postman 并且它可以工作。谢谢你的帮助。

这是要做什么,只需 POST 向具有 body 的 UAA(https) 服务发送消息:

grant_type=password&username=myUserName&password=myPassword

和headers:

Content-Type=application/x-www-form-urlencoded
Authorization=Basic aW5nZXN0b3IuNTdlNzJkZDMt==

服务器将颁发访问令牌。

喜欢这个邮递员的例子:

OkHttpClient client = new OkHttpClient();
MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
RequestBody body = RequestBody.create(mediaType, "username=93f7c061_ingestor&password=15a79f41a0daf3&grant_type=password");
Request request = new Request.Builder()
  .url("https://d1e53858-2903-4c21-86c0-95edc7a5cef2.uaa.run.aws-usw02-pr.ice.io/oauth/token")
  .post(body)
  .addHeader("Content-Type", "application/x-www-form-urlencoded")
  .addHeader("Authorization", "Basic aW5nZXN0b3IuNTdlNzJkZDMtNmY5ZS00OTMxLWI0YmMtY2QwNGVhYWZmM2UzLjFmN2RiZTEyLTIzNzItNDM5ZS04MTA0LTA2YTVmNDA5OGVjOTo=")
  .addHeader("Cache-Control", "no-cache")
  .addHeader("Postman-Token", "ad8ba9b0-6215-4c53-a6ef-b3a5bf7901f6")
  .build();

Response response = client.newCall(request).execute();

你好我希望有人可以提供帮助,我被卡住了。 我已经确认,我相信 HTTP4 端点不工作。我有一封死信 queue

<bean id="deadLetterErrorHandler" class="org.apache.camel.builder.DeadLetterChannelBuilder">
    <property name="deadLetterUri" value="${deadLetterQueue}"/>
    <property name="redeliveryPolicy" ref="redeliveryPolicyConfig"/>
</bean>

<bean id="redeliveryPolicyConfig" class="org.apache.camel.processor.RedeliveryPolicy">
    <property name="maximumRedeliveries" value="3"/>
</bean>

并且发送到此端点的每个交换都经过 3 次尝试,然后发送到死信 queue。死信 queue 中的消息内容是应该发送到 HTTP4 端点以及 UAA 服务的内容。

├── deadletterqueue
│   ├── ID-alphprdfuse2i-36326-1524606956414-3-65

grant_type=password&username=5c0642fe_ingestor&password=02a79f41a0daf3

通向此的消息 header 看起来也不错。

core.getToken.route) log[HTTP4 POST body: ${body}] --> http4://d1e53858-2903-4c21-86c0-95edc7a5cef2.uaa.run.aws-usw02.io:443/oauth/token?throwExceptionOnFailure=false <<< Pattern:InOnly, Headers:{Authorization=Basic aW5nZXN0b3IuNTdlNzJkZDMtNmY5ZS00OTMxLWI0YmMtY2QwNGVhYWZmM2UzLjFmN2RiZTEyLTIzNzItNDM5ZS04MTA0LTA2YTVmNDA5OGVjOQ==, CamelHttpCharacterEncoding=UTF-8, CamelHttpMethod=POST, CamelHttpUri=http4://d1e53858-2903-4c21-86c0-95edc7a5cef2.uaa.run.aws.io:443/oauth/token, Content-Type=MediaType.APPLICATION_FORM_URLENCODE, TOKENURL=http4://d95edc7a5cef2.uaa.run.aws-usw02-pr.ice.io:443/oauth/token}, BodyType:String, Body:grant_type=password&username=5c06-a495-44db-93f7-67056fa2c061_ingestor&password=7b5e21ef171b02a79f41a0daf3

我确信我实现 HTTP4 的方式一定有问题。我不需要公开我只需要推送给它的 Web 服务。我无法让它工作。请帮忙。

好的,这是一个多方面的问题。

1st 我的代理设置不正确。我发现它必须设置为 IP 或名称,没有协议 http:// 的圆锥形名称。

我喜欢它:

<camelContext     
  id="com.ge.digital.passthru.coreCamelContext"
  trace="true"
  xmlns="http://camel.apache.org/schema/blueprint"
  allowUseOriginalMessage="false"
  streamCache="true"
  errorHandlerRef="deadLetterErrorHandler" >
  <properties>
       <property key="http.proxyHost" value="http://PITC-Zscaler-Americas.proxy.corporate.com"/>
       <property key="http.proxyPort" value="80"/>
  </properties>

但如前所述,这显然是不正确的,请不要使用 def 中的协议。喜欢:

  <properties>
       <property key="http.proxyHost" value="PITC-Zscaler-Americas.proxy.corporate.com"/>
       <property key="http.proxyPort" value="80"/>
  </properties>

  <properties>
       <property key="http.proxyHost" value="123.123.123.123"/>
       <property key="http.proxyPort" value="80"/>
  </properties>

这给了我一个回应,不是我所希望的,而是给我希望的。 这给了我一个 504 网关超时,哇,我得到了一些回报。 :)

2,端点覆盖无效...

m.setHeader(Exchange.HTTP_URI, tokenUrl);

使用

<toD uri="${header.TOKENURL}?throwExceptionOnFailure=false" />
<toD uri="${header.TOKENURL}" />

所以我只是尝试了一个简单的路线

<to uri="http4://d1e53858-uaa.run.aws-usw02-pr.ice.io:443/oauth/token?throwExceptionOnFailure=false" />

超车

m.setHeader(Exchange.HTTP_URI, tokenUrl);

其中 tokenUrl 被定义为

http4://d1e53858-uaa.run.aws-usw02-pr.ice.io:443/oauth/token

这给了我 504,我希望这是我可以处理的事情,通常不是,但有时……所以我一直在尝试……直到……我使用了HTTP_URI 中的实际地址,例如...

https://d1e53858-uaa.run.aws-usw02-pr.ice.io/oauth/token

现在我得到一个 CamelHttpResponseCode=401,CamelHttpResponseText=Unauthorized

我是一个快乐的露营者,这是我可以使用的东西...然后我测试了相同的替换设置 xml 中的路线中的 URI。这也有效。

 <setHeader headerName="CamelHttpMethod">
    <constant>POST</constant>
 </setHeader>
<log message="HTTP4 POST headers: ${headers}" loggingLevel="DEBUG"/>
<setHeader headerName="CamelHttpUri">
    <simple>${header.TOKENURL}?throwExceptionOnFailure=false</simple>
</setHeader>
<to uri="http4://d1e53858-uaa.run.aws-usw02-pr.ice.io/oauth/token?throwExceptionOnFailure=false" />

我仍在努力让动态路线发挥作用,但我对我所拥有的感到满意,以后会更加关注它。

<toD uri="${header.TOKENURL}?throwExceptionOnFailure=false" />
<toD uri="${header.TOKENURL}" /> -->

谢谢大家,我希望我作为新手的奋斗能帮助到别人,我不能是唯一一个发生这些愚蠢事件的人。无论如何,为所有人欢呼。