如何在Red Hat中间件中通过camel-context.xml配置RabbitMQ JMS

我来帮你解决这个问题——你遇到的核心问题是混淆了RabbitMQ原生连接工厂和JMS规范的连接工厂，而且没正确在Spring上下文里注册符合要求的javax.jms.ConnectionFactory Bean。下面是一步步的完整解决方案：

首先确保你的Maven pom.xml 包含以下必要依赖（如果用Gradle可以对应转换）：

<dependencies>
    <!-- Spring Boot基础依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-- Camel Spring Boot整合 -->
    <dependency>
        <groupId>org.apache.camel.springboot</groupId>
        <artifactId>camel-spring-boot-starter</artifactId>
        <version>3.20.2</version> <!-- 选择和你的CodeReady Studio兼容的版本 -->
    </dependency>
    <!-- Camel JMS组件 -->
    <dependency>
        <groupId>org.apache.camel.springboot</groupId>
        <artifactId>camel-jms-starter</artifactId>
        <version>3.20.2</version>
    </dependency>
    <!-- RabbitMQ JMS客户端（提供符合JMS规范的连接工厂） -->
    <dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>rabbitmq-jms-client</artifactId>
        <version>2.0.0</version>
    </dependency>
</dependencies>

创建一个Spring配置类，专门注册javax.jms.ConnectionFactory类型的Bean——这里必须用RabbitMQ官方提供的RMQConnectionFactory（它实现了JMS规范的ConnectionFactory接口，而你之前用的com.rabbitmq.client.ConnectionFactory是RabbitMQ原生客户端的，和JMS规范不兼容）：

import com.rabbitmq.jms.admin.RMQConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.jms.ConnectionFactory;

@Configuration
public class JmsConfig {

    @Bean(name = "myConnectionFactory")
    public ConnectionFactory jmsConnectionFactory() {
        RMQConnectionFactory connectionFactory = new RMQConnectionFactory();
        // 配置你的本地RabbitMQ信息
        connectionFactory.setHost("localhost");
        connectionFactory.setPort(5672);
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        // 如果需要虚拟主机，添加下面一行
        // connectionFactory.setVirtualHost("/");
        return connectionFactory;
    }
}

现在你可以在camel-context.xml里直接引用上面注册的myConnectionFactory，配置JMS收发路由了。示例如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:camel="http://camel.apache.org/schema/spring"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
       http://camel.apache.org/schema/spring https://camel.apache.org/schema/spring/camel-spring.xsd">

    <!-- 引用我们注册的JMS连接工厂 -->
    <bean id="jmsComponent" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="myConnectionFactory"/>
    </bean>

    <!-- Camel路由配置：从inputQueue接收消息，处理后发送到outputQueue -->
    <camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
        <route id="jmsReceiveAndSend">
            <from uri="jms:queue:inputQueue"/>
            <log message="Received JMS message: ${body}"/>
            <transform>
                <simple>Processed: ${body}</simple>
            </transform>
            <to uri="jms:queue:outputQueue"/>
        </route>
    </camelContext>
</beans>

在你的Spring Boot启动类中，通过@ImportResource加载camel-context.xml，同时启用Spring Boot和Camel的自动配置：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("classpath:camel-context.xml") // 加载自定义的camel上下文配置
public class CamelJmsRabbitmqApplication {
    public static void main(String[] args) {
        SpringApplication.run(CamelJmsRabbitmqApplication.class, args);
    }
}

你之前遇到的两个问题根源：

1. 找不到javax.jms.ConnectionFactory类型的myConnectionFactory：因为你没有在Spring上下文里注册这个类型的Bean，或者注册的是错误的实现类。
2. 用com.rabbitmq.client.ConnectionFactory注册失败：这个类是RabbitMQ原生客户端的连接工厂，完全没有实现JMS规范的ConnectionFactory接口，所以Camel的JMS组件无法识别它，必须用RabbitMQ JMS客户端提供的RMQConnectionFactory。

启动Spring Boot应用后，你可以通过RabbitMQ管理界面发送一条消息到inputQueue，然后查看outputQueue是否收到前缀为Processed:的消息，同时检查应用日志是否打印了接收消息的日志，以此确认路由正常运行。

内容的提问来源于stack exchange，提问作者Eduard Nickel