SpringBoot多RabbitMQ连接集成的实现示例_Java

问题背景

在企业级开发中，我们经常遇到这样的场景：系统已经使用了自己的 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. 配置文件

# 主 rabbitmq（默认）
spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: admin
    password: admin123
    virtual-host: /

# 第三方 rabbitmq
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;
    
    /**
     * 第三方 rabbitmq 连接工厂
     */
    @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;
    }
    
    /**
     * 第三方 rabbitmq 发送模板
     */
    @bean("thirdpartyrabbittemplate")
    public rabbittemplate thirdpartyrabbittemplate(
            @qualifier("thirdpartyconnectionfactory") connectionfactory connectionfactory) {
        return new rabbittemplate(connectionfactory);
    }
    
    /**
     * 第三方 rabbitmq 监听器工厂
     */
    @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 {

    // 主 rabbitmq（默认）
    @autowired
    private rabbittemplate rabbittemplate;
    
    // 第三方 rabbitmq
    @autowired
    @qualifier("thirdpartyrabbittemplate")
    private rabbittemplate thirdpartyrabbittemplate;

    /**
     * 发送到主 rabbitmq
     */
    public void sendtomain(string exchange, string routingkey, object message) {
        rabbittemplate.convertandsend(exchange, routingkey, message);
        log.info("发送到主rabbitmq: {}", message);
    }

    /**
     * 发送到第三方 rabbitmq
     */
    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 {

    /**
     * 监听主 rabbitmq（使用默认工厂）
     */
    @rabbitlistener(queues = "main.queue")
    public void handlemainmessage(string message) {
        log.info("收到主系统消息: {}", message);
        // 处理主业务逻辑
    }

    /**
     * 监听第三方 rabbitmq（指定工厂）
     */
    @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成功";
    }
}