如何通过Apache Camel将对象列表批量保存至MongoDB？

你的核心问题是消息体类型不符合MongoDB组件的预期：

• 发送单个UserBean时，序列化后的JSON是单个对象结构，Camel MongoDB组件能自动将byte[]转为单个Document，匹配默认save操作的要求。
• 发送列表时，你把List<UserBean>序列化成了JSON数组的byte[]，此时组件尝试将这个字节流转为单个Document，但JSON数组对应的BSON类型是ARRAY，自然转换失败——因为默认save操作只接受单个文档，而非数组/列表结构。

另外，MongoDB组件支持直接处理Java对象列表实现批量插入，但前提是消息体是Java列表对象，而非JSON数组的字节流。

方案1：直接传递Java列表对象（推荐） #

修改TransformRoute，移除Jackson序列化步骤，直接将List<UserBean>发送到ActiveMQ，让MongoDB组件直接处理Java对象列表：

from("activemq:unpacked")
    .unmarshal(new BindyCsvDataFormat(UserBean.class)) // 得到List<UserBean>
    // 移除JSON序列化，直接传递Java列表
    .to("activemq:save");

在PersistRoute中，显式指定MongoDB组件的批量插入操作：

from("activemq:save")
    // 指定operation为batchInsert，明确处理列表批量插入
    .to("mongodb:mongoClient?database=test&collection=user&operation=batchInsert");

注：部分Camel版本中operation=insert即可自动识别并处理列表，可根据实际版本调整。

方案2：若必须传递JSON数组 #

如果因跨语言等场景必须传递JSON格式，需要在PersistRoute中先将JSON数组的byte[]反序列化为Java列表，再传给MongoDB组件：

from("activemq:save")
    // 反序列化JSON数组为List<UserBean>
    .unmarshal(new JacksonDataFormat(new TypeReference<List<UserBean>>() {}))
    .to("mongodb:mongoClient?database=test&collection=user&operation=batchInsert");

• 不要将Java列表序列化为JSON数组后传递，这会丢失对象类型信息，导致MongoDB组件无法识别这是需要批量插入的列表。
• 处理列表时必须显式指定批量插入类操作，默认save仅支持单文档操作。

内容的提问来源于stack exchange，提问作者Chris