我正在尝试使用Spring-Integration(3.0.1)来实现RESTful服务,该服务使用int-http:inbound-gateway支持 both XML和JSON作为请求和响应格式 .
我的代码基于Spring集成示例(尽管这不使用消息有效负载):
https://github.com/spring-projects/spring-integration-samples/tree/master/intermediate/rest-http
服务激活类:
@Service("httpOrderGateway")
public class HttpOrderGateway implements OrderGateway {
private static final Logger LOGGER = Logger.getLogger(HttpOrderGateway.class);
@Override
public Message<CreateOrderResponse> createOrder(Message<CreateOrderRequest> orderRequest) {
LOGGER.info("Received CreateOrderRequest headers: " + orderRequest.getHeaders());
LOGGER.info("Received: " + orderRequest.getPayload());
return MessageBuilder.withPayload(new CreateOrderResponse("Thank you for your order")).build();
}
}
Spring集成XML:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/http
http://www.springframework.org/schema/integration/http/spring-integration-http.xsd
http://www.springframework.org/schema/oxm
http://www.springframework.org/schema/oxm/spring-oxm.xsd"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:oxm="http://www.springframework.org/schema/oxm"
xmlns:int-http="http://www.springframework.org/schema/integration/http">
<int:annotation-config />
<int:channel id="orderRequestChannel" />
<int:channel id="orderResponseChannel" />
<int-http:inbound-gateway id="inboundOrderRequestGateway"
supported-methods="POST"
request-channel="orderRequestChannel"
reply-channel="orderResponseChannel"
view-name="/order"
path="/services/order"
reply-timeout="50000">
</int-http:inbound-gateway>
<bean class="org.springframework.web.servlet.view.ContentNegotiatingViewResolver">
<property name="order" value="1" />
<property name="contentNegotiationManager">
<bean class="org.springframework.web.accept.ContentNegotiationManagerFactoryBean">
<property name="defaultContentType" value="application/json" />
<property name="mediaTypes">
<map>
<entry key="json" value="application/json" />
<entry key="xml" value="application/xml" />
</map>
</property>
</bean>
</property>
<property name="defaultViews">
<list>
<bean class="com.anon.order.gateway.json.view.ExtendedMappingJacksonJsonView">
<property name="objectMapper" ref="jaxbJacksonObjectMapper" />
</bean>
<bean class="org.springframework.web.servlet.view.xml.MarshallingView">
<constructor-arg ref="marshaller" />
</bean>
</list>
</property>
</bean>
<oxm:jaxb2-marshaller id="marshaller" contextPath="com.anon.order.gateway.marshalling.model.impl" />
<int:service-activator id="orderGatewayActivator"
input-channel="orderRequestChannel"
output-channel="orderResponseChannel"
ref="httpOrderGateway"
method="createOrder"
requires-reply="true"
send-timeout="60000" />
<bean id="jaxbJacksonObjectMapper" class="com.anon.order.gateway.json.JaxbJacksonObjectMapper" />
</beans>
目前,代码注销:
Received: <CustomerServiceRequest><CustomerName>Robert Pulson</CustomerName></CustomerServiceRequest>
(或等效的JSON格式),并根据Accept Header返回JSON或XML中的响应,以便该部分正常工作 .
我已经阅读了以下基于以前版本的Spring Integration的类似问题:
Spring Integration : http:inbound-channel adapter - not getting json object in payload
但这使用的是 inbound-channel-adaptor
,而不是 inbound-gateway
.
如何配置 inbound-gateway
以使用 marshaller
和 jaxbJacksonObjectMapper
(来自相同的配置文件)将原始请求主体转换为JSON / XML的 CreateOrderRequest
实例?
1 回答
配置适当的
HttpMessageConverter
并使用message-converters
属性注入它们 .另请参见
merge-with-default-converters
属性 .见
MappingJackson2HttpMessageConverter
( Jackson 2),MappingJacksonHttpMessageConverter
( Jackson 1.x)和MarshallingHttpMessageConverter
.此外,如果它们位于类路径上,则默认情况下会自动使用JAXB和Json消息转换器 . 如果转换不需要任何特殊内容,您可以在网关上设置
request-payload-type
.有关更多信息,请参阅reference documentation .