主页
产品
Red Hat build of Apache Camel for Spring Boot
3.18
Camel Spring Boot 参考
60.4. 使用 Java DSL

60.4. 使用 Java DSL

下一步实例化与此记录类型关联的 DataFormat bindy 类，并提供类作为参数。

例如，以下命令使用类 BindyCsvDataFormat （对应于与 CSV 记录类型关联的类），该类配置了 com.acme.model.MyModel.class 来初始化在此软件包中配置的模型对象。

DataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

DataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

Copy to Clipboard

Toggle word wrap

60.4.1. 设置区域设置
复制链接

Bindy 支持在 dataformat 上配置区域设置，如

BindyCsvDataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

bindy.setLocale("us");

BindyCsvDataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

bindy.setLocale("us");

Copy to Clipboard

Toggle word wrap

或者使用平台默认区域设置，然后使用"default"作为区域设置的名称。

BindyCsvDataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

bindy.setLocale("default");

BindyCsvDataFormat bindy = new BindyCsvDataFormat(com.acme.model.MyModel.class);

bindy.setLocale("default");

Copy to Clipboard

Toggle word wrap

60.4.2. unmarshaling
复制链接

from("file://inbox")
  .unmarshal(bindy)
  .to("direct:handleOrders");

from("file://inbox")
  .unmarshal(bindy)
  .to("direct:handleOrders");

Copy to Clipboard

Toggle word wrap

另外，您可以使用对数据格式的命名引用，然后可以在 Registry 中定义，例如您的 Spring XML 文件：

from("file://inbox")
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");

from("file://inbox")
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");

Copy to Clipboard

Toggle word wrap

Camel 路由将获取 inbox 目录中的文件，unmarshall CSV 记录为模型对象的集合，并将集合
发送到由 handleOrders 引用的路由。

返回的集合是 Map 对象列表。列表中的每一映射都包含在 CSV 每行中模糊的模型对象。其背后的原因是 每行可以与多个对象对应。当您只期望每行返回一个对象时，这可能会造成混淆。

每个对象都可以使用其类名称来检索。

List<Map<String, Object>> unmarshaledModels = (List<Map<String, Object>>) exchange.getIn().getBody();

int modelCount = 0;
for (Map<String, Object> model : unmarshaledModels) {
  for (String className : model.keySet()) {
     Object obj = model.get(className);
     LOG.info("Count : " + modelCount + ", " + obj.toString());
  }
 modelCount++;
}

LOG.info("Total CSV records received by the csv bean : " + modelCount);

List<Map<String, Object>> unmarshaledModels = (List<Map<String, Object>>) exchange.getIn().getBody();

int modelCount = 0;
for (Map<String, Object> model : unmarshaledModels) {
  for (String className : model.keySet()) {
     Object obj = model.get(className);
     LOG.info("Count : " + modelCount + ", " + obj.toString());
  }
 modelCount++;
}

LOG.info("Total CSV records received by the csv bean : " + modelCount);

Copy to Clipboard

Toggle word wrap

假设您要从此映射中提取单个 Order 对象以在路由中处理，您可以使用 Splitter 和一个 Processor 的组合，如下所示：

from("file://inbox")
    .unmarshal(bindy)
    .split(body())
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                Message in = exchange.getIn();
                Map<String, Object> modelMap = (Map<String, Object>) in.getBody();
                in.setBody(modelMap.get(Order.class.getCanonicalName()));
            }
        })
        .to("direct:handleSingleOrder")
    .end();

from("file://inbox")
    .unmarshal(bindy)
    .split(body())
        .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
                Message in = exchange.getIn();
                Map<String, Object> modelMap = (Map<String, Object>) in.getBody();
                in.setBody(modelMap.get(Order.class.getCanonicalName()));
            }
        })
        .to("direct:handleSingleOrder")
    .end();

Copy to Clipboard

Toggle word wrap

请注意，Bindy 使用 CHARSET_NAME 属性或 CHARSET_NAME 标头，如 Exchange 界面中所定义，为 unmarshalling 接收输入流的字符转换。在一些制作者（如 file-endpoint）中，您可以定义一个 characterset。字符集转换过程可能已经由此制作者完成。有时，您需要从交换中删除此属性或标头，然后再将其发送到 unmarshal。如果您没有删除它，则转换可能会进行两次，这可能会导致不必要的结果。

from("file://inbox?charset=Cp922")
  .removeProperty(Exchange.CHARSET_NAME)
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");

from("file://inbox?charset=Cp922")
  .removeProperty(Exchange.CHARSET_NAME)
  .unmarshal("myBindyDataFormat")
  .to("direct:handleOrders");

Copy to Clipboard

Toggle word wrap

60.4.3. marshaling
复制链接

要从模型对象集合生成 CSV 记录，您需要创建以下路由：

from("direct:handleOrders")
   .marshal(bindy)
   .to("file://outbox")

from("direct:handleOrders")
   .marshal(bindy)
   .to("file://outbox")

Copy to Clipboard

Toggle word wrap

返回顶部

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情，请参阅红帽博客.

關於紅帽

我们提供强化的解决方案，使企业能够更轻松地跨平台和环境（从核心数据中心到网络边缘）工作。

Theme

© 2025 Red Hat