springboot连接两个rabbitmq实现将其中一个rabbitmq上的数据转发到另个一rabbitmq

在Spring Boot中连接两个RabbitMQ实例并其中一个RabbitMQ上的数据转发到另一个RabbitMQ可以通过以下步骤实现：

1. 首先，确保你已经在Spring Boot项目中添加了RabbitMQ的依赖。可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

2. 在application.properties或application.yml文件中配置两个RabbitMQ实例的连接信息。例如：

# 第一个RabbitMQ实例
spring.rabbitmq.host=host1
spring.rabbitmq.port=5672
spring.rabbitmq.username=username1
spring.rabbitmq.password=password1

# 第二个RabbitMQ实例
custom.rabbitmq.host=host2
custom.rabbitmq.port=5672
custom.rabbitmq.username=username2
custom.rabbitmq.password=password2

3. 创建两个RabbitMQ连接工厂的Bean。在Spring Boot的配置类中添加以下代码：

@Configuration
public class RabbitMQConfig {

    @Value("${spring.rabbitmq.host}")
    private String rabbitmqHost;

    @Value("${spring.rabbitmq.port}")
    private int rabbitmqPort;

    @Value("${spring.rabbitmq.username}")
    private String rabbitmqUsername;

    @Value("${spring.rabbitmq.password}")
    private String rabbitmqPassword;

    @Value("${custom.rabbitmq.host}")
    private String customRabbitmqHost;

    @Value("${custom.rabbitmq.port}")
    private int customRabbitmqPort;

    @Value("${custom.rabbitmq.username}")
    private String customRabbitmqUsername;

    @Value("${custom.rabbitmq.password}")
    private String customRabbitmqPassword;

    @Bean
    public ConnectionFactory rabbitmqConnectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(rabbitmqHost);
        connectionFactory.setPort(rabbitmqPort);
        connectionFactory.setUsername(rabbitmqUsername);
        connectionFactory.setPassword(rabbitmqPassword);
        return connectionFactory;
    }

    @Bean
    public ConnectionFactory customRabbitmqConnectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(customRabbitmqHost);
        connectionFactory.setPort(customRabbitmqPort);
        connectionFactory.setUsername(customRabbitmqUsername);
        connectionFactory.setPassword(customRabbitmqPassword);
        return connectionFactory;
    }
}

4. 创建两个RabbitMQ模板的Bean。在Spring Boot的配置类中添加以下代码：

@Configuration
public class RabbitMQConfig {

    // ...

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory rabbitmqConnectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(rabbitmqConnectionFactory);
        return rabbitTemplate;
    }

    @Bean
    public RabbitTemplate customRabbitTemplate(ConnectionFactory customRabbitmqConnectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(customRabbitmqConnectionFactory);
        return rabbitTemplate;
    }
}

5. 创建一个消息监听器，从第一个RabbitMQ实例接收消息，并将其发送到第二个RabbitMQ实例。例如：

@Component
public class MessageListener {

    private final RabbitTemplate customRabbitTemplate;

    public MessageListener(RabbitTemplate customRabbitTemplate) {
        this.customRabbitTemplate = customRabbitTemplate;
    }

    @RabbitListener(queues = "queue1")
    public void receiveMessageFromFirstRabbitMQ(String message) {
        // 将消息发送到第二个RabbitMQ实例
        customRabbitTemplate.convertAndSend("exchange2", "routingKey2", message);
    }
}

以上是一个简单的示例，通过消息监听器将第一个RabbitMQ实例上的消息转发到第二个RabbitMQ实例。你可以根据实际需求进行修改和扩展。