Spring Integration 提供了一个 API 和配置，用于与在同一应用程序上下文中声明的 Apache Camel 端点进行通信。Spring中文文档

您需要将此依赖项包含在项目中：Spring中文文档

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-camel</artifactId>
    <version>6.3.1</version>
</dependency>
compile "org.springframework.integration:spring-integration-camel:6.3.1"

Spring Integration 和 Apache Camel 实现了企业集成模式，并提供了一种方便的方法来组合它们，但项目使用不同的方法来实现它们的 API 和抽象。 Spring Integration 完全依赖于 Spring Core 中的依赖注入容器。 它使用许多其他 Spring 项目（Spring Data、Spring AMQP、Spring for Apache Kafka 等）来实现其通道适配器。 它还将抽象用作开发人员在编写集成流时需要注意的一等公民。 另一方面，Apache Camel 不提供消息通道的一等公民抽象，并建议通过内部交换来组合其路由，隐藏在 API 之外。 此外，它需要一些额外的依赖项和配置才能在 Spring 应用程序中使用。MessageChannelSpring中文文档

即使对于最终的企业集成解决方案来说，如何实现其部分并不重要，开发人员体验和高生产力也会被考虑在内。 因此，开发人员可能会出于多种原因选择一个框架而不是另一个框架，或者如果某些目标系统支持存在差距，则两者兼而有之。 Spring Integration 和 Apache Camel 应用程序可以通过许多外部协议相互交互，它们为这些协议实现通道适配器。 例如，Spring Integration 流可能会将记录发布到 Apache Kafka 主题，该主题由使用者端的 Apache Camel 端点使用。 或者，Apache Camel 路由可能会将数据写入该目录的 SFTP 文件，该文件由 Spring Integration 的 SFTP 入站通道适配器轮询。 或者，在同一个 Spring 应用程序上下文中，它们可以通过抽象进行通信。ApplicationEventSpring中文文档

为了简化开发过程，并避免不必要的网络跳跃，Apache Camel 提供了一个模块，用于通过消息通道与 Spring Integration 进行通信。 所需要的只是从应用程序上下文中引用 a 来发送或使用消息。 当 Apache Camel 路由是消息流的发起者，并且 Spring Integration 仅作为解决方案的一部分起支持作用时，这很有效。MessageChannelSpring中文文档

为了获得类似的开发人员体验，Spring Integration 现在提供了一个通道适配器来调用 Apache Camel 端点，并可以选择等待回复。 没有入站通道适配器，因为从 Spring 集成 API 和抽象的角度来看，订阅用于使用 Apache Camel 消息就足够了。MessageChannelSpring中文文档

Apache Camel 的出站通道适配器

这是一个实现，可以在单向（默认）和请求-回复模式下工作。 它使用 an 发送（或发送和接收）到 . 交互模式可以通过该选项控制（可以在运行时通过 SpEL 表达式根据请求消息进行评估）。 可以显式配置目标 Apache Camel 端点，也可以将其配置为要在运行时计算的 SpEL 表达式。 否则，它将回退到 . 可以提供内联显式端点，而不是指定端点，例如，调用 Spring Integration 中没有通道适配器支持的 Apache Camel 组件。CamelMessageHandlerAbstractReplyProducingMessageHandlerorg.apache.camel.ProducerTemplateorg.apache.camel.EndpointExchangePatterndefaultEndpointProducerTemplateLambdaRouteBuilderSpring中文文档

此外，还可以提供一个（默认实现）来确定在 Spring Integration 和 Apache Camel 消息之间映射哪些标头。 默认情况下，映射所有标头。HeaderMapper<org.apache.camel.Message>CamelHeaderMapperSpring中文文档

支持调用和生成用于回复处理的模式（如果有）。CamelMessageHandlerasyncProducerTemplate.asyncSend()CompletableFutureSpring中文文档

可以通过 SpEL 表达式进行自定义，该表达式的计算结果必须为 .exchangePropertiesMapSpring中文文档

如果未提供 a，则通过从应用程序上下文解析的 Bean 创建它。ProducerTemplateCamelContextSpring中文文档

@Bean
@ServiceActivator(inputChannel = "sendToCamel")
CamelMessageHandler camelService(ProducerTemplate producerTemplate) {
    CamelHeaderMapper headerMapper = new CamelHeaderMapper();
    headerMapper.setOutboundHeaderNames("");
    headerMapper.setInboundHeaderNames("testHeader");

    CamelMessageHandler camelMessageHandler = new CamelMessageHandler(producerTemplate);
    camelMessageHandler.setEndpointUri("direct:simple");
    camelMessageHandler.setExchangePatternExpression(spelExpressionParser.parseExpression("headers.exchangePattern"));
    camelMessageHandler.setHeaderMapper(headerMapper);
    return camelMessageHandler;
}

对于 Java DSL 流定义，可以使用工厂提供的一些变体来配置此通道适配器：CamelSpring中文文档

@Bean
IntegrationFlow camelFlow() {
    return f -> f
            .handle(Camel.gateway().endpointUri("direct:simple"))
            .handle(Camel.route(this::camelRoute))
            .handle(Camel.handler().endpointUri("log:com.mycompany.order?level=WARN"));
}

private void camelRoute(RouteBuilder routeBuilder) {
    routeBuilder.from("direct:inbound").transform(routeBuilder.simple("${body.toUpperCase()}"));
}