Spring Boot 3.x + RabbitMQ: Продвинутая конфигурация

Введение: Современный стек для production

Spring Boot 3.x в сочетании с RabbitMQ представляет собой enterprise-уровневую платформу для построения event-driven систем. В 2025 году фокус сместился с базовой интеграции на production-готовые конфигурации, обеспечивающие безопасность, наблюдаемость и отказоустойчивость.


Spring Boot 3.3+ и RabbitMQ Starter: ключевые изменения

Spring Boot 3.3 существенно улучшил автоконфигурацию RabbitMQ:
Автоматическое определение кворумных очередей (Quorum Queues) как стандарта
Интеграция с Micrometer для детального мониторинга
Поддержка реактивных потоков через Project Reactor
Готовность к GraalVM native images из коробки

Минимальная конфигурация:

@Configuration
public class RabbitMQConfig {
    
    @Bean
    public CachingConnectionFactory connectionFactory(
            @Value("${spring.rabbitmq.host}") String host) {
        CachingConnectionFactory factory = new CachingConnectionFactory(host);
        
        // Производственные настройки по умолчанию
        factory.setPublisherConfirmType(CachingConnectionFactory.ConfirmType.CORRELATED);
        factory.setPublisherReturns(true);
        factory.setChannelCacheSize(25);
        
        return factory;
    }
}

Конфигурация для production: критичные параметры

Для production обязательны:
TLS/SSL для шифрования трафика
mTLS (Mutual TLS) для аутентификации клиентов
OAuth2 или JWT для авторизации

Конфигурация mTLS в application.yaml:

spring:
  rabbitmq:
    ssl:
      enabled: true
      algorithm: TLSv1.3
      key-store: file:/etc/ssl/client-keystore.p12
      key-store-password: ${KEYSTORE_PASSWORD}
      key-store-type: PKCS12
      trust-store: file:/etc/ssl/truststore.jks
      trust-store-password: ${TRUSTSTORE_PASSWORD}
      trust-store-type: JKS
      verify-hostname: true

Гарантии доставки

spring:
  rabbitmq:
    # Подтверждения от брокера
    publisher-confirm-type: correlated
    publisher-returns: true
    
    # Подтверждения от потребителя
    listener:
      simple:
        acknowledge-mode: manual  # Для полного контроля
        prefetch: 10              # Балансировка нагрузки
        retry:
          enabled: true
          max-attempts: 3
          back-off:
            initial-interval: 1s
            multiplier: 2

Spring Boot 3.3 предоставляет расширенный мониторинг через Micrometer:

@Configuration
public class MonitoringConfig {
    
    @Bean
    public MeterRegistryCustomizer<MeterRegistry> rabbitMQMetrics() {
        return registry -> {
            // Кастомные метрики для RabbitMQ
            registry.config().commonTags("application", "order-service");
        };
    }
    
    @Bean
    public RabbitTemplateMonitoring rabbitTemplateMonitoring(
            RabbitTemplate rabbitTemplate,
            MeterRegistry meterRegistry) {
        
        // Мониторинг времени доставки
        Timer timer = Timer.builder("rabbitmq.publish.duration")
            .description("Time to publish message to RabbitMQ")
            .register(meterRegistry);
        
        rabbitTemplate.setObservationEnabled(true);
        
        return new RabbitTemplateMonitoring(rabbitTemplate, timer);
    }
}

Reactive RabbitMQ с Project Reactor

Реактивная модель идеальна для:
Высоконагруженных систем с тысячами соединений
Сценариев, требующих backpressure управления
Интеграции с другими реактивными компонентами (WebFlux, R2DBC)

#Java #middle #RabbitMQ