1. 概述
Apache Camel是一个强大的开源集成框架，实现了几个已知的企业集成模式。
通常在使用Camel处理消息路由时，我们需要一种方法来根据消息的内容以不同的方式处理消息。为此，Camel提供了一个强大的功能，称为EIP模式集合中的基于内容的路由器。
在本教程中，我们将介绍根据某些条件路由消息的几种方法。
2. 依赖项
我们首先需要的是将camel-spring-boot-starter添加到我们的pom.xml中：
<dependency>
<groupId>org.apache.camel.springboot</groupId>
<artifactId>camel-spring-boot-starter</artifactId>
<version>3.18.1</version>
</dependency>
然后，我们需要将camel-test-spring-junit5依赖项添加到我们的pom.xml中：
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-test-spring-junit5</artifactId>
<version>3.18.1</version>
</dependency>
顾名思义，此依赖项专门用于我们的单元测试。
3. 定义一个简单的Camel Spring Boot应用程序
在本教程中，我们示例的重点将是一个简单的Apache Camel Spring Boot应用程序。
因此，让我们从定义应用程序入口点开始：
@SpringBootApplication
public class ConditionalRoutingSpringApplication {
public static void main(String[] args) {
SpringApplication.run(ConditionalRoutingSpringApplication.class, args);
}
}
正如我们所见，这是一个标准的Spring Boot应用程序。
4. 条件路由
快速回顾一下，Apache Camel中的路由是一个基本构建块，通常由一系列步骤组成，由Camel按顺序执行，用于消费和处理消息。
例如，路由通常会使用可能来自磁盘上的文件或消息队列的消费者接收消息。然后，Camel执行路由中的其余步骤，这些步骤要么以某种方式处理消息，要么将其发送到其他端点。
毫无疑问，我们需要一种方法来根据某些事实有条件地路由消息。为此，Camel提供了choice和when构建块。我们可以认为这相当于Java中的if-else语句。
考虑到这一点，让我们继续使用一些条件逻辑创建我们的第一个路由。
5. 创建路由
在此示例中，我们将根据收到的消息正文的内容定义一个具有一些条件逻辑的基本路由：
@Component
public class ConditionalBodyRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("direct:start-conditional")
.routeId("conditional-body-route")
.choice()
.when(body().contains("Tuyucheng"))
.setBody(simple("Goodbye, Tuyucheng!"))
.to("mock:result-body")
.otherwise()
.to("mock:result-body")
.end();
}
}
正如我们在简单示例中所见，我们将路由配置为使用来自名为start-conditional的直接端点的消息。
现在让我们来看看路由的关键部分：
- 首先，我们使用choice()方法开始路由-这告诉Camel以下几行将包含一些要评估的条件
- 接下来，when()方法指示要评估的新条件-在此示例中，我们只是检查消息正文是否包含字符串”Tuyucheng“。我们可以根据需要添加任意数量的when条件
- 为了概括我们的路由，我们使用otherwise()方法来定义当前面的条件都不满足时要做什么
- 最后，路由使用end()方法终止，该方法关闭choice块
总而言之，当我们运行路由时，如果我们的消息正文包含字符串“Tuyucheng”，我们将消息正文设置为“Goodbye, Tuyucheng!”并将结果发送到名为result-body的mock端点。
或者，我们只是将原始消息路由到mock端点。
6. 测试路由
考虑到最后一部分，让我们继续编写一个单元测试来探索我们的路由的行为方式：
@SpringBootTest
@CamelSpringBootTest
class ConditionalBodyRouterUnitTest {
@Autowired
private ProducerTemplate template;
@EndpointInject("mock:result-body")
private MockEndpoint mock;
@Test
void whenSendBodyWithTuyucheng_thenGoodbyeMessageReceivedSuccessfully() throws InterruptedException {
mock.expectedBodiesReceived("Goodbye, Tuyucheng!");
template.sendBody("direct:start-conditional", "Hello Tuyucheng Readers!");
mock.assertIsSatisfied();
}
}
正如我们所见，我们的测试包括三个简单的步骤：
- 首先，我们设置一个预期，即我们的mock端点将收到给定的消息正文
- 然后我们将使用模板向direct:start-conditional端点发送一条消息。请注意，我们将确保我们的消息正文包含字符串”Tuyucheng“
- 为了结束我们的测试，我们使用assertIsSatisfied方法来验证我们对mock端点的初始期望是否已得到满足
此测试确认我们的条件路由正常工作。
请务必查看我们之前的教程，以了解有关如何为我们的Camel路由编写可靠、独立的单元测试的更多信息。
7. 构建其他条件谓词
到目前为止，我们已经探索了一种关于如何构建我们的when谓词的选项-检查我们交换的消息正文。但是，我们还有其他几种选择。
例如，我们还可以通过检查给定消息头的值来控制我们的条件：
@Component
public class ConditionalHeaderRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("direct:start-conditional-header")
.routeId("conditional-header-route")
.choice()
.when(header("fruit").isEqualTo("Apple"))
.setHeader("favourite", simple("Apples"))
.to("mock:result")
.otherwise()
.setHeader("favourite", header("fruit"))
.to("mock:result")
.end();
}
}
这一次，我们修改了when方法来查看名为fruit的标头的值。也完全可以在我们的when条件中使用Camel提供的SIMPLE语言。
8. 使用Java Bean
此外，当我们想在谓词中使用Java方法调用的结果时，我们也可以使用CamelBean语言。
首先，我们需要创建一个包含返回boolean值的方法的Java bean：
public class FruitBean {
public static boolean isApple(Exchange exchange) {
return "Apple".equals(exchange.getIn().getHeader("fruit"));
}
}
在这里，我们还可以选择将Exchange添加为参数，以便Camel自动将Exchange传递给我们的方法。
然后我们可以继续从when块中使用Fruit Bean：
@Component
public class ConditionalBeanRouter extends RouteBuilder {
@Override
public void configure() throws Exception {
from("direct:start-conditional-bean")
.routeId("conditional-bean-route")
.choice()
.when(method(FruitBean.class, "isApple"))
.setHeader("favourite", simple("Apples"))
.to("mock:result")
.otherwise()
.setHeader("favourite", header("fruit"))
.to("mock:result")
.endChoice()
.end();
}
}
9. 总结
在本文中，我们了解了如何根据路由中的某种条件路由消息。首先，我们创建了一个简单的Camel应用程序，其中包含一个检查消息正文的路由。
然后我们学习了其他几种使用消息头和Java bean在我们的路由中构建谓词的技术。
与往常一样，本教程的完整源代码可在GitHub上获得。
Post Directory
