问题背景

在企业级开发中，我们常常遇到这样的场景：系统已经使用了自己的 RabbitMQ 处理核心业务，但又需要对接第三方系统的 RabbitMQ。由于 Spring Boot 默认只支持单个 RabbitMQ 连接配置，直接添加第二个连接会导致配置冲突。

本文将详细介绍如何优雅地解决这个问题。

核心思路

Spring Boot 默认只支持单个 RabbitMQ 连接，当需要对接多个 RabbitMQ 时，核心思路是：

保留默认配置 ：主业务继续使用 Spring Boot 的默认 RabbitMQ 配置
自定义额外连接 ：为每个额外的 RabbitMQ 创建独立的 ConnectionFactory、RabbitTemplate 和 ListenerContainerFactory
Bean 隔离 ：使用 @Qualifier 注解区分不同的 #技术分享 RabbitMQ Bean
指定连接源 ：在发送消息和监听消息时明确指定使用哪个 RabbitMQ 连接

实战案例：对接两个 RabbitMQ

假设我们的系统需要：

主 RabbitMQ ：处理核心业务消息
第三方 RabbitMQ ：对接外部系统消息

1. 配置文件

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: admin
    password: admin123
    virtual-host: /

third-party: rabbitmq: host: 192.168.1.100 port: 5672 username: guest password: guest virtual-host: /external

2. 第三方 RabbitMQ 配置类

@Configuration
@ConfigurationProperties(prefix = "third-party.rabbitmq")
@Data
public class ThirdPartyRabbitConfig {

    private String host;
    private int port;
    private String username;
    private String password;
    private String virtualHost;


    @Bean("thirdPartyConnectionFactory")
    public ConnectionFactory thirdPartyConnectionFactory() {
        CachingConnectionFactory factory = new CachingConnectionFactory();
        factory.setHost(host);
        factory.setPort(port);
        factory.setUsername(username);
        factory.setPassword(password);
        factory.setVirtualHost(virtualHost);
        return factory;
    }


    @Bean("thirdPartyRabbitTemplate")
    public RabbitTemplate thirdPartyRabbitTemplate(
            @Qualifier("thirdPartyConnectionFactory") ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }


    @Bean("thirdPartyListenerFactory")
    public SimpleRabbitListenerContainerFactory thirdPartyListenerFactory(
            @Qualifier("thirdPartyConnectionFactory") ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        return factory;
    }
}

3. 消息发送：指定不同的 RabbitMQ

@Service
@Slf4j
public class MessageSender {

@Autowired private RabbitTemplate rabbitTemplate; @Autowired @Qualifier("thirdPartyRabbitTemplate") private RabbitTemplate thirdPartyRabbitTemplate;

public void sendToMain(String exchange, String routingKey, Object message) { rabbitTemplate.convertAndSend(exchange, routingKey, message); log.info("发送到主 RabbitMQ: {}", message); }

public void sendToThirdParty(String exchange, String routingKey, Object message) { thirdPartyRabbitTemplate.convertAndSend(exchange, routingKey, message); log.info("发送到第三方 RabbitMQ: {}", message); } }

4. 消息监听：指定不同的 RabbitMQ

@Component
@Slf4j
public class MessageListener {

@RabbitListener(queues = "main.queue") public void handleMainMessage(String message) { log.info("收到主系统消息: {}", message); }

@RabbitListener( queues = "external.queue", containerFactory = "thirdPartyListenerFactory" // 关键：指定监听器工厂 ) public void handleThirdPartyMessage(String message) { log.info("收到第三方消息: {}", message); } }

5. 使用示例

@RestController
public class TestController {

@Autowired private MessageSender messageSender;

@PostMapping("/send-main") public String sendToMain() { messageSender.sendToMain("main.exchange", "main.key", "Hello Main!"); return "发送到主 RabbitMQ 成功"; }

@PostMapping("/send-third-party") public String sendToThirdParty() { messageSender.sendToThirdParty("external.exchange", "external.key", "Hello External!"); return "发送到第三方 RabbitMQ 成功"; } }