代码之家  ›  专栏  ›  技术社区  ›  Sugandha Mishra

迁移到Spring Boot 3后,IBM MQ JMS不工作

  •  0
  • Sugandha Mishra  · 技术社区  · 2 年前

    我尝试在Spring Boot 2.5中使用 javax.jms MQ依赖关系。正在成功建立连接。下面是我的 pom.xml 和代码。我正在使用应用程序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;
        }
    

    现在,我所做的是尝试迁移到SpringBoot3.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连接工厂而不是JMS,但现在我得到了MQRC_NOT_AUTHORIZED(2035)错误。

    为了在Spring Boot 3.1中使用com.ibm.mq.jakarta.client.jar 9.3,我必须执行哪些修改?

    1 回复  |  直到 2 年前
        1
  •  2
  •   JoshMc    2 年前

    在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. 队列管理器具有 CONNAUTH 配置为 ADOPTCTX(NO)
    3. 队列管理器没有安全性,队列管理器只是假设您发送的用户名是正确的。

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

    您可以通过关闭兼容性模式、发送正确的密码并指定 -Duser.name=username ,如果这有效,那么它很可能是#2。

    如果以上两项都失败了,那么它很可能是#1。

    推荐文章