红帽全球峰会2.2. Spring Boot
Spring Boot 会自动为您配置 Camel。Camel 上下文自动探测到 Spring 上下文中提供的 Camel 路由，并将密钥 Camel 实用程序（如生成者模板、消费者模板和类型转换器）注册为 Bean。
Maven 用户需要将以下依赖项添加到其 pom.xml 中，以便使用此组件：
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot</artifactId>
</dependency>
camel-spring-boot jar 附带 spring.factories 文件，因此当您将该依赖项添加到类路径时，Spring Boot 将自动为您配置 Camel。
2.2.1. Camel Spring Boot Starter
Apache Camel 提供了一个 Spring Boot Starter 模块，允许您使用 starters 开发 Spring Boot 应用程序。
example 存储库中也提供了 示例应用程序。
要使用启动程序，将以下内容添加到 spring boot pom.xml 文件中：
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
</dependency>然后，您可以使用 Camel 路由添加类，例如：
package com.example;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class MyRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("timer:foo").to("log:bar");
}
}
package com.example;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;
@Component
public class MyRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("timer:foo").to("log:bar");
}
}然后，这些路由将自动启动。
您可以在 application.properties 或 application.yml 文件中自定义 Camel 应用程序。
2.2.2. Spring Boot 自动配置
当在 Spring Boot 中使用 spring-boot 时，请确保使用以下 Maven 依赖项来支持自动配置：
<dependency> <groupId>org.apache.camel.springboot</groupId> <artifactId>camel-spring-boot-starter</artifactId> </dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
</dependency>2.2.3. 自动配置的 Camel 上下文
Camel 自动配置提供的最重要功能是 CamelContext 实例。Camel 自动配置为您创建一个 SpringCamelContext，并负责正确初始化和关闭该上下文。创建的 Camel 上下文也在 Spring 应用程序上下文中注册（在 camelContext bean 名称下），因此您可以像任何其他 Spring bean 一样访问它。
@Configuration
public class MyAppConfig {
@Autowired
CamelContext camelContext;
@Bean
MyService myService() {
return new DefaultMyService(camelContext);
}
}
@Configuration
public class MyAppConfig {
@Autowired
CamelContext camelContext;
@Bean
MyService myService() {
return new DefaultMyService(camelContext);
}
}2.2.4. 自动探测 Camel 路由
Camel 自动配置从 Spring 上下文收集所有 RouteBuilder 实例，并自动将它们注入到提供的 CamelContext 中。这意味着，使用 Spring Boot starter 创建新的 Camel 路由非常简单，就像将 @Component 注解类添加到您的 classpath 中一样简单：
@Component
public class MyRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:invoices").to("file:/invoices");
}
}
@Component
public class MyRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:invoices").to("file:/invoices");
}
}
或者在您的 @Configuration 类中创建新的路由 RouteBuilder bean：
@Configuration
public class MyRouterConfiguration {
@Bean
RoutesBuilder myRouter() {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
from("jms:invoices").to("file:/invoices");
}
};
}
}
@Configuration
public class MyRouterConfiguration {
@Bean
RoutesBuilder myRouter() {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
from("jms:invoices").to("file:/invoices");
}
};
}
}2.2.5. Camel 属性
Spring Boot 自动配置会使用 Camel 属性支持自动连接到 Spring Boot 外部配置 （可能包含属性占位符、操作系统环境变量或系统属性）。它基本上表示 application.properties 文件中定义的任何属性：
route.from = jms:invoices
route.from = jms:invoices或者通过系统属性设置：
java -Droute.to=jms:processed.invoices -jar mySpringApp.jar
java -Droute.to=jms:processed.invoices -jar mySpringApp.jar可用作 Camel 路由中的占位符：
@Component
public class MyRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("{{route.from}}").to("{{route.to}}");
}
}
@Component
public class MyRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("{{route.from}}").to("{{route.to}}");
}
}2.2.6. 自定义 Camel 上下文配置
如果要对 CamelContext bean 创建的 CamelContext bean 执行一些操作，请在 Spring 上下文中注册 CamelContextConfiguration 实例：
@Configuration
public class MyAppConfig {
@Bean
CamelContextConfiguration contextConfiguration() {
return new CamelContextConfiguration() {
@Override
void beforeApplicationStart(CamelContext context) {
// your custom configuration goes here
}
};
}
}
@Configuration
public class MyAppConfig {
@Bean
CamelContextConfiguration contextConfiguration() {
return new CamelContextConfiguration() {
@Override
void beforeApplicationStart(CamelContext context) {
// your custom configuration goes here
}
};
}
}
在启动 Spring 上下文 之前，才会调用ApplicationStart 的方法，因此传递给此回调的 CamelContext 实例会被完全自动配置。如果您在 Spring 上下文中添加多个 CamelContextConfiguration 实例，则每个实例都会被执行。
如需示例应用程序，请参阅 camel-spring-boot-examples 存储库中的 Metrics 示例。
2.2.7. 自动配置的消费者和制作者模板
Camel 自动配置提供预配置的 ConsumerTemplate 和 ProducerTemplate 实例。您可以简单地将它们注入到 Spring 管理的 Bean 中：
@Component
public class InvoiceProcessor {
@Autowired
private ProducerTemplate producerTemplate;
@Autowired
private ConsumerTemplate consumerTemplate;
public void processNextInvoice() {
Invoice invoice = consumerTemplate.receiveBody("jms:invoices", Invoice.class);
...
producerTemplate.sendBody("netty-http:http://invoicing.com/received/" + invoice.id());
}
}
@Component
public class InvoiceProcessor {
@Autowired
private ProducerTemplate producerTemplate;
@Autowired
private ConsumerTemplate consumerTemplate;
public void processNextInvoice() {
Invoice invoice = consumerTemplate.receiveBody("jms:invoices", Invoice.class);
...
producerTemplate.sendBody("netty-http:http://invoicing.com/received/" + invoice.id());
}
}默认情况下，消费者模板和制作者模板将端点缓存大小设置为 1000。您可以通过修改以下 Spring 属性来更改这些值：
camel.springboot.consumer-template-cache-size = 100 camel.springboot.producer-template-cache-size = 200
camel.springboot.consumer-template-cache-size = 100
camel.springboot.producer-template-cache-size = 2002.2.8. 自动配置的类型Converter
Camel 自动配置注册 Spring 上下文中名为 typeConverter 的 TypeConverter 实例。
@Component
public class InvoiceProcessor {
@Autowired
private TypeConverter typeConverter;
public long parseInvoiceValue(Invoice invoice) {
String invoiceValue = invoice.grossValue();
return typeConverter.convertTo(Long.class, invoiceValue);
}
}
@Component
public class InvoiceProcessor {
@Autowired
private TypeConverter typeConverter;
public long parseInvoiceValue(Invoice invoice) {
String invoiceValue = invoice.grossValue();
return typeConverter.convertTo(Long.class, invoiceValue);
}
}2.2.8.1. Spring 类型转换 API 网桥
Spring 附带强大的 类型转换 API。Spring API 与 Camel 类型转换器 API 类似。因为这两个 API 都类似，Camel Spring Boot 会自动注册一个网桥转换器(SpringTypeConverter)，其委托给 Spring conversion API。这意味着，开箱即用的 Camel 将对待 Spring Converters，如 Camel。使用此方法，您可以使用通过 Camel TypeConverter API 访问的 Camel 和 Spring 转换器：
@Component
public class InvoiceProcessor {
@Autowired
private TypeConverter typeConverter;
public UUID parseInvoiceId(Invoice invoice) {
// Using Spring's StringToUUIDConverter
UUID id = invoice.typeConverter.convertTo(UUID.class, invoice.getId());
}
}
@Component
public class InvoiceProcessor {
@Autowired
private TypeConverter typeConverter;
public UUID parseInvoiceId(Invoice invoice) {
// Using Spring's StringToUUIDConverter
UUID id = invoice.typeConverter.convertTo(UUID.class, invoice.getId());
}
}
在 hood Camel Spring Boot 下，将转换委派给应用程序上下文中提供的 Spring ConversionService 实例。如果没有 ConversionService 实例，则 Camel Spring Boot 自动配置会为您创建一个。
如需示例应用程序，请参阅 camel-spring-boot-examples 存储库中的 Type 转换示例。
2.2.9. 使应用程序保持活跃
启用了此功能的 Camel 应用程序在启动时会启动一个新线程，从而通过防止 JVM 终止来保持应用程序保持处于活动状态的唯一目的。这意味着，在使用 Spring Boot 启动 Camel 应用程序后，应用程序会等待 Ctrl+C 信号，且不会立即退出。
可以使用 camel.springboot.main-run-controller 作为 true 激活控制器线程。
camel.springboot.main-run-controller = true
camel.springboot.main-run-controller = true
使用 Web 模块（例如，导入 org.springframework.boot:spring-boot-web-starter 模块的应用程序）的应用程序通常不需要使用此功能，因为应用程序由其他非守护进程线程保留。
如需示例应用程序，请参阅 camel-spring-boot-examples 存储库中的 POJO 示例。
2.2.10. 添加 XML 路由
默认情况下，您可以将 Camel XML 路由放在目录 camel 下的 classpath 中，camel-spring-boot 将 auto-detect 和 include。您可以使用配置选项配置目录名称或关闭它：
turn off
# turn off
camel.springboot.routes-include-pattern = falsescan only in the com/foo/routes classpath
# scan only in the com/foo/routes classpath
camel.springboot.routes-include-pattern = classpath:com/foo/routes/*.xml
XML 文件应为 Camel XML 路由(而不是 < CamelContext>)，例如：
<routes xmlns="http://camel.apache.org/schema/spring">
<route id="test">
<from uri="timer://trigger"/>
<transform>
<simple>ref:myBean</simple>
</transform>
<to uri="log:out"/>
</route>
</routes>
<routes xmlns="http://camel.apache.org/schema/spring">
<route id="test">
<from uri="timer://trigger"/>
<transform>
<simple>ref:myBean</simple>
</transform>
<to uri="log:out"/>
</route>
</routes>有关示例应用程序，请参阅 camel-spring-boot-examples 存储库中的 XML 示例。
2.2.11. 测试 JUnit 5 方法
对于测试，Maven 用户需要将以下依赖项添加到其 pom.xml 中：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>3.4.5</version> <!-- Use the same version as your Spring Boot version -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-test-spring-junit5</artifactId>
<version>4.10.3.redhat-00020</version> <!-- use the same version as your Camel core version -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>3.4.5</version> <!-- Use the same version as your Spring Boot version -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-test-spring-junit5</artifactId>
<version>4.10.3.redhat-00020</version> <!-- use the same version as your Camel core version -->
<scope>test</scope>
</dependency>
要测试 Camel Spring Boot 应用程序，请使用 @CamelSpringBootTest 注解测试类。这会为应用程序提供 Camel 的 Spring Test 支持，以便您可以使用 Spring Boot 测试惯例编写测试。
要获取 CamelContext 或 ProducerTemplate，您可以使用 @Autowired 以普通的 Spring 方法将它们注入类。
您还可以使用 camel-test-spring-junit5 来配置测试。本例使用 @MockEndpoints 注释自动模拟端点：
@CamelSpringBootTest
@SpringBootApplication
@MockEndpoints("direct:end")
public class MyApplicationTest {
@Autowired
private ProducerTemplate template;
@EndpointInject("mock:direct:end")
private MockEndpoint mock;
@Test
public void testReceive() throws Exception {
mock.expectedBodiesReceived("Hello");
template.sendBody("direct:start", "Hello");
mock.assertIsSatisfied();
}
}
@CamelSpringBootTest
@SpringBootApplication
@MockEndpoints("direct:end")
public class MyApplicationTest {
@Autowired
private ProducerTemplate template;
@EndpointInject("mock:direct:end")
private MockEndpoint mock;
@Test
public void testReceive() throws Exception {
mock.expectedBodiesReceived("Hello");
template.sendBody("direct:start", "Hello");
mock.assertIsSatisfied();
}
}有关示例应用程序，请参阅 camel-spring-boot-examples 存储库中的 Infinispan 示例。
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}