草庐IT

关于 java:Camel POST RestService 接受 JSONArray ：注释和解析错误

codeneng 2023-03-28 原文

Camel POST RestService accepting JSONArray : annotations and parsing errors

我正在尝试构建一个 Apache Camel (v2.15) 路由来处理 REST 服务上的 POST 请求。

预期的 POST 请求将如下所示(一个 JSONArray 表示 JSONObjects 的列表，这些 JSONObjects 都是单一给定类型的所有实例)：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
Content-Type:application/json;charset=UTF-8

[
    {
       "aaa":"TEST",
       "bbb":"TEST",
       "ccc": 5004000
    },
    {
       "aaa":"TEXT",
       "bbb":"TEXT",
       "ccc": 5004001
    },
    ...
]

我的问题是配置东西以使 POST 正文正确反序列化...

这里是路由定义：

1
2
3
4
from("cxfrs:bean:messageServer").choice()
        .when(header("operationName").isEqualTo("postJsonMessage"))
        .beanRef("messageService","postJsonMessage")
        .end();

现在，通过 beanRef 行引用的服务定义：

1
2
3
4
5
6
7
8
9
10
11
@Path("/root-path/")
public class MyService {
    private final Logger logger = LoggerFactory.getLogger(MyService.class);

    @POST
    @Path("/message/")
    @Consumes(MediaType.APPLICATION_JSON +";charset=UTF-8")
    public void postJsonMessage(@Body final List<CustomMessage> data) {
        logger.info("body size :" + data.size());
    }
}

以及描述未序列化列表项的POJO：

1
2
3
4
5
6
7
public class CustomMessage {
    private String aaa;
    private String bbb;
    private int ccc;

    // ...getters and setters...
}

当我在 POJO 上不使用注释时，我得到了这个异常：

1
JAXRSUtils | 152 - org.apache.cxf.cxf-core - 3.0.6 | No message body reader has been found for class java.util.List, ContentType: application/json;charset=UTF-8

但是如果我在 POJO 上使用@XMLRootElement，我得到一个 JSON 解析异常：

1
2
3
4
5
6
7
AbstractJAXBProvider | 152 - org.apache.cxf.cxf-core - 3.0.6 | javax.xml.stream.XMLStreamException: ParseError at [row,col]:[0,1] Message: A JSONObject text must begin with '{' at character 1 of [
    {
       "aaa":"TEST",
       "bbb":"TEST",
       "ccc": 5004000
    },
    ...

那么如何配置解析器以将发布的数据解释为 JSONArray 而不是 JSONObject？

提前感谢您的帮助:)

最后，通过使用org.codehaus.jackson.jaxrs.JacksonJaxbJsonProvider和@Body参数的数组类型定义，找到了我的问题的解决方案：

所以，在 camel-context.xml 中我们定义了一个提供程序并在 osgi:

中安装了相关的库

1
2
3
4
5
6
7
<cxf:rsServer id="messageServer"
    address="http://0.0.0.0:${rest.service.message.port}"
    serviceClass="com.example.service.MyService">
    <cxf:providers>
        <bean class="org.codehaus.jackson.jaxrs.JacksonJaxbJsonProvider" />
    </cxf:providers>
</cxf:rsServer>

所需的库是(在我们的环境中)：

1
2
3
4
install mvn:org.codehaus.jackson/jackson-core-asl/1.9.12
install mvn:org.codehaus.jackson/jackson-mapper-asl/1.9.12
install mvn:org.codehaus.jackson/jackson-jaxrs/1.9.12
install mvn:org.codehaus.jackson/jackson-xc/1.9.12

然后，服务方法签名被修改为期望一个 CustomMessage 对象数组：

1
2
3
4
5
6
    @POST
    @Path("/message/")
    @Consumes(MediaType.APPLICATION_JSON +";charset=UTF-8")
    public void postJsonMessage(@Body final CustomMessage[] data) {
        // process data...
    }

此外，在路由构建器中添加了类型定义：

1
2
3
4
5
    from("cxfrs:bean:messageServer").choice()
            .when(header("operationName").isEqualTo("postJsonMessage"))
            .convertBodyTo(CustomMessage[].class)
            .beanRef("messageService","postJsonMessage")
            .end();

我记得遇到过类似的问题(但与编组有关)。
解决方法是在列表周围定义一个package器，以便 Jackson 库现在能够解组您的 JSON 有效负载

1
2
3
4
5
6
7
8
public class CustomMessageList extends ArrayList<CustomMessage> {};

@POST
@Path("/message/")
@Consumes(MediaType.APPLICATION_JSON +";charset=UTF-8")
public void postJsonMessage(@Body final CustomMessageList data) {
   logger.info("body size :" + data.size());
}

希望这会有所帮助。

  • 感谢您的回答，我无法让它按原样工作，但尝试更改 @Body 参数的类型定义中的内容是一个很好的提示......

RestServiceJSONArrayspanclassnbspapache-cameljavajson

有关关于 java:Camel POST RestService 接受 JSONArray ：注释和解析错误的更多相关文章

  1. ruby-on-rails - Rails 常用字符串(用于通知和错误信息等) - 2

    大约一年前，我决定确保每个包含非唯一文本的Flash通知都将从模块中的方法中获取文本。我这样做的最初原因是为了避免一遍又一遍地输入相同的字符串。如果我想更改措辞，我可以在一个地方轻松完成，而且一遍又一遍地重复同一件事而出现拼写错误的可能性也会降低。我最终得到的是这样的:moduleMessagesdefformat_error_messages(errors)errors.map{|attribute,message|"Error:#{attribute.to_s.titleize}#{message}."}enddeferror_message_could_not_find(obje

  2. java - 等价于 Java 中的 Ruby Hash - 2

    我真的很习惯使用Ruby编写以下代码:my_hash={}my_hash['test']=1Java中对应的数据结构是什么？ 最佳答案 HashMapmap=newHashMap();map.put("test",1);我假设？ 关于java-等价于Java中的RubyHash，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/22737685/

  3. ruby-on-rails - 迷你测试错误 : "NameError: uninitialized constant" - 2

    我遵循MichaelHartl的“RubyonRails教程:学习Web开发”，并创建了检查用户名和电子邮件长度有效性的测试(名称最多50个字符，电子邮件最多255个字符)。test/helpers/application_helper_test.rb的内容是:require'test_helper'classApplicationHelperTest在运行bundleexecraketest时，所有测试都通过了，但我看到以下消息在最后被标记为错误:ERROR["test_full_title_helper",ApplicationHelperTest,1.820016791]test

  4. ruby-on-rails - 如何在 Rails View 上显示错误消息？ - 2

    我是rails的新手，想在form字段上应用验证。myviewsnew.html.erb.....模拟.rbclassSimulation{:in=>1..25,:message=>'Therowmustbebetween1and25'}end模拟Controller.rbclassSimulationsController我想检查模型类中row字段的整数范围，如果不在范围内则返回错误信息。我可以检查上面代码的范围，但无法返回错误消息提前致谢 最佳答案 关键是您使用的是模型表单，一种显示ActiveRecord模型实例属性的表单。c

  5. 使用 ACL 调用 upload_file 时出现 Ruby S3 "Access Denied"错误 - 2

    我正在尝试编写一个将文件上传到AWS并公开该文件的Ruby脚本。我做了以下事情:s3=Aws::S3::Resource.new(credentials:Aws::Credentials.new(KEY,SECRET),region:'us-west-2')obj=s3.bucket('stg-db').object('key')obj.upload_file(filename)这似乎工作正常，除了该文件不是公开可用的，而且我无法获得它的公共(public)URL。但是当我登录到S3时，我可以正常查看我的文件。为了使其公开可用，我将最后一行更改为obj.upload_file(file

  6. ruby-on-rails - 错误 : Error installing pg: ERROR: Failed to build gem native extension - 2

    我克隆了一个rails仓库，我现在正尝试捆绑安装背景:OSXElCapitanruby2.2.3p173(2015-08-18修订版51636)[x86_64-darwin15]rails-v在您的Gemfile中列出的或native可用的任何gem源中找不到gem'pg(>=0)ruby​​'。运行bundleinstall以安装缺少的gem。bundleinstallFetchinggemmetadatafromhttps://rubygems.org/............Fetchingversionmetadatafromhttps://rubygems.org/...Fe

  7. ruby - ＃之间？ Cooper 的 *Beginning Ruby* 中的错误或异常 - 2

    在Cooper的书BeginningRuby中，第166页有一个我无法重现的示例。classSongincludeComparableattr_accessor:lengthdef(other)@lengthother.lengthenddefinitialize(song_name,length)@song_name=song_name@length=lengthendenda=Song.new('Rockaroundtheclock',143)b=Song.new('BohemianRhapsody',544)c=Song.new('MinuteWaltz',60)a.betwee

  8. ruby-on-rails - 每次我尝试部署时，我都会得到 - (gcloud.preview.app.deploy) 错误响应 : [4] DEADLINE_EXCEEDED - 2

    我是Google云的新手，我正在尝试对其进行首次部署。我的第一个部署是RubyonRails项目。我基本上是在关注thisguideinthegoogleclouddocumentation.唯一的区别是我使用的是我自己的项目，而不是他们提供的“helloworld”项目。这是我的app.yaml文件runtime:customvm:trueentrypoint:bundleexecrackup-p8080-Eproductionconfig.ruresources:cpu:0.5memory_gb:1.3disk_size_gb:10当我转到我的项目目录并运行gcloudprevie

  9. ruby-on-rails - Rails 5 Active Record 记录无效错误 - 2

    我有两个Rails模型，即Invoice和Invoice_details。一个Invoice_details属于Invoice，一个Invoice有多个Invoice_details。我无法使用accepts_nested_attributes_forinInvoice通过Invoice模型保存Invoice_details。我收到以下错误:(0.2ms)BEGIN(0.2ms)ROLLBACKCompleted422UnprocessableEntityin25ms(ActiveRecord:4.0ms)ActiveRecord::RecordInvalid(Validationfa

  10. arrays - 这是 Ruby 中 Array.fill 方法的错误吗？ - 2

    这个问题在这里已经有了答案:Arraysmisbehaving(1个回答)关闭6年前。是否应该这样，即我误解了，还是错误？a=Array.new(3,Array.new(3))a[1].fill('g')=>[["g","g","g"],["g","g","g"],["g","g","g"]]它不应该导致:=>[[nil,nil,nil],["g","g","g"],[nil,nil,nil]]

随机推荐