# 主 RabbitMQ（默認(rèn)）
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

@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 發(fā)送模板
     */
    @Bean("thirdPartyRabbitTemplate")
    public RabbitTemplate thirdPartyRabbitTemplate(
            @Qualifier("thirdPartyConnectionFactory") ConnectionFactory connectionFactory) {
        return new RabbitTemplate(connectionFactory);
    }
    
    /**
     * 第三方 RabbitMQ 監(jiān)聽器工廠
     */
    @Bean("thirdPartyListenerFactory")
    public SimpleRabbitListenerContainerFactory thirdPartyListenerFactory(
            @Qualifier("thirdPartyConnectionFactory") ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        return factory;
    }
}

@Service
@Slf4j
public class MessageSender {

    // 主 RabbitMQ（默認(rèn)）
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    // 第三方 RabbitMQ
    @Autowired
    @Qualifier("thirdPartyRabbitTemplate")
    private RabbitTemplate thirdPartyRabbitTemplate;

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

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

@Component
@Slf4j
public class MessageListener {

    /**
     * 監(jiān)聽主 RabbitMQ（使用默認(rèn)工廠）
     */
    @RabbitListener(queues = "main.queue")
    public void handleMainMessage(String message) {
        log.info("收到主系統(tǒng)消息: {}", message);
        // 處理主業(yè)務(wù)邏輯
    }

    /**
     * 監(jiān)聽第三方 RabbitMQ（指定工廠）
     */
    @RabbitListener(
        queues = "external.queue",
        containerFactory = "thirdPartyListenerFactory"  // 關(guān)鍵：指定監(jiān)聽器工廠
    )
    public void handleThirdPartyMessage(String message) {
        log.info("收到第三方消息: {}", message);
        // 處理第三方消息
    }
}

@RestController
public class TestController {

    @Autowired
    private MessageSender messageSender;

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

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