如何在 Apache Camel 中对生产路线进行单元测试？

Question

假设我在单独的 RouteBuilder 类中创建了路线。它看起来像：

• 从 JMS 队列中获取消息，
• 进行一些转换、验证等
• 根据验证结果转发到特定的 JMS 队列，

，并将某些内容保存在数据库中。我想在没有 JMS 代理和数据库的情况下对该路由进行单元测试。我知道我可以模拟我的处理器实现，但这还不够。我不想更改这条路线（假设我在 jar 文件中得到了该类）。据我从《Camel in Action》（第 6.2.6 节）中了解到，为了能够使用端点的模拟和其他内容，我需要更改我的路由端点定义（在本书的示例中，这是“mina:tcp:/”的更改） /米兰达”到“模拟：米兰达”等）。

是否可以在不更改路由定义的情况下完全隔离地测试流？ 如果我将 RouteBuilder 作为一个单独的类，我是否被迫以某种方式“复制”路由定义并手动更改它？是不是测试错了？

我对 Camel 很陌生，对我来说，能够在开发路线时进行独立的单元测试真的很酷。只是为了能够改变一些东西，进行小测试，观察结果等等。

Answer 1

假设 RouteBuilder 类具有硬编码端点，那么测试起来会有点困难。但是，如果 RouteBuilder 使用端点 uri 的属性占位符，那么您通常可以使用一组不同的端点 uri 进行单元测试。正如 Camel 书第 6 章所解释的那样。

如果它们是硬编码的，那么您可以在单元测试中使用带有功能的建议，如下所示： https://camel.apache.org/components/latest/others/test-cdi.html#CDITesting-RoutesadvisingwithadviceWith

在 Camel 2.7 中，我们使操作路线变得更加容易，这样你就可以移除零件，更换零件等。这就是链接谈到的编织内容。

例如，要模拟向数据库端点发送消息，您可以使用上面的方法，并将 to 替换为另一个将其发送到模拟的端点。

在以前的版本中，您可以使用interceptSendToEndpoint技巧，这在Camel书中也有介绍（第6.3.3节）

哦，您也可以用模拟组件替换组件，如第169页所示。现在在Camel 2.8中，模拟组件将不再抱怨它不知道的 uri 参数。这意味着在每个组件级别上用模拟替换组件要容易得多。

Answer 2

我

   <bean id="properties" class="org.apache.camel.component.properties.PropertiesComponent">
        <property name="location" value="classpath:shop.properties"/>
    </bean>

    <route>
        <from uri="direct://stock"/>
        <to uri="{{stock.out}}"/>
    </route>

在我的 spring 文件中，然后在测试类路径上的 shop.properties 中，我有一个 stock.out=xxxx ，它在运行时被替换，所以我可以有不同的路线，一个用于运行时，一个用于测试，

有一个更好的例子6.1.6 多环境下的单元测试

Answer 3

虽然您可以按照克劳斯·易卜生 (Claus Ibsen) 的说法使用拦截和建议来交换端点
答案，我认为允许您的路线接受 Endpoint 会更好
实例，以便您的测试不会耦合到生产端点 URI。

例如，假设您有一个看起来像这样的 RouteBuilder

public class MyRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("http://someapi/someresource")
        .process(exchange -> {
            // Do stuff with exchange
        })
        .to("activemq:somequeue");
    }
}

您可以像这样注入端点：

public class MyRoute extends RouteBuilder {
    private Endpoint in;
    private Endpoint out;

    // This is the constructor your production code can call
    public MyRoute(CamelContext context) {
        this.in = context.getEndpoint("http://someapi/someresource");
        this.out = context.getEndpoint("activemq:somequeue");
    }

    // This is the constructor your test can call, although it would be fine
    // to use in production too
    public MyRoute(Endpoint in, Endpoint out) {
        this.in = in;
        this.out = out;
    }

    @Override
    public void configure() throws Exception {
        from(this.in)
        .process(exchange -> {
            // Do stuff with exchange
        })
        .to(this.out);
    }
}

然后可以像这样进行测试：

public class MyRouteTest {
    private Endpoint in;
    private MockEndpoint out;
    private ProducerTemplate producer;

    @Before
    public void setup() {
        CamelContext context = new DefaultCamelContext();

        this.in = context.getEndpoint("direct:in");
        this.out = context.getEndpoint("mock:direct:out", MockEndpoint.class);
        this.producer = context.createProducerTemplate();
        this.producer.setDefaultEndpoint(this.in);

        RouteBuilder myRoute = new MyRoute(this.in, this.out);
        context.addRoutes(myRoute);

        context.start();
    }

    @Test
    public void test() throws Exception {
        this.producer.sendBody("Hello, world!");
        this.out.expectedMessageCount(1);
        this.out.assertIsSatisfied();
    }
} 

这具有以下优点：

• 您的测试非常简单并且易于理解，甚至不需要扩展 CamelTestSupport 或其他辅助类，
• CamelContext 是手动创建的，因此您可以确保只创建被测试的路由
• 测试不关心生产路由 URI
• 如果需要，您仍然可以方便地将端点 URI 硬编码到路由类中

Answer 4

1. 如果您使用 Spring（这主要是一个好主意），我想
   分享我的方法。

   你的生产路线是一个具有特殊类别的 Spring bean
   我的路线

   <前><代码>@Component
   公共类 MyRoute 扩展 RouteBuilder {

   公共静态最终字符串IN =“jms://inqueue”;

   @覆盖
   公共无效配置（）抛出异常{
   来自(IN)
   .process(交换->{
   // 通过交换做一些事情
   })
   .to("activemq:somequeue");
   }
   }

   所以在测试中你可以像这样轻松地覆盖它（这是一个
   spring java config内部（到测试类）类）：

   静态类 TestConfig 扩展 IntegrationTestConfig {
   
           @豆
           公共我的路线我的路线（）{
               返回新的 MyRoute() {
                   @覆盖
                   公共无效配置（）抛出异常{
                       拦截（MyRoute.IN）
                               。选择（） 
   
                                   .when(x -> delayThisMessagePredicate.matches(x)) //使谓词在测试之间可修改
                                   .to("日志：延迟")
                                   .延迟(5000)
                               .endChoice();
                       超级配置（）；
                   }
               };
           }
   }
   

   注意 super.configure() 安装你的生产路线，你可以
   使用interceptFrom、interceptSendToEndpoint注入测试代码：eg
   引发异常。

   我还添加了一些辅助路线。通过这条路线，我可以测试文件是否具有
   已在输出文件夹中生成，它可能是 JMS 消费者...

   <前><代码>@Bean
   公共 RouteBuilder createOutputRoute() {

   返回新的 RouteBuilder() {
   @覆盖
   公共无效配置（）{

   来自F(FILE_IN,
   输出目录)
   .to("模拟：输出")
   .routeId("完成路由");
   };

2. 对于 JMS/JDBC/... 还有 Mockrunner。使用测试配置中的以下代码，您几乎完成了：您的 JMS 连接工厂已被模拟实现替换，因此现在您甚至可以将某些内容放入 JMS 并从 jms 读取（使用如上所述的简单骆驼路由）进行验证。不要忘记在模拟上创建一个队列。

   @Bean(JMS_MOCK_CONNECTION_FACTORY)
   @基本的
   公共 ConnectionFactory jmsConnectionFactory() {
   return (new JMSMockObjectFactory()).getMockQueueConnectionFactory();
   }

3. 我不喜欢AdviseWith，是的，它很灵活，但是它要求你在测试中手动处理camelContext，这对我来说太具有侵入性。我不想将该代码放入数百个测试中，我也不想围绕它创建一个框架。另外，子类化 CamelTestSupport 也可能是一个问题，例如，如果您使用两个库，这两个库都要求您子类化某些内容，并且您可能有自己的测试类层次结构，但您看不到 CamelTestSupport。我尽量不在测试中使用类层次结构，以使测试保持独立。子类化意味着，您需要一些魔法才能发生（您在测试中不会直接看到该代码）。如果你修改那个魔法，就会影响很多测试。我为此使用 spring java 配置集。