![]() |
调皮的小笼包 · RabbitMQ消息Json序列化Could ...· 1 月前 · |
![]() |
温柔的玉米 · 新书发布 | 《数字建造》系列丛书来了!_建筑业· 2 月前 · |
![]() |
礼貌的汉堡包 · 小新pro14真的很好吗? - 知乎· 11 月前 · |
![]() |
急躁的自行车 · 设计师的仿生椅子真是脑洞大开! - 知乎· 1 年前 · |
![]() |
多情的伏特加 · 哥布林杀猎手解说_哥布林洞窟1提取码_哥布林 ...· 1 年前 · |
![]() |
爱听歌的筷子 · 王阶:广安门中医院如何推进中西医结合-新华网· 1 年前 · |
我是spring集成的新手,在spring集成http模块中工作,以满足我的项目需求。我作为一个http客户端从出站网关发送请求。我正在尝试向服务器发起一个请求,并且服务器应该用我的设置值返回消息有效负载。我正在将对象转换为JSON,使用它向服务器发送请求,从客户机(HttpClientDemo)向服务器端的入站网关发送请求,如下所示。为此,我将对象转换为JSON,然后在客户端将其转换为JSON字符串,执行一些简单的操作并将其发送回客户机(HttpClientDemo),但在此之前,我将得到与HttpMessageConverter相关的异常,如下所示:
Exception in thread "main" org.springframework.web.client.RestClientException: Could not extract response: no suitable HttpMessageConverter found for response type [class com.mycompany.MyChannel.model.FFSampleResponseHttp] and content type [text/plain;charset=UTF-8]
at org.springframework.web.client.HttpMessageConverterExtractor.extractData(HttpMessageConverterExtractor.java:108)
at org.springframework.web.client.RestTemplate$ResponseEntityResponseExtractor.extractData(RestTemplate.java:784)
at org.springframework.web.client.RestTemplate$ResponseEntityResponseExtractor.extractData(RestTemplate.java:769)
at org.springframework.web.client.RestTemplate.doExecute(RestTemplate.java:549)
at org.springframework.web.client.RestTemplate.execute(RestTemplate.java:517)
at org.springframework.web.client.RestTemplate.exchange(RestTemplate.java:462)
at org.springframework.integration.http.outbound.HttpRequestExecutingMessageHandler.handleRequestMessage(HttpRequestExecutingMessageHandler.java:421)
at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:170)
at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:78)
at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116)
at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:101)
at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:97)
at org.springframework.integration.channel.AbstractSubscribablMyChannel.doSend(AbstractSubscribablMyChannel.java:77)
at org.springframework.integration.channel.AbstractMessagMyChannel.send(AbstractMessagMyChannel.java:255)
at org.springframework.integration.channel.AbstractMessagMyChannel.send(AbstractMessagMyChannel.java:223)
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:114)
at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:44)
at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:93)
请查找以下相关代码:
客户端代码: HttpClientDemo.java
public class HttpClientDemo {
private static Logger logger = Logger.getLogger(HttpClientDemo.class);
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("/META-INF/spring/integration/http-outbound-config.xml");
RequestGateway requestGateway = context.getBean("requestGateway", RequestGateway.class);
FFSampleRequestHttp FFSampleRequesthttp = new FFSampleRequestHttp();
FFSampleRequesthttp.setMyChannelID("1");
FFSampleRequesthttp.setMyNumber("88");
FFSampleRequesthttp.setReferenceID("9I");
FFSampleRequesthttp.setTemplateType(1);
FFSampleRequesthttp.setTimestamp("today");
FFSampleResponseHttp reply = requestGateway.FFSampleResponsegatway(FFSampleRequesthttp);
logger.info("Replied with: " + reply);
}
我的请求网关如下: RequestGateway.java
public interface RequestGateway {
FFSampleResponseHttp FFSampleResponsegatway(FFSampleRequestHttp request);
}
http-outbound-config.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"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-http="http://www.springframework.org/schema/integration/http"
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">
<int:gateway id="requestGateway"
service-interface="com.mycompany.MyChannel.Common.RequestGateway"
default-request-channel="requestChannel"/>
<int:channel id="requestChannel"/>
<int:channel id="requestChannel1"/>
<!-- com.mycompany.MyChannel.model.FFSampleResponseHttp -->
<int-http:outbound-gateway request-channel="requestChannel1" reply-channel="replyChannel1" url="http://localhost:8080/MyChannel_prj-1.0.0.BUILD-SNAPSHOT/receiveGateway" http-method="POST" extract-request-payload="true" expected-response-type="com.mycompany.MyChannel.model.FFSampleResponseHttp"/>
<int:object-to-json-transformer input-channel="requestChannel" output-channel="requestChannel1" content-type="application/json" result-type="STRING"/>
<bean id="FFSampleRequestHttp" class="com.mycompany.MyChannel.model.FFSampleRequestHttp"></bean>
</beans>
Web.xml
<?xml version="1.0" encoding="ISO-8859-1" standalone="no"?>
<web-app xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.4" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
<servlet>
<servlet-name>MyChannel-http</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>/WEB-INF/servlet-config.xml</param-value>
</init-param>
<load-on-startup>2</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>MyChannel-http</servlet-name>
<url-pattern>/receiveGateway</url-pattern>
</servlet-mapping>
<welcome-file-list>
<welcome-file>index.html</welcome-file>
</welcome-file-list>
</web-app>
servlet-config.xml
<int:channel id="receivMyChannel"/>
<int-http:inbound-gateway request-channel="receivMyChannel" path="/receiveGateway" supported-methods="POST"/>
<int:service-activator input-channel="receivMyChannel">
<bean class="com.mycompany.MyChannel.serviceImpl.FFSampleHttpImpl">
<constructor-arg ref = "FFSampleRequestHttp"></constructor-arg>
</bean>
</int:service-activator>
<bean id="FFSampleRequestHttp" class="com.mycompany.MyChannel.model.FFSampleRequestHttp"></bean>
<bean id="FFSampleResponseHttp" class="com.mycompany.MyChannel.model.FFSampleResponseHttp"></bean>
</beans>
public class FFSampleHttpImpl{
private static org.apache.log4j.Logger log = Logger
.getLogger(FFSampleImpl.class);
@Autowired
FFSampleRequestHttp request;
public FFSampleHttpImpl() {
public FFSampleHttpImpl(FFSampleRequestHttp request) {
super();
this.request = request;
public String issueResponseFor(String str) throws JsonParseException, JsonMappingException, IOException {
ObjectMapper mapper = new ObjectMapper();
FFSampleRequestHttp FFSampleRequestHttp = mapper.readValue(new String(str), FFSampleRequestHttp.class);
FFSampleRequestHttp.setReferenceID("Hi My Number");
String strs = new String();
strs = mapper.writeValueAsString(FFSampleRequestHttp);
return strs;
}
FFSampleRequestHttp.java
public class FFSampleRequestHttp {
protected String MyNumber;
protected String referenceID;
protected String myChannelID;
protected String timestamp;
protected int templateType;
public String getMyNumber() {
return MyNumber;
public void setMyNumber(String MyNumber) {
this.MyNumber = MyNumber;
public String getReferenceID() {
return referenceID;
public void setReferenceID(String referenceID) {
this.referenceID = referenceID;
public String getMyChannelID() {
return myChannelID;
public void setMyChannelID(String myChannelID) {
this.myChannelID = myChannelID;
public String getTimestamp() {
return timestamp;
public void setTimestamp(String timestamp) {
this.timestamp = timestamp;
public int getTemplateType() {
return templateType;
public void setTemplateType(int templateType) {
this.templateType = templateType;
}
FFSampleResponseHttp.java
public class FFSampleResponseHttp {
protected String MyNumber;
protected String referenceID;
protected String myChannelID;
protected String timestamp;
protected int templateType;
public String getMyNumber() {
return MyNumber;
public void setMyNumber(String MyNumber) {
this.MyNumber = MyNumber;
public String getReferenceID() {
return referenceID;
public void setReferenceID(String referenceID) {
this.referenceID = referenceID;
public String getMyChannelID() {
return myChannelID;
public void setMyChannelID(String myChannelID) {
this.myChannelID = myChannelID;
public String getTimestamp() {
return timestamp;
public void setTimestamp(String timestamp) {
this.timestamp = timestamp;
public int getTemplateType() {
return templateType;
public void setTemplateType(int templateType) {
this.templateType = templateType;
}
当我运行上面的代码时,我会得到以下错误:
16:55:46.843 [main] DEBUG o.s.web.client.RestTemplate - Writing [{"MyNumber":"88","referenceID":"9I","myChannelID":"1","timestamp":"today","templateType":1}] as "text/plain;charset=UTF-8" using [org.springframework.http.converter.StringHttpMessageConverter@7d31a3e2]
16:55:46.988 [main] DEBUG o.s.web.client.RestTemplate - POST request for "http://localhost:8080/MyChannel_prj-1.0.0.BUILD-SNAPSHOT/receiveGateway" resulted in 200 (OK)
Exception in thread "main" org.springframework.web.client.RestClientException: Could not extract response: no suitable HttpMessageConverter found for response type [class com.mycompany.MyChannel.model.FFSampleResponseHttp] and content type [text/plain;charset=UTF-8]
at org.springframework.web.client.HttpMessageConverterExtractor.
我借鉴了spring集成的基本示例代码。请提供您的意见。我还尝试使用JSON配置文件中的spring来实现对象转换,但同时也为HttpMessageConverter提供了类似的问题。请帮助我对您的宝贵投入/建议,并让我知道,如果我们有任何限制的春天集成,http对象映射程序。
你好,阿特姆,谢谢你的回复。我仍然面临以下一些挑战。我已经按照您的建议对我的配置文件进行了更改。但是在使用Jackson2JsonObjectMapper时会遇到问题,需要您的进一步帮助。请查找下面的问题说明。
我已经对我的文件进行了更改,现在的文件如下所示: Servlet-Config.xml文件内容如下所示:
<int:channel id="channel1" />
<int:channel id="channel2" />
<int:channel id="channel3" />
<int-http:inbound-gateway request-channel="channel1" supported-methods="POST" path="/receiveGateway" />
- <int:service-activator input-channel="channel2">
- <bean class="com.myCompany.myChannel.serviceImpl.FFSampleHttpImpl">
<constructor-arg ref="ffSampleRequestHttp" />
</bean>
</int:service-activator>
<int:json-to-object-transformer input-channel="channel1" output-channel="channel2" type="com.myCompany.myChannel.model.FFSampleRequestHttp" object-mapper="jackson2JsonObjectMapper" />
<bean id="jackson2JsonObjectMapper" class="org.springframework.integration.support.json.Jackson2JsonObjectMapper" />
<bean id="ffSampleRequestHttp" class="com.myCompany.myChannel.model.FFSampleRequestHttp" />
<bean id="ffSampleResponseHttp" class="com.myCompany.myChannel.model.FFSampleResponseHttp" />
</beans>
外绑定文件配置(负责向服务器发送消息的文件):
<int:gateway id="requestGateway" service-interface="com.myCompany.myChannel.Common.RequestGateway" default-request-channel="requestChannel" />
<int:channel id="requestChannel" />
<int:channel id="requestChannel1" />
<int:object-to-json-transformer input-channel="requestChannel" output-channel="requestChannel1" content-type="application/json" />
<int-http:outbound-gateway request-channel="requestChannel1" reply-channel="channel4" url="http://localhost:8080/myChannel_prj-1.0.0.BUILD-SNAPSHOT/http/receiveGateway" http-method="POST" />
<bean id="FFSampleRequestHttp" class="com.myCompany.myChannel.model.FFSampleRequestHttp" />
<int:json-to-object-transformer input-channel="channel4" output-channel="requestChannel" type="com.myCompany.myChannel.model.FFSampleResponseHttp" object-mapper="jackson2JsonObjectMapper" />
<bean id="jackson2JsonObjectMapper" class="org.springframework.integration.support.json.Jackson2JsonObjectMapper" />
</beans>
我的impl类方法如下:
public FfSampleResponseHttp issueResponseFor(FfSampleRequestHttp request) {
FfSampleResponseHttp ffSampleResponse2 = new FfSampleResponseHttp();
ffSampleResponse2.setCifNumber("Yappi I am in the method");
log.info("issueResponseFor(FfSampleRequesthttp request)");
return ffSampleResponse2;
}
我可以从客户端调用服务器端的服务方法issueResponseFor,但在进一步处理时:
Caused by: java.lang.IllegalArgumentException: 'json' argument must be an instance of: [class java.lang.String, class [B, class java.io.File, class java.net.URL, class java.io.InputStream, class java.io.Reader]
at org.springframework.integration.support.json.Jackson2JsonObjectMapper.fromJson(Jackson2JsonObjectMapper.java:93)
at org.springframework.integration.support.json.Jackson2JsonObjectMapper.fromJson(Jackson2JsonObjectMapper.java:44)
at org.springframework.integration.support.json.AbstractJacksonJsonObjectMapper.fromJson(AbstractJacksonJsonObjectMapper.java:55)
at org.springframework.integration.json.JsonToObjectTransformer.doTransform(JsonToObjectTransformer.java:78)
at org.springframework.integration.transformer.AbstractTransformer.transform(AbstractTransformer.java:33)
... 54 more
在调试过程中,我验证了响应时的有效载荷体在Jackson2JsonObjectMapper.fromJson(…)参数中json对象中为空。成功地漫游了我的服务方法。我不明白我在哪里搞错了。请提供您的帮助/输入。如果我再次丢失配置文件中的某些内容,请再次通知我。非常感谢您的支持。
由于您只返回到客户机
String
及其
content type == 'text/plain'
,因此默认转换器无法确定如何将
String
响应转换为
FFSampleResponseHttp
对象。
修复它的简单方法是:
expected-response-type
中删除
<int-http:outbound-gateway>
replyChannel1
<json-to-object-transformer>
中
否则,您应该编写自己的
HttpMessageConverter
来将字符串转换为适当的对象。
要使它与
MappingJackson2HttpMessageConverter
(默认转换器之一)和您的
expected-response-type
一起工作,您应该使用
content type = 'application/json'
发送您的回复。
如果需要,只需在您的
<header-enricher>
之后添加
<service-activator>
,然后再向
<int-http:inbound-gateway>
发送回复即可。
因此,这取决于您选择哪种解决方案,但由于与默认配置不一致,您的当前状态无法工作。
更新
好的。由于您将服务器更改为将
FfSampleResponseHttp
对象作为HTTP返回,而不是字符串,所以只需在发送HTTP响应之前添加
contentType = 'application/json'
头,而
MappingJackson2HttpMessageConverter
将为您完成此任务--您的对象将被转换为JSON并具有正确的
contentType
报头。
从客户端,您应该回到
expected-response-type="com.mycompany.MyChannel.model.FFSampleResponseHttp"
,
MappingJackson2HttpMessageConverter
应该再次为您做这些事情。
当然,您应该在
<json-to-object-transformer>
之后从消息流中删除
<int-http:outbound-gateway>
。
public class Application {
private static List<HttpMessageConverter<?>> getMessageConverters() {
List<HttpMessageConverter<?>> converters = new ArrayList<HttpMessageConverter<?>>();
converters.add(new MappingJacksonHttpMessageConverter());
return converters;
public static void main(String[] args) {
RestTemplate restTemplate = new RestTemplate();
restTemplate.setMessageConverters(getMessageConverters());
HttpHeaders headers = new HttpHeaders();
headers.setAccept(Arrays.asList(MediaType.APPLICATION_JSON));
HttpEntity<String> entity = new HttpEntity<String>(headers);
//Page page = restTemplate.getForObject("http://graph.facebook.com/pivotalsoftware", Page.class);
ResponseEntity<Page> response =
restTemplate.exchange("http://graph.facebook.com/skbh86", HttpMethod.GET, entity, Page.class, "1");
Page page = response.getBody();
System.out.println("Name: " + page.getId());
System.out.println("About: " + page.getFirst_name());
System.out.println("Phone: " + page.getLast_name());
System.out.println("Website: " + page.getMiddle_name());
System.out.println("Website: " + page.getName());
}
![]() |
温柔的玉米 · 新书发布 | 《数字建造》系列丛书来了!_建筑业 2 月前 |
![]() |
礼貌的汉堡包 · 小新pro14真的很好吗? - 知乎 11 月前 |
![]() |
急躁的自行车 · 设计师的仿生椅子真是脑洞大开! - 知乎 1 年前 |
![]() |
爱听歌的筷子 · 王阶:广安门中医院如何推进中西医结合-新华网 1 年前 |