Mule ESB HTTP POST Request with URL-Form-Encoded Body

Question

我是Mule ESB的新手，并试图向REST服务发送发布请求。请求的正文采用字符串形式，请求应为 x-www-form-urlencoded。我将有效负载设置为我的参数并将请求发送到 REST 服务，但出现异常：

Failed to invoke REST service "http://username:password@192.168.10.252/api/rest/session/login.json". Message payload is of type: String

My Rest URL is： (#[restURL]( ${dms.host}/api/rest/session/login.json

我的参数是(设置为有效负载#[restBody](：用户名=用户&密码=传递

<sub-flow name="RESTrequestToDMS" doc:name="RESTrequestToDMS" processingStrategy="synchronous">
    <set-variable variableName="originalMessage" value="#[payload]" doc:name="Backup original message"/>
    <logger message="#[restBody]" level="INFO" doc:name="Logger"/>
    <choice doc:name="Choice">
        <when expression="restHTTPmethod == 'POST'">
            <processor-chain>    
                <set-payload value="#[restBody]" doc:name="Set Payload"/>           
                <http:rest-service-component httpMethod="POST" serviceUrl="http://${dms.user}:${dms.pass}@#[restURL]"></http:rest-service-component>
            </processor-chain>
        </when>
        <when expression="restHTTPmethod == 'GET'">
            <processor-chain>
                <http:rest-service-component httpMethod="GET" serviceUrl="http://${dms.user}:${dms.pass}@#[restURL]?#[restBody]"></http:rest-service-component>
            </processor-chain>
        </when>
        <otherwise>
            <processor-chain>
                <logger message="Unknown http method type is provided! " level="ERROR" doc:name="Logger"/>
            </processor-chain>
        </otherwise>
    </choice>
    <json:json-to-object-transformer returnClass="java.util.Map" doc:name="JSON to Object"/>
    <echo-component doc:name="Echo"/>
    <set-variable variableName="RESTResponse" value="#[payload]" doc:name="set RESTResponse"/>
    <set-payload value="#[flowVars['originalMessage']]" doc:name="Restore Original Message"/>
</sub-flow>

有人可以帮我解决这个问题吗？

提前非常感谢。

注意：根据大卫的回复更新。

-------------------更新--------------------

所以现在，出于测试目的，我像这样修改了流程：

<set-payload value="#[restBody]" doc:name="Set Payload"/>
<custom-transformer class="de.mfg.osii.http.StringToURIParametersMapTransformer" doc:name="String To URI Parameters"/>  
<http:rest-service-component httpMethod="POST" serviceUrl="http://${dms.user}:${dms.pass}@#[restURL]">
    <http:requiredParameter key="username" value="#[payload.get('username')]" />
    <http:requiredParameter key="password" value="#[payload.get('password')]" />
</http:rest-service-component>  

所以现在的有效载荷是：{用户名=用户，密码=通过}但是现在当我尝试运行它时，出现以下错误：

1. Failed to invoke REST service "http://user:pass@192.168.10.252/api/rest/session/login.json". Message payload is of type: LinkedHashMap (org.mule.transport.http.components.RestServiceException)

更新：上述问题，异常，刚刚通过添加值为"application/x-www-form-urlencoded"的消息属性"内容类型"来解决。

下面的最后一部分对我来说仍然是个谜:)

另一件事是，正如我在对 David 答案的评论中所述，我可以以自适应方式为 rest 组件添加所需的参数吗？更清楚的是，我不想为每个不同的请求创建不同的流。我在有效负载中有参数映射，所以我想迭代它们并将它们放在所需的参数中。这样的事情可能吗？

提前非常感谢！

-------------------更新--------------------

因此，我修改了我的流程并使用了David的建议。但是，现在，我收到HTTP 405错误(不允许使用方法(。但我确定我使用正确的内容类型发布到正确的地址。这是什么原因呢？有人有想法吗？

我进入此流的有效负载是一个字符串(url 编码参数(，例如 ->

sessionId=9eub9gm7k7oc1ub81dhef6t46q&xml=%3CObjectList%3E%3CFolderObject%3E%3CAddToFolder%20RefType%3D%22Path%22%20ClassName%3D%22FolderObject%22%3E%3C！%5BCDATA%5B%2FfolderPath%5D%5D%3E%3C%2FAddToFolder%3E%3CName%3E%3C！%5BCDATA%5Baaa%5D%5D%3E%3C%2FName%3E%3CDescription%3E%3C

！%5BCDATA%5BRequests%20from%20user%20aaa%20are%20storage%20in%20this%20folder%5D%5D%3E%3C%2FDescription%3E%3CNoErrorIfExist%2F%3E%3C%2FFolderObject%3E%3C%2FObjectList%3E

<flow name="RESTrequestToDMS" doc:name="RESTrequestToDMS" processingStrategy="synchronous">
    <set-variable variableName="originalMessage" value="#[payload]" doc:name="Backup original message"/>
    <choice doc:name="Choice">
        <when expression="restHTTPmethod == 'POST'">
            <processor-chain>
                <set-payload value="#[restBody]" doc:name="Set Payload"/>
                <logger message="The payload before http post is: #[message.payload]" level="INFO" doc:name="Logger"/>
                <http:outbound-endpoint  exchange-pattern="request-response" doc:name="HTTP" address="http://#[restURL]"  user="${dms.user}" password="${dms.pass}" contentType="application/x-www-form-urlencoded">
                </http:outbound-endpoint>
            </processor-chain>
        </when>
        <when expression="restHTTPmethod == 'GET'">
            <processor-chain>
                <http:outbound-endpoint method="GET"  exchange-pattern="request-response" doc:name="HTTP" address="http://#[restURL]?#[restBody]"  user="${dms.user}" password="${dms.pass}" contentType="application/x-www-form-urlencoded">
        </http:outbound-endpoint>
            </processor-chain>
        </when>
        <otherwise>
            <processor-chain>
                <logger message="Unknown http method type is provided! " level="ERROR" doc:name="Logger"/>
            </processor-chain>
        </otherwise>
    </choice>
    <echo-component doc:name="Echo"/>
    <choice doc:name="Choice">
        <when expression="payload != null &amp;&amp; payload != empty &amp;&amp; payload != ''">
            <processor-chain>
                <json:json-to-object-transformer doc:name="JSON to Object" returnClass="java.util.Map"/>
                <set-variable variableName="RESTResponse" value="#[payload]" doc:name="set RESTResponse"/>
            </processor-chain>
        </when>
        <otherwise>
            <processor-chain>
                <logger message="The payload is null or empty! HTTP response code is: #[message.inboundProperties['http.status']]" level="INFO" doc:name="Logger"/>
                <set-variable variableName="RESTResponse" value="#[message.inboundProperties['http.status']]" doc:name="Set HTTP Status Code"/>
            </processor-chain>
        </otherwise>
    </choice>
    <set-payload value="#[flowVars['originalMessage']]" doc:name="Restore Original Message"/>
</flow> 

Answer 1

以下是传递参数以使用 rest-service-component 进行 URL 编码的方法：

<http:rest-service-component httpMethod="POST"
    serviceUrl="http://${dms.user}:${dms.pass}@#[restURL]">
    <http:requiredParameter key="username" value="user" />
    <http:requiredParameter key="password" value="pass" />
</http:rest-service-component>