JSON的Camel绑定模式不起作用，无法将其解组到POJO

0kjbasz6  于 2022-11-07  发布在  Apache
关注(0)|答案(2)|浏览(163)

我尝试将消息从REST API发送到新路由，即使我在REST API上接收到JSON格式的请求，并且绑定设置为JSON，当我将其转发到新路由时，它将显示为InputStream，我必须将其封送为JSON才能使用它。
我已经试过在RestConfiguration中使用streamCaching和其他组件（消费、生产、类型、数据类型）。

  1. public void configure() {
  2.     restConfiguration().component("servlet")
  3.             .bindingMode(RestBindingMode.json)
  4.             .skipBindingOnErrorCode(false);
  6.     rest("/resttest")
  7.        .patch("/t1")
  8.             .id("t1")
  9.             .description("t1")
  10.             .consumes("application/json")
  11.             .produces("application/json")
  12.             .param()
  13.                 .name("body")
  14.                .type(RestParamType.body)
  15.                .dataType("json")
  16.                 .required(true)
  17.             .endParam()
  18.             .to("direct:test2");

此路由在其他类中：

  1. from("direct:test2").id("test2")
  3.             .marshal().json(JsonLibrary.Jackson,SomePOJO.class)
  4.             .unmarshal().json(JsonLibrary.Jackson, SomePOJO.class)
  5.             .choice()
  6.             .when(simple("${body.getStatus()} =~ 'Closed'"))
  7.             .....

我希望在test2路由上得到JSON消息，但不知何故我得到了InputStream，所以我必须首先进行封送处理。有人知道我如何让REST API转发我以JSON格式路由消息，而不是作为流吗？

apache-camel

2条答案

按热度按时间
of1yzvn4

of1yzvn41#

请尝试：

  1. .convertBodyTo(String.class)

在你解组之前

赞(0）分享  回复(0）举报  2022-11-07
ny6fqffe

ny6fqffe2#

我遇到了同样的问题，我必须对传入的值应用编组方法，对响应应用解组方法。
这是 Postman 的回答：

我用的是这个代码：

  1. rest(service.service)
  2. .description(ContentCategory.api("Service Test"))           
  3. .post("/product/{productType}/{enterpriseId}")
  4. .description("service for saving a product")
  5. .consumes(MediaType.APPLICATION_JSON)
  6. .type(Product.class)
  7. .bindingMode(RestBindingMode.json)
  8. .produces(MediaType.APPLICATION_JSON)
  9. .outType(String.class)
  10. .route()
  11. .bean("productService", "saveProduct")
  12. .marshal()
  13. .json(JsonLibrary.Jackson)
  14. .setHeader(Exchange.CONTENT_TYPE, constant(MediaType.APPLICATION_JSON))
  15. .endRest();

我只是在意识到接收到InputStream之后添加了unmarshall方法

  1. rest(service.service)
  2. .description(ContentCategory.api("Service Test"))           
  3. .post("/product/{productType}/{enterpriseId}")
  4. .description("service for saving a product")
  5. .consumes(MediaType.APPLICATION_JSON)
  6. .type(Product.class)
  7. .bindingMode(RestBindingMode.json)
  8. .produces(MediaType.APPLICATION_JSON)
  9. .outType(String.class)
  10. .route()
  11. .bean("productService", "saveProduct")
  12. .marshal()
  13. .json(JsonLibrary.Jackson)
  14. .unmarshal()
  15. .json(JsonLibrary.Jackson)
  16. .setHeader(Exchange.CONTENT_TYPE, constant(MediaType.APPLICATION_JSON))
  17. .endRest();

其实我只是加了这两行

  1. .unmarshal()
  2. .json(JsonLibrary.Jackson)

它开始工作：

它认为您可能需要对resttest服务使用解组方法。

展开查看全部
赞(0）分享  回复(0）举报  2022-11-07
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com