如何在不使用XML的情况下将Camel与Spring集成

嘿，我之前也从《Camel in Action（第二版）》里学过XML配置方式，后来转用无XML的方式集成Camel和Spring，其实现在主流的方案都是基于Java配置的，不管是Spring Boot还是纯Spring项目都很方便，给你梳理几种常用的实现方式：

Spring Boot和Camel的集成是最省心的，官方提供的starter会自动完成大部分配置工作：

• 引入依赖：在你的pom.xml（Maven）或build.gradle（Gradle）里添加spring-boot-starter-camel依赖，它会自动引入Camel核心、Spring集成相关的包，以及自动配置类。
• 定义路由：创建一个类继承RouteBuilder，并用@Component标注，Spring会自动把它注册到Camel上下文中：

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

@Component
public class SampleCamelRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // 示例路由：每隔1秒打印一次日志
        from("timer:hello?period=1000")
          .log("Hello from Camel + Spring Boot (no XML!)");
    }
}

• 自动发现组件：只要你的自定义组件是Spring管理的Bean（比如用@Component、@Service标注），Camel会自动识别并注册这些组件，直接在路由里使用组件的URI即可：

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

// 自定义组件，标注@Component并指定组件名称
@Component("myCustomComponent")
public class MyCustomComponent implements Component {
    // 实现组件的核心逻辑（比如创建Endpoint等）
}

之后在路由里就可以直接用from("myCustomComponent:myEndpoint")来引用这个组件。

如果你的项目不是Spring Boot，而是纯Spring应用，可以通过Java Config手动配置Camel上下文：

• 引入依赖：添加camel-spring依赖，确保Spring核心包也已引入。
• 创建Spring配置类：手动初始化SpringCamelContext，并注册路由和组件：

import org.apache.camel.CamelContext;
import org.apache.camel.spring.SpringCamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class CamelSpringJavaConfig {

    @Bean
    public CamelContext camelContext() throws Exception {
        SpringCamelContext camelContext = new SpringCamelContext();
        // 添加自定义路由
        camelContext.addRoutes(sampleRoute());
        // 启动Camel上下文
        camelContext.start();
        return camelContext;
    }

    @Bean
    public RouteBuilder sampleRoute() {
        return new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                // 示例路由：从input文件夹读取文件，输出到output文件夹
                from("file:src/main/resources/input")
                  .to("file:src/main/resources/output");
            }
        };
    }

    // 自定义组件Bean，Camel会自动从Spring上下文获取
    @Bean("myCustomComponent")
    public Component myCustomComponent() {
        return new MyCustomComponent();
    }
}

除了路由定义，还可以用Spring注解来简化Camel组件的使用：

• 注入ProducerTemplate：可以直接用@Autowired注入，用来发送消息到Camel端点：

import org.apache.camel.ProducerTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class CamelMessageService {
    @Autowired
    private ProducerTemplate producerTemplate;

    public void sendMessage(String content) {
        producerTemplate.sendBody("file:output", content);
    }
}

• 注入特定端点：用@EndpointInject注解直接注入指定URI的端点：

import org.apache.camel.Endpoint;
import org.apache.camel.ProducerTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class CamelEndpointService {
    @Autowired
    private ProducerTemplate producerTemplate;

    @Autowired
    @EndpointInject(uri = "file:output")
    private Endpoint outputEndpoint;

    public void sendToOutput(String content) {
        producerTemplate.sendBody(outputEndpoint, content);
    }
}

内容的提问来源于stack exchange，提问作者Tuomas Toivonen