我尝试使用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 中工作?
在 9.3 中,Java 和 JMS 类中 MQ 身份验证的默认设置从兼容模式更改为 MQCSP。这就是您现在获得 2035 的原因。要使连接再次正常工作,您需要切换回兼容模式。
有几种方法可以将其设置回兼容模式,其中两种是:
JmsConstants.USER_AUTHENTICATION_MQCSP
为false
com.ibm.mq.cfg.jmqi.useMQCSPauthentication
为N
。例如:
System.setProperty("com.ibm.mq.cfg.jmqi.useMQCSPauthentication", "N")
-Dcom.ibm.mq.cfg.jmqi.useMQCSPauthentication=N
有关更多详细信息,请参阅Java 客户端的连接身份验证。
9.3 破坏它可能意味着以下三种情况之一:
CONNAUTH
配置ADOPTCTX(NO)
。您可以通过打开兼容模式并故意发送不正确的密码来测试它是否为#3。如果它有效,那么你就知道它是#3。
您可以通过关闭兼容模式、发送正确的密码并指定来测试它是否是#2
-Duser.name=username
,如果这有效,那么它可能是#2`如果上述两项都失败了,那么它很可能是#1。