如何在骆驼测试中模拟 AMQP 消费者？

Question

假设我有以下路线：

from(rabbitMQUri)
    .to(myCustomerProcessor)
    .choice()
        .when(shouldGotoA)
            .to(fizz)
        .when(shouldGotoB)
            .to(buzz)
        .otherwise()
            .to(foo);

让我们假设myCustomProcessor根据从RabbitMQ消费的消息调整shouldGotoA和shouldGotoB。

我想对 3 个场景进行单元测试：

1. 一条“fizz”消息被消费，shouldGotoA 设置为 true，执行第一个 when(...)。
2. 一条“buzz”消息被消费，shouldGotoB 设置为 true，执行第二个 when(...)。
3. 一条“foo”消息被消费，otherwise() 被执行。

我的问题是：我如何模拟/存根 RabbitMQ 端点，以便路由在生产中正常执行，但这样我就不必实际将测试连接到 RabbitMQ 服务器？我需要某种“模拟消息”生产者。

代码示例或 sn-p 会非常有帮助，非常感谢！

Answer 1

使软件（尤其是与外部事物通信的软件）更好地可测试的一个好方法是使用依赖注入。我爱Guice，它是directly supported by camel。 （所有这些东西都会让你学习依赖注入，但我可以向你保证很快就会付出代价）

在这种情况下，您只需注入“端点”。您可以像这样预先配置端点（将放置在“模块”中）。

@Provides
@Named("FileEndpoint")
private Endpoint fromFileEndpoint() {
    FileEndpoint fileEndpoint = getContext().getEndpoint("file:" + somFolder, FileEndpoint.class);
    fileEndpoint.setMove(".done");
    fileEndpoint.setRecursive(true);
    fileEndpoint.setDoneFileName(FtpRoutes.DONE_FILE_NAME);
    ...
    return fileEndpoint;
}

您的 RouteBuilder 只需注入端点：

@Inject
private MyRoutes(@Named("FileEndpoint") final Endpoint fileEndpoint) {
    this.fileEndpoint = fileEndpoint;
}
@Override
public void configure() throws Exception {
    from(fileEndpoint)....
}

要轻松测试这样的路由，您需要注入另一个端点进行测试，而不是 FileEndpoint，而是“direct:something”。一个非常简单的方法是"Jukito"，它结合了Guice 和Mockito。测试看起来像这样：

@RunWith(JukitoRunner.class)
public class OcsFtpTest extends CamelTestSupport {

    public static class TestModule extends JukitoModule {
        @Override
        protected void configureTest() {
            bind(CamelContext.class).to(DefaultCamelContext.class).in(TestSingleton.class);
        }
        @Provides
        @Named("FileEndpoint")
        private Endpoint testEndpoint() {
            DirectEndpoint fileEndpoint = getContext().getEndpoint("direct:a", DirectEndpoint.class);
        return fileEndpoint;
        }
    }
    @Inject
    private MyRoutes testObject;

   @Test
   ....
}

现在“testObject”将获得直接端点而不是文件端点。这适用于所有类型的端点，通常适用于所有严重依赖接口的接口/抽象类和 API（骆驼在这里表现出色！）。

Answer 2

这是组合合适测试的一种方法。

首先定义一个空的 Camel Context，其中只有一个 ProducerTemplate：

<camel:camelContext id="camelContext">
   <camel:template id="producerTemplate" />
</camel:camelContext>

这样做是为了在执行测试时，我可以控制实际启动哪些路由，因为我不希望所有路由在测试期间启动。

现在在测试类本身中，您需要对生产者模板和 Camel 上下文的引用。就我而言，我使用的是 Spring，我将它们自动连接到：

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:/spring/spring-test-camel.xml" })
public class MyTest {

    @Autowired
    private ProducerTemplate producerTemplate;

    @Autowired
    private CamelContext camelContext;

在测试本身中，将上下文中的 RabbitMQ/ActiveMQ/JMS 组件替换为 seda 或直接组件。例如，用 seda 队列替换所有 JMS 调用。

camelContext.removeComponent("jms");
camelContext.addComponent("jms", this.camelContext.getComponent("seda"));
camelContext.addRoutes(this.documentBatchRouting);

现在，每当您读取或写入 JMS URI 时，它实际上都会进入 seda 队列。这类似于向组件中注入一个新的 URI，但需要较少的配置，并且允许您向路由添加新的端点，而不必担心记住注入所有的 URI。

最后在测试中，使用生产者模板发送测试消息：

producerTemplate.sendBody("jms:MyQueue", 2);

然后你的路线应该执行，你可以测试你的期望。

有两点需要注意：

1. 您的事务边界可能会发生变化，尤其是当您将 JMS 队列替换为直接组件时

2. 如果您正在测试多条路线，则必须小心在该路线的测试结束时从 Camel 上下文中删除该路线。

Answer 3

这可能取决于您使用什么组件（AMQP 或 RabbitMQ）进行通信。

Camel 中示例代码的一个最重要的资源是源代码中的 junit 测试用例。

这两个文件与您需要的功能相似，但您可能希望在测试用例中四处查看以获取灵感： AMQPRouteTest.java RabbitMQConsumerIntTest.java

使路由可测试的一种更“基本”的方法是使“来自”uri 成为参数。 假设您将 RouteBuilder 设为如下所示：

   private String fromURI = "amqp:/..";

   public void setFromURI(String fromURI){
     this.fromURI = fromURI;
   }

   public void configure(){
     from(fromURI).whatever();
   }

然后，您可以在开始单元测试之前在 fromURI 中注入“seda:foobar”端点。 seda 端点是 trivial to test。这假设您不需要测试 AMQP/RabbitMQ 特定的构造，而只需接收有效负载。