Mule ESB動態設置端點路徑

我在嘗試構建一個Web服務，該服務接受許多用於構建Bing查詢API路徑的變量。出於某種原因，如果我構建URI，我的流程將識別新的URI已正確分配給有效內容，但是當我將有效內容分配給出站HTTP端點時，它將失敗。Mule ESB動態設置端點路徑

<flow name="BingQuery" doc:name="BingQuery"> 
     <http:inbound-endpoint exchange-pattern="one-way" host="localhost" port="8082" doc:name="HTTP" /> 
     <set-variable variableName="query" doc:name="Variable" value="#[header:INBOUND:query]"/> 
     <set-variable variableName="numResults" doc:name="Variable" value="#[header:INBOUND:top]"/> 
     <set-variable variableName="offsetResults" doc:name="Variable" value="#[header:INBOUND:offset]"/> 
     <scripting:component doc:name="Groovy"> 
      <scripting:script engine="Groovy"> 
       <scripting:text><![CDATA[def query = message.getInvocationProperty("query") 
       def numResults = message.getInvocationProperty("numResults") 
       def offsetResults = message.getInvocationProperty("offsetResults") 
       def path = "Data.ashx/Bing/Search/v1/Web?Query=" + "$query" + "&amp;WebFileType=%27PDF%27&amp;\$top=" + "$numResults" + "&amp;\$skip=" + "$offsetResults" + "&amp;\$format=Json" 
        println "$path" 
        message.setProperty("pathVar","$path") 
        return null;]]></scripting:text> 
      </scripting:script> 
     </scripting:component> 
     <logger level="INFO" doc:name="Logger" message="#[header:OUTBOUND:pathVar]"/> 
     <https:outbound-endpoint exchange-pattern="request-response" 
      host="api.datamarket.azure.com" port="443" path="#[header:OUTBOUND:pathVar]" 
      user="*****" password="******" 
      doc:name="Bing" /> ...

我得到的例外是

ERROR 2012-10-25 14:14:26,250 [[poll_directory].BingQuery.stage1.02] org.mule.exception.DefaultMessagingExceptionStrategy: 
******************************************************************************** 
Message    : Failed to transform from "json" to "java.util.Map" 
Code     : MULE_ERROR-65110 
-------------------------------------------------------------------------------- 
Exception stack is: 
1. Unexpected character ('T' (code 84)): expected a valid value (number, String, array, object, 'true', 'false' or 'null') 
at [Source: [email protected]; line: 1, column: 2] (org.codehaus.jackson.JsonParseException) 
org.codehaus.jackson.JsonParser:1291 (null) 
2. Failed to transform from "json" to "java.util.Map" (org.mule.api.transformer.TransformerException) 
org.mule.module.json.transformers.JsonToObject:136 (http://www.mulesoft.org/docs/site/current3/apidocs/org/mule/api/transformer/TransformerException.html) 
-------------------------------------------------------------------------------- 
Root Exception stack trace: 
org.codehaus.jackson.JsonParseException: Unexpected character ('T' (code 84)): expected a valid value (number, String, array, object, 'true', 'false' or 'null') 
at [Source: [email protected]; line: 1, column: 2] 
    at org.codehaus.jackson.JsonParser._constructError(JsonParser.java:1291) 
    at org.codehaus.jackson.impl.JsonParserMinimalBase._reportError(JsonParserMinimalBase.java:385) 
    at org.codehaus.jackson.impl.JsonParserMinimalBase._reportUnexpectedChar(JsonParserMinimalBase.java:306) 
    + 3 more (set debug level logging or '-Dmule.verbose.exceptions=true' for everything) 
********************************************************************************

必須有它不工作，原因很簡單，我敢肯定，這只是因爲我不知道正確的語法，但在騾子。我也知道，使用MEL和Groovy可能有更好的方法來實現這一點，但我對MEL還不夠熟悉。

SOLUTION

原來一些用戶屬性和密碼屬性的特徵被髮送之前進行編碼的。在傳遞給用戶密碼屬性之前，將該密鑰放入一個變量中可以防止並取得成功。

<?xml version="1.0" encoding="UTF-8"?> 

<mule xmlns:scripting="http://www.mulesoft.org/schema/mule/scripting" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:json="http://www.mulesoft.org/schema/mule/json" 
    xmlns:vm="http://www.mulesoft.org/schema/mule/vm" xmlns:http="http://www.mulesoft.org/schema/mule/http" 
    xmlns:https="http://www.mulesoft.org/schema/mule/https" xmlns:file="http://www.mulesoft.org/schema/mule/file" 
    xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" 
    xmlns:spring="http://www.springframework.org/schema/beans" xmlns:core="http://www.mulesoft.org/schema/mule/core" 
    version="CE-3.3.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation=" 
http://www.mulesoft.org/schema/mule/json http://www.mulesoft.org/schema/mule/json/current/mule-json.xsd 
http://www.mulesoft.org/schema/mule/vm http://www.mulesoft.org/schema/mule/vm/current/mule-vm.xsd 
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd 
http://www.mulesoft.org/schema/mule/https http://www.mulesoft.org/schema/mule/https/current/mule-https.xsd 
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd 
http://www.mulesoft.org/schema/mule/scripting http://www.mulesoft.org/schema/mule/scripting/current/mule-scripting.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd "> 
    <configuration doc:name="Configuration"> 
     <expression-language> 
      <import class="org.mule.util.StringUtils" /> 
     </expression-language> 
    </configuration> 
    <flow name="BingQuery" doc:name="BingQuery"> 
     <http:inbound-endpoint exchange-pattern="one-way" host="localhost" port="8082" doc:name="HTTP" /> 
     <set-variable variableName="query" doc:name="Variable" value="#[header:INBOUND:query]"/> 
     <set-variable variableName="numResults" doc:name="Variable" value="#[header:INBOUND:top]"/> 
     <set-variable variableName="offsetResults" doc:name="Variable" value="#[header:INBOUND:offset]"/> 
     <scripting:component doc:name="Groovy"> 
      <scripting:script engine="Groovy"> 
       <scripting:text><![CDATA[def query = message.getInvocationProperty("query") 
       def numResults = message.getInvocationProperty("numResults") 
       def offsetResults = message.getInvocationProperty("offsetResults") 
       def path = "Data.ashx/Bing/Search/v1/Web?Query=" + "$query" + "&WebFileType=%27PDF%27&\$top=" + "$numResults" + "&\$skip=" + "$offsetResults" + "&\$format=Json" 
        println "$path" 
        message.setProperty("pathVar","$path") 
        message.setProperty("APIIdentifier","*****") 
        return null;]]></scripting:text> 
      </scripting:script> 
     </scripting:component> 
     <https:outbound-endpoint exchange-pattern="request-response" 
      host="api.datamarket.azure.com" port="443" path="#[header:OUTBOUND:pathVar]" 
      user="#[header:OUTBOUND:APIIdentifier]" password="#[header:OUTBOUND:APIIdentifier]" 
      doc:name="Bing" /> 
     <json:json-to-object-transformer 
      returnClass="java.util.Map" doc:name="JSON to Object" /> 
     <expression-transformer expression="#[message.payload.d.results]" 
      doc:name="Expression" /> 
     <collection-splitter doc:name="Collection Splitter" /> 
     <vm:outbound-endpoint exchange-pattern="one-way" 
      path="fileWriter" doc:name="VM" /> 
    </flow> 
    <flow name="RestProcessor" doc:name="RestProcessor"> 
     <vm:inbound-endpoint exchange-pattern="one-way" 
      path="fileWriter" doc:name="VM" /> 
     <set-variable variableName="fileName" value="#[message.payload.ID].pdf" 
      doc:name="Variable" /> 
     <http:rest-service-component 
      serviceUrl="#[joinChar=message.payload.Url.contains('?')?'&amp;':'?' ; StringUtils.join(new String[]{message.payload.Url,(String)joinChar,'followRedirects=true'})]" 
      httpMethod="GET"> 
      <http:error-filter> 
       <expression-filter expression="#[Integer.valueOf(message.inboundProperties['http.status']) &gt;= 400]"></expression-filter> 
      </http:error-filter> 
     </http:rest-service-component> 
     <file:outbound-endpoint path="/home/administrator/Documents" 
      outputPattern="#[flowVars.fileName]" responseTimeout="10000" 
      mimeType="application/pdf" doc:name="File" /> 
    </flow> 
</mule>

來源

2012-10-25 Thaneofife

這裏是MEL改寫流的開始（工作對我來說，雖然我對測試端點不是兵測試）。

請注意，我還設置爲GET出站HTTPS端點的方法：

<flow name="BingQuery"> 
    <http:inbound-endpoint exchange-pattern="one-way" 
     host="localhost" port="8082" /> 
    <set-variable variableName="query" 
     value="#[message.inboundProperties.query]" /> 
    <set-variable variableName="numResults" 
     value="#[message.inboundProperties.top]" /> 
    <set-variable variableName="offsetResults" 
     value="#[message.inboundProperties.offset]" /> 
    <expression-component> 
     flowVars['bingQuery'] = 
      'Data.ashx/Bing/Search/v1/Web?Query=' + query 
      + '&amp;WebFileType=%27PDF%27&amp;$top=' + numResults 
      + '&amp;$skip=' + offsetResults 
      + '&amp;$format=Json'; 
     payload = null; 
    </expression-component> 
    <logger level="ERROR" message="#[bingQuery]" /> 
    <http:outbound-endpoint exchange-pattern="request-response" 
     method="GET" 
     host="api.datamarket.azure.com" port="443" path="#[bingQuery]" 
     user="*****" password="******" />

如果query，numResults和offsetResults變量沒有在流動其他地方使用的話，建議內聯用來創建表達式他們正確的在expression-component。

來源

2012-10-25 22:10:34

我們記錄了＃[有效載荷]，它正在踢出正確的路徑字符串，但由於某種原因，即使將方法設置爲GET，我們仍然得到相同的錯誤。如果我們只是放入路徑的字符串文字，它的工作原理沒有錯誤。 – Thaneofife

提供第二個選項... –

我剛剛更新了我的腳本，並得到相同的錯誤。日誌記錄＃[header：OUTBOUND：pathVar]給出與之前相同的字符串，但路徑失敗。 – Thaneofife

Mule ESB動態設置端點路徑

回答

相關問題