如何在SpringBoot应用中设置WMQConstants.USERID连接IBM MQ？

我正尝试通过SpringBoot应用连接远程IBM MQ，相关代码和配置如下：

配置类 #

@Configuration
@EnableJms
@ConditionalOnProperty(value = "mq.enabled", havingValue = "true")
@Import({MQAutoConfiguration.class, JmsAutoConfiguration.class})
public class MQConfiguration {

  @Bean
  JmsListenerContainerFactory<?> jmsListenerContainerFactory(
      ConnectionFactory connectionFactory,
      DefaultJmsListenerContainerFactoryConfigurer configurer) {
    var factory = new DefaultJmsListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    return factory;
  }
}

监听器代码 #

@JmsListener(destination = "${test-queue}")
public void receive(TextMessage message) {
  try {
    var foo =
        objectMapper.readValue(message.getText(), Foo.class);
    LOGGER.info("Incoming JMS message : " + message.getText());
    //Business logic
  } catch (Exception e) {
      e.printStackTrace();
  }
}

application.yaml 配置 #

ibm:
  mq:
    channel: DEV.CHNL
    user: app
    conn-name: ${ibm.mq.host}(${ibm.mq.port})
    queue-manager: QM_NAME

pom.xml 依赖 #

<dependency>
    <groupId>com.ibm.mq</groupId>
    <artifactId>mq-jms-spring-boot-starter</artifactId>
    <version>${ibm-mq.version}</version>
</dependency>

队列管理器需要UserId才能连接，但配置的ibm.mq.user并未生效，而是自动读取Java系统属性user.name（即进程名）。目前只能通过set - _JAVA_OPTIONS=-Duser.name=myUser这种方式设置，想问有没有不需要修改系统属性，直接设置WMQConstants.USERID的方法？

方法一：自定义 MQ 连接工厂配置 #

在MQConfiguration类中，手动创建MQConnectionFactory并显式设置USERID和密码，覆盖默认的系统属性读取逻辑：

@Configuration
@EnableJms
@ConditionalOnProperty(value = "mq.enabled", havingValue = "true")
@Import({MQAutoConfiguration.class, JmsAutoConfiguration.class})
public class MQConfiguration {

    @Value("${ibm.mq.user}")
    private String mqUser;

    @Value("${ibm.mq.password}")
    private String mqPassword;

    @Value("${ibm.mq.channel}")
    private String channel;

    @Value("${ibm.mq.conn-name}")
    private String connName;

    @Value("${ibm.mq.queue-manager}")
    private String queueManager;

    @Bean
    public MQConnectionFactory mqConnectionFactory() {
        MQConnectionFactory factory = new MQConnectionFactory();
        try {
            factory.setChannel(channel);
            factory.setConnectionNameList(connName);
            factory.setQueueManager(queueManager);
            // 手动指定USERID和密码
            factory.setStringProperty(WMQConstants.USERID, mqUser);
            factory.setStringProperty(WMQConstants.PASSWORD, mqPassword);
        } catch (JMSException e) {
            throw new RuntimeException("Failed to configure MQ connection factory", e);
        }
        return factory;
    }

    @Bean
    JmsListenerContainerFactory<?> jmsListenerContainerFactory(
            ConnectionFactory connectionFactory,
            DefaultJmsListenerContainerFactoryConfigurer configurer) {
        var factory = new DefaultJmsListenerContainerFactory();
        configurer.configure(factory, connectionFactory);
        return factory;
    }
}

配置后Spring会优先使用这个自定义连接工厂，不再读取user.name系统属性。

方法二：通过配置属性覆盖（适用于新版 starter） #

如果使用的是较新版本的mq-jms-spring-boot-starter，可以直接在application.yaml中添加配置禁用系统用户读取：

ibm:
  mq:
    channel: DEV.CHNL
    user: app
    password: your-password
    conn-name: ${ibm.mq.host}(${ibm.mq.port})
    queue-manager: QM_NAME
    # 禁用自动读取系统user.name属性
    use-system-user-name: false

注意use-system-user-name是新版starter新增属性，低版本不支持时优先用方法一。

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