Spring Boot 和 Apache Camel

位置:首页>文章>详情   分类: Java教程 > 编程技术   阅读(98)   2024-04-22 16:20:59

随着软件世界的发展,正在开发更复杂的系统,这些系统必须相互集成。它从 SOA 开始,然后继续使用微服务。

Camel 是我想到的第一个集成工具,因为现在 spring boot 和 camel 是一个非常强大的组合。

第一步是将 camel 依赖项包含到我们的 spring 项目中。

buildscript {
	ext {
		springBootVersion = '1.5.9.BUILD-SNAPSHOT'
	}
	repositories {
		mavenCentral()
		maven { url "https://repo.spring.io/snapshot" }
		maven { url "https://repo.spring.io/milestone" }
	}
	dependencies {
		classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")
	}
}

apply plugin: 'java'
apply plugin: 'eclipse'
apply plugin: 'org.springframework.boot'

group = 'com.gkatzioura'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = 1.8

repositories {
	mavenCentral()
	maven { url "https://repo.spring.io/snapshot" }
	maven { url "https://repo.spring.io/milestone" }
}


dependencies {
	compile('org.apache.camel:camel-spring-boot-starter:2.20.0')
	testCompile('org.springframework.boot:spring-boot-starter-test')
    testCompile('org.apache.camel:camel-test-spring:2.20.0')
}

为了从头开始更快地设置项目,您始终可以使用在线 spring initializer。

现在让我们添加一个简单的路由

package com.gkatzioura.springcamel.routes;

import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;

@Component
public class TimerRoute extends RouteBuilder {

    public static final String ROUTE_NAME = "TIMER_ROUTE";

    @Override
    public void configure() throws Exception {
        from("timer:initial//start?period=10000")
                .routeId(ROUTE_NAME)
                .to("log:executed");
    }
}

我们不必担心 camel 上下文配置,因为 Camel 自动配置会为您创建一个 SpringCamelContext 并负责正确初始化和关闭该上下文。

camel 自动配置还从 Spring 上下文中收集所有 RouteBuilder 实例,并自动将它们注入到提供的 CamelContext 中。因此我们不必将我们的路由注册到 CamelContext。

如您所见,我们的路由有一个周期为 10000 毫秒的定时器,它路由到一个日志端点。日志端点将每 10000 毫秒打印一次执行的字符串。

请记住,如果没有指定 routeId,camel 将自己分配一个名称,因此为我们的路由定义命名是一个很好的做法,以防我们想要检索根定义。

为了让骆驼熬夜,我们需要让我们的主线程保持阻塞状态。因此,我们将此配置添加到我们的 application.yml 文件中。

camel:
  springboot:
    main-run-controller: true

取而代之的是,我们可以包含 spring-boot-starter-web 依赖项,但我们的应用程序具有尽可能少的依赖项,我们需要保持这种方式。

然而,与其他系统集成中最困难的部分是测试。多年来,测试和我们使用的工具取得了快速进步。 Camel 还打包了一些很棒的工具来进行单元测试。

例如,我们将对先前指定的路由进行测试。

@RunWith(CamelSpringBootRunner.class)
@SpringBootTest
public class SpringCamelApplicationTests {

    @EndpointInject(uri = MOCK_RESULT)
    private MockEndpoint resultEndpoint;

    @Autowired
    private CamelContext camelContext;

    @EndpointInject(uri = MOCK_TIMER)
    private ProducerTemplate producer;

    private static final String MOCK_RESULT = "mock:result";
    private static final String MOCK_TIMER = "direct:mock-timer";

    @Before
	public void setup() throws Exception {

	    camelContext.getRouteDefinition(TimerRoute.ROUTE_NAME)
                .autoStartup(true)
                .adviceWith(camelContext, new AdviceWithRouteBuilder() {
                    @Override
                    public void configure() throws Exception {
                        replaceFromWith(MOCK_TIMER);
                        interceptSendToEndpoint("log*")
                                .skipSendToOriginalEndpoint()
                                .to(MOCK_RESULT);
                    }
                });
    }

    @Test
    public void sendMessage() throws Exception {

        resultEndpoint.expectedMessageCount(1);
        producer.sendBody("A message");
        resultEndpoint.assertIsSatisfied();
    }

}

让我们来看看测试的每个部分。

我们选择的 JUnit 运行程序是 CamelSpringBootRunner.class

@RunWith(CamelSpringBootRunner.class)

我们注入一个 ProducerTemplate。 ProducerTemplate 接口允许您以各种不同的方式将消息交换发送到端点,以便从 Java 代码轻松使用 Camel Endpoint 实例。

然后我们注入一个 MockEndpoint。 MockEndpoint 将通过替换原始端点来为我们服务。然后我们将设置要接收的消息的预期数量。处理完成后,我们断言接收到的消息数量已满足。

在我们的设置方法中,我们将用伪造的生产者模板端点替换我们的原始端点。因此,我们的路线将接收我们将从 ProducerTemplate 发出的事件。然后我们也将拦截日志端点并将消息定向到之前指定的 MockEndpoint。

所以我们最终得到了一个 camel 应用程序和一个指定路由的单元测试。您可以在 github 上找到源代码。

标签2: Java教程
地址:https://www.cundage.com/article/jcg-spring-boot-apache-camel.html

相关阅读

Java HashSet 教程展示了如何使用 Java HashSet 集合。 Java哈希集 HashSet 是一个不包含重复元素的集合。此类为基本操作(添加、删除、包含和大小)提供恒定时间性...
SpringApplicationBuilder 教程展示了如何使用 SpringApplicationBuilder 创建一个简单的 Spring Boot 应用程序。 春天 是用于创建企业应...
通道是继 buffers 之后 java.nio 的第二个主要新增内容,我们在之前的教程中已经详细了解了这一点。通道提供与 I/O 服务的直接连接。 通道是一种在字节缓冲区和通道另一端的实体(通...
课程大纲 Elasticsearch 是一个基于 Lucene 的搜索引擎。它提供了一个分布式的、支持多租户的全文搜索引擎,带有 HTTP Web 界面和无模式的 JSON 文档。 Elasti...
解析器是强大的工具,使用 ANTLR 可以编写可用于多种不同语言的各种解析器。 在这个完整的教程中,我们将: 解释基础:什么是解析器,它可以用来做什么 查看如何设置 ANTLR 以便在 Java...
Java 是用于开发各种桌面应用程序、Web 应用程序和移动应用程序的最流行的编程语言之一。以下文章将帮助您快速熟悉 Java 语言,并迈向 API 和云开发等更复杂的概念。 1. Java语言...
Java中的继承是指子类继承或获取父类的所有非私有属性和行为的能力。继承是面向对象编程的四大支柱之一,用于提高层次结构中类之间的代码可重用性。 在本教程中,我们将了解 Java 支持的继承类型,...
Java Message Service 是一种支持正式通信的 API,称为 网络上计算机之间的消息传递。 JMS 为支持 Java 程序的标准消息协议和消息服务提供了一个通用接口。 JMS 提...
Java 项目中的一项常见任务是将日期格式化或解析为字符串,反之亦然。解析日期意味着你有一个代表日期的字符串,例如“2017-08-3”,你想把它转换成一个代表 Java 中日期的对象,例如Ja...
之前,我介绍了spring 3 + hibernate 集成 示例和struts 2 hello world 示例。在本教程中,我将讨论在将 spring 框架与 struts 与 hibern...