如何在Camel 4/Spring 3/Spring Boot 6中使用CachingConnectionFactory

问题根源 #

Camel 4调整了组件配置的类型转换逻辑，不再支持直接通过字符串类名实例化ConnectionFactory，必须通过Spring Bean注入的方式使用。

解决方案 #

方案1：复用Spring自动装配的连接工厂 #

Spring AMQP会根据application.properties/application.yaml中spring.rabbitmq.*的配置，自动创建CachingConnectionFactory类型的Bean，只需让Camel引用这个Bean即可：

在配置文件中添加：

# 你的RabbitMQ基础配置
spring.rabbitmq.host=你的主机地址
spring.rabbitmq.port=5672
spring.rabbitmq.username=你的用户名
spring.rabbitmq.password=你的密码

# Camel引用Spring自动生成的connectionFactory Bean
camel.component.spring-rabbitmq.connection-factory=#connectionFactory

方案2：手动定义可绑定配置的Bean（适用于自定义扩展） #

如果需要自定义CachingConnectionFactory的额外属性（比如连接缓存大小），可以手动定义Bean并绑定Spring配置：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    @Bean
    @ConfigurationProperties(prefix = "spring.rabbitmq")
    public ConnectionFactory connectionFactory() {
        return new CachingConnectionFactory();
    }
}

同样在Camel配置中引用该Bean：

camel.component.spring-rabbitmq.connection-factory=#connectionFactory

关键说明 #

• Camel 4中引用Spring Bean时，需在Bean名称前添加#，明确告知Camel这是Bean引用而非普通字符串。
• @ConfigurationProperties(prefix = "spring.rabbitmq")注解会自动将配置文件中spring.rabbitmq.*的参数绑定到CachingConnectionFactory实例，无需手动设置主机、账号等属性。

内容的提问来源于stack exchange，提问作者serv-inc