Apache Camel 路由在 Spring Boot 中的测试

Kahen大约 5 分钟

Apache Camel 路由在 Spring Boot 中的测试

Apache Camel 是一个强大的开源集成框架，实现了一些众所周知的企业集成模式。

在本教程中，我们将学习如何为我们的 Camel 路由编写可靠、自包含的单元测试。

首先，我们将创建一个使用 Spring Boot 的基本 Camel 应用程序。然后，我们将看看如何使用 Camel 的 Spring 测试支持 API 和 JUnit 5 来测试我们的应用程序。

2. 依赖项

假设我们的项目已经设置并配置为与 Spring Boot 和 Camel 一起工作。

然后，我们需要在我们的 pom.xml 中添加 camel-test-spring-junit5 依赖项：

`<dependency>`
    `<groupId>`org.apache.camel`</groupId>`
    `<artifactId>`camel-test-spring-junit5`</artifactId>`
    `<version>`4.3.0`</version>`
    `<scope>`test`</scope>`
`</dependency>`

顾名思义，这个依赖项专门用于我们的单元测试。

3. 定义一个简单的 Camel Spring Boot 应用程序

在整个教程中，我们的测试重点将是一个简单的 Apache Camel Spring Boot 应用程序。

所以让我们从定义我们的应用程序入口点开始：

@SpringBootApplication
public class GreetingsFileSpringApplication {

    public static void main(String[] args) {
        SpringApplication.run(GreetingsFileSpringApplication.class, args);
    }
}

正如我们所看到的，这是一个标准的 Spring Boot 应用程序。

3.1 创建路由

接下来，我们将定义一个相当基础的路由：

@Component
public class GreetingsFileRouter extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        from("direct:start")
          .routeId("greetings-route")
          .setBody(constant("Hello Baeldung Readers!"))
          .to("file:output");
    }
}

快速回顾一下，Apache Camel 中的路由是一个基本构建块，通常由 Camel 按顺序执行的一系列步骤组成，用于消费和处理消息。

正如我们简单示例中所看到的，我们配置我们的路由从称为 start 的直接端点消费消息。

然后，我们将消息体设置为包含字符串 Hello Baeldung Readers! 并使用文件组件将我们的消息交换内容写入名为 output 的文件目录。

我们还为我们的路由设置了一个名为 greetings-route 的 ID。在路由中使用 ID 通常被认为是一种良好的实践，可以帮助我们在测试路由时。

3.2 运行我们的应用程序

在本节的最后，如果我们运行我们的应用程序并向我们的直接消费者端点发送消息，我们应该会看到我们的问候文本在我们的输出目录中的一个文件里。如果我们没有指定文件名，Camel 将为我们创建一个：

$ cat output/D97099B6B2958D2-0000000000000000
Hello Baeldung Readers!

4. 关于测试的说明

通常，在编写清晰的测试时，我们不应该依赖我们可能无法控制或可能突然停止工作的外部服务或文件系统。这可能对我们的测试结果产生不利影响。

我们也不想为我们的单元测试特别编写代码。幸运的是，Camel 有一套专门用于测试的扩展和 API。所以我们可以将这看作是一种测试工具包。

这个工具包通过发送消息到路由并检查消息是否按预期接收，使测试我们的 Camel 应用程序变得更容易。

**5. 使用 @MockEndpoints 进行测试**

考虑到上一节的内容，让我们继续编写我们的第一个单元测试：

@SpringBootTest
@CamelSpringBootTest
@MockEndpoints("file:output")
class GreetingsFileRouterUnitTest {

    @Autowired
    private ProducerTemplate template;

    @EndpointInject("mock:file:output")
    private MockEndpoint mock;

    @Test
    void whenSendBody_thenGreetingReceivedSuccessfully() throws InterruptedException {
        mock.expectedBodiesReceived("Hello Baeldung Readers!");
        template.sendBody("direct:start", null);
        mock.assertIsSatisfied();
    }
}

让我们浏览一下我们测试的关键部分。

首先，我们通过三个注解来装饰我们的测试类：