jms - 使用 com.ibm.mq.jakarta.client.jar 9.3 迁移到 Spring Boot 3 后，IBM MQ JMS 无法工作

Question

我尝试使用 javax.jms MQ 依赖项在 Spring Boot 2.5 中调用 Enterprise MQ。正在成功建立连接。下面是我的 pom.xml 和代码。我正在使用 App ID 凭据连接到我在 UserCredentialsProvider 类中设置的队列。

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-activemq</artifactId>
        </dependency>
        
        <dependency>
            <groupId>com.ibm.mq</groupId>
            <artifactId>com.ibm.mq.allclient</artifactId>
            <version>0.0.0.3</version>
        </dependency>
        
        <dependency>
            <groupId>javax.jms</groupId>
            <artifactId>javax.jms-api</artifactId>
            <version>2.0.1</version>
        </dependency>

代码-

    @Bean
    public MQQueueConnectionFactory mqQueueConnectionFactory() {
        MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
        mqQueueConnectionFactory.setHostName(host);
        try {
            mqQueueConnectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
            mqQueueConnectionFactory.setCCSID(1208);
            mqQueueConnectionFactory.setChannel(channel);
            mqQueueConnectionFactory.setPort(port);
            mqQueueConnectionFactory.setQueueManager(queueManager);            
            
        } catch (Exception e) {
            e.printStackTrace();
        }
        return mqQueueConnectionFactory;
    }

    @Bean
    UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter(MQQueueConnectionFactory mqQueueConnectionFactory) {
        UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter = new UserCredentialsConnectionFactoryAdapter();
        userCredentialsConnectionFactoryAdapter.setUsername(username);
        userCredentialsConnectionFactoryAdapter.setPassword(password);
        userCredentialsConnectionFactoryAdapter.setTargetConnectionFactory(mqQueueConnectionFactory);
        return userCredentialsConnectionFactoryAdapter;
    }

    @Bean
    @Primary
    public CachingConnectionFactory cachingConnectionFactory(UserCredentialsConnectionFactoryAdapter userCredentialsConnectionFactoryAdapter) {
        CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
        cachingConnectionFactory.setTargetConnectionFactory(userCredentialsConnectionFactoryAdapter);
        cachingConnectionFactory.setSessionCacheSize(500);
        cachingConnectionFactory.setReconnectOnException(true);
        return cachingConnectionFactory;
    }

    @Bean
    public PlatformTransactionManager jmsTransactionManager(CachingConnectionFactory cachingConnectionFactory) {
        JmsTransactionManager jmsTransactionManager = new JmsTransactionManager();
        jmsTransactionManager.setConnectionFactory(cachingConnectionFactory);
        return jmsTransactionManager;
    }

    @Bean
    public JmsOperations jmsOperations(CachingConnectionFactory cachingConnectionFactory) throws JMSException {
        JmsTemplate jmsTemplate = new JmsTemplate(cachingConnectionFactory);
        jmsTemplate.setReceiveTimeout(receiveTimeout);
   Connection c = jmsTemplate.getConnectionFactory().createConnection();
   System.out.println(c.getMetaData()); //the connection is established successfully
        return jmsTemplate;
    }

现在，我所做的是尝试迁移到 Spring Boot 3.1.1。我必须更改 POM 中的 MQ 依赖项，以使用 jakarta 代替 javax 包。以下是我更新的 POM:

        <dependency>
            <groupId>jakarta.jms</groupId>
            <artifactId>jakarta.jms-api</artifactId>
        </dependency>
        <dependency>
            <groupId>com.ibm.mq</groupId>
            <artifactId>com.ibm.mq.jakarta.client</artifactId>
            <version>9.3.0.0</version>
        </dependency>

我更新了上面的代码以使用 jakarta Connection Factory 而不是 JMS ，但现在我收到 MQRC_NOT_AUTHORIZED(2035) 错误。

我必须执行哪些修改才能使其在带有 com.ibm.mq.jakarta.client.jar 9.3 的 Spring Boot 3.1 中工作？

Answer 1

在 9.3 中，Java 和 JMS 类中 MQ 身份验证的默认设置从兼容模式更改为 MQCSP。这就是您现在获得 2035 的原因。要使连接再次正常工作，您需要切换回兼容模式。

有几种方法可以将其设置回兼容模式，其中两种是:

1. 将连接工厂属性 JmsConstants.USER_AUTHENTICATION_MQCSP 设置为 false
2. 将 Java 系统属性 com.ibm.mq.cfg.jmqi.useMQCSPauthentication 设置为 N。
   例如:
   • System.setProperty("com.ibm.mq.cfg.jmqi.useMQCSPauthentication", "N")
   • -Dcom.ibm.mq.cfg.jmqi.useMQCSPauthentication=N

有关更多详细信息，请参阅 Connection authentication with the Java client .

---

9.3 打破它可能意味着以下三件事之一:

1. 队列管理器使用自定义安全导出来验证需要兼容模式的用户名和密码。
2. 队列管理器已使用 ADOPTCTX(NO) 配置了 CONNAUTH。
3. 队列管理器没有适当的安全措施，队列管理器只是假设您发送的用户名是正确的。

您可以通过打开兼容模式并故意发送不正确的密码来测试它是否为#3。如果它有效，那么你就知道它是#3。

您可以通过关闭兼容模式、发送正确的密码并指定 -Duser.name=username 来测试它是否是 #2，如果有效，则可能是 #2。

如果上述两项都失败，那么很可能是#1。