Spring Boot 2.2.11.RELEASE集成Azure Service Bus JMS配置求助

问题根源 #

你当前的JmsConfig使用了ActiveMQConnectionFactory，这是专为ActiveMQ设计的连接工厂，无法识别Azure Service Bus的非tcp://开头连接字符串，必须替换为Azure官方提供的JMS连接工厂实现。

第一步：修正依赖 #

移除spring-boot-starter-activemq依赖（避免与Azure Service Bus的JMS实现冲突），保留必要的Azure相关依赖：

implementation 'com.azure.spring:spring-cloud-azure-starter-servicebus-jms:5.5.0'
implementation 'com.microsoft.azure:azure-servicebus-jms:2.0.6'

第二步：统一配置项命名 #

修正application.yml的配置，确保与后续代码中的@Value引用对应：

spring:
  jms:
    servicebus:
      connection-string: ${AZURE_ENDPOINT}
      topic: ${TOPIC}
      topic-client-id: ${TOPIC_CLIENT_ID}
      pricing-tier: standard

第三步：正确的JmsConfig配置 #

使用Azure Service Bus专属的连接工厂构建器，替换ActiveMQ相关配置：

@Configuration
@EnableJms
public class JmsConfig {

    @Value("${spring.jms.servicebus.connection-string}")
    private String connectionString;
    @Value("${spring.jms.servicebus.topic}")
    private String topic;

    // 保留原有消息转换器逻辑
    @Bean
    public MessageConverter jacksonJmsMessageConverter() {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setTargetType(MessageType.TEXT);
        converter.setTypeIdPropertyName("_type");
        return converter;
    }

    // 构建Azure Service Bus适配的JMS连接工厂
    @Bean
    public ConnectionFactory connectionFactory() {
        return new ServiceBusJmsConnectionFactoryBuilder()
                .connectionString(connectionString)
                .build();
    }

    // 配置JmsTemplate，绑定Azure连接工厂
    @Bean
    public JmsTemplate jmsTemplate() {
        JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory());
        jmsTemplate.setDefaultDestinationName(topic);
        jmsTemplate.setMessageConverter(jacksonJmsMessageConverter());
        return jmsTemplate;
    }
}

关键说明 #

• ServiceBusJmsConnectionFactoryBuilder是com.microsoft.azure:azure-servicebus-jms包提供的工具类，可正确解析Azure Service Bus的连接字符串格式。
• 移除所有ActiveMQ相关配置，防止Spring自动装配冲突。
• 业务代码无需修改，JMS API的通用性保证jmsTemplate.send()逻辑可直接复用。

内容的提问来源于stack exchange，提问作者Siyamcela Nxuseka