json - 如何在 Camel 中的自定义拆分器之后链接路由器

Question

我想从 JSON 有效负载中提取文档，并根据它们的位置将它们发送到不同的处理器。

JSON：

{
    "email" : {
        "documents" : [{
                "name" : "Document 1",
                "id" : "1111"
            }, {
                "name" : "Document 2",
                "id" : "222"
            }
        ]
    },
    "sms" : {
        "documents" : [{
                "name" : "Document 3",
                "id" : "3333"
            }, {
                "name" : "Document 4",
                "id" : "4444"
            }
        ]
    }
}

我正在考虑通过执行以下操作来实现这一目标：

from("servlet:///doc").unmarshal()
  .json(JsonLibrary.Jackson, DocumentRequest.class)
  .split().method("docSplit", "split")
  .choice()
    .when().header("mode").isEqualTo("email")
      .to("direct:email")
    .when().header("mode").isEqualTo("sms")
      .to("direct:sms");

我的拆分器可以接收 DocumentRequest 并拉出所有文档……但我不知道如何为将来的路由设置“模式”标头。

如何设置“模式”标题？

有更好的整体方法吗？

Answer 1

您始终可以将自定义拆分逻辑放在自定义处理器中并使用 ProducerTemplate

例如：

    from("servlet:///doc").unmarshal()
              .json(JsonLibrary.Jackson, DocumentRequest.class)
              .process(new Processor()  {
                    @Override
                    public void process(Exchange exchange) throws Exception {
                        ProducerTemplate producer=exchange.getContext().createProducerTemplate();

                        String mode;
                        for (Document doc: // split and set mode logic goes here ) {
                            if (mode.compareToIgnoreCase("email") ==0) {
                                producer.sendBody("direct:email", doc);
                            } else 
                            if (mode.compareToIgnoreCase("sms") ==0) {
                                producer.sendBody("direct:sms", doc);
                            }
...
                        }
                    }
              });