我有一个简单的Mule流设置,带有一个servlet入站 endpoints ,它调用一个REST服务:
<flow name="sandboxFlow" doc:name="sandboxFlow">
<servlet:inbound-endpoint path="rest" responseTimeout="10000" doc:name="Servlet"/>
<set-payload value="#[message.inboundProperties['http.query.params']]" doc:name="Set Payload"/>
<logger message="Payload is #[message.payload]" level="INFO" doc:name="Logger"/>
<jersey:resources doc:name="REST">
<component class="com.csc.rest.service.PersonService">
</jersey:resources>
</flow>
顺便说一句,我使用servlet endpoints 的原因是因为它在JBoss webapp中运行 .
这是一个简单的html / jquery / ajax客户端,用于调用REST服务:
$(document).ready(function(){
$("#buttonEnroll").click(function(){
var name = $("#textName").val();
var ssn = $("#textSsn").val();
var params = "name="+name+"&ssn="+ssn;
$.ajax({
type: "POST"
url: "esb/rest/PersonService",
data: params,
cache: false,
success: function(data){
alert("POST success: " + data);
}
});
});
});
问题是参数没有传递给REST服务 . 该服务正在调用,但我有一个NullPayload .
如果我将我的 endpoints 更改为HTTP,并在Mule容器而不是JBoss中运行相同的应用程序,那么它可以工作 . 参数确实通过了 . 但是在JBoss中使用servlet endpoints 时,参数会丢失 . 以下是 Logger 组件的输出:
INFO [org.mule.api.processor.LoggerMessageProcessor] (default task-2) Payload is null
知道如何解决这个问题吗?我需要能够将数据POST到REST服务
这只是一个起点,我希望在向项目添加更多组件之前开始工作 .
编辑:添加web.xml以显示PersonService的mule配置和结构
web.xml中:
<context-param>
<param-name>org.mule.config</param-name>
<param-value>mule-config.xml</param-value>
</context-param>
<listener>
<listener-class>org.mule.config.builders.MuleXmlBuilderContextListener</listener-class>
</listener>
<servlet>
<servlet-name>muleServlet</servlet-name>
<servlet-class>org.mule.transport.servlet.MuleReceiverServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>muleServlet</servlet-name>
<url-pattern>/esb/*</url-pattern>
</servlet-mapping>
PersonService
@Path("/PersonService")
@RequestScoped
public class PersonService {
PersonManager manager = PersonManager.newPersonManager();
@POST
public String addPerson(String input) {
System.out.println("addPerson: input=" + input.toString());
HashMap<String,String> params = Toolbox.parseParameters(input)
String name = params.get("name");
String ssn = params.get("ssn");
if(name != null && ssn != null) {
Person person = new Person(name, ssn);
manager.persist(person);
}
return "person added: " + name + ";" + ssn;
}
}
1 回答
我想你需要删除:
让有效载荷按原样击中Jersey组件 .
然后,您需要替换自定义参数解析,而是依赖于JAX-RS提供的标准功能: