SpringJMS 3.0.4不使用用户名连接MQ 7.5连接

Question

下面是我们正在使用的配置，但我们得到如下所示的错误消息

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms" xmlns:p="http://www.springframework.org/schema/p"  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd         http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd">

<!-- :: Messaging Infrastructure Beans :: -->

<bean id="transport" class="org.springframework.beans.factory.config.FieldRetrievingFactoryBean" p:staticField="com.ibm.mq.jms.JMSC.MQJMS_TP_CLIENT_MQ_TCPIP" />

  <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory" p:transportType-ref="transport"
  p:queueManager="${tcs.messaging.queueManager.name}" p:hostName="${tcs.messaging.queueManager.host}" p:port="${tcs.messaging.queueManager.port}"
  p:channel="${tcs.messaging.queueManager.channel}" />

<bean id="queueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"
  p:targetConnectionFactory-ref="mqConnectionFactory" p:sessionCacheSize="${tcs.messaging.connectionFactory.sessionCacheSize}"
  p:exceptionListener-ref="providerMessageListener" />

<bean id="providerMessageListener" class="com.uhg.treasury.customerservice.management.transport.jms.ProviderExceptionListener" />

<!-- New Addition ::   -->
   <bean id="myConnectionFactory2" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
      <property name="targetConnectionFactory"> <ref bean ="mqConnectionFactory"/> </property>
     <property name="username"> <value>"tbossmqd"</value> </property>
     <property name="password"> <value>"password1"</value> </property>
  </bean>

</beans>

错误信息如下所示

2014-06-27 11:25:42,503[main]debug-defaultMessageListenerContainer.InstructionSharedConnection(752)无法建立共享JMS连接-让异步调用程序尽快建立连接com.ibm.msg.client.JMS.detailedJMSSecurityException:JMSWMQ2013:为QueueManager“WMQT013”提供的安全身份验证无效，该身份验证的连接模式为“Client”，主机名为“WMQLT0006.xxx.com(1960)”。请检查您正在连接的QueueManager上提供的用户名和密码是否正确。com.ibm.msg.client.wmq.common.internal.reason.reasontoException(reas.java:521)在com.ibm.msg.client.wmq.internal.createException(reas.java:221)在com.ibm.msg.client.wmq.internal.wmqConnection.java:426)在ProviderConnection(WMQConnectionFactory.java:6277)在com.ibm.msg.client.jms.admin.jmsConnectionFactoryImpl.createConnection(JMSConnectionFactory.java:285)在com.ibm.mq.jms.mqConnectionFactory.createConnection(MQConnectionFactory.java:6233)在com.ibm.mq.jms.mqQueueConnectionFactory.java:6233)在在org.springframework.jms.connection.SingleConnectionFactory.docreateConnection(SingleConnectionFactory.java:342)在org.springframewinitConnection（singleConnectionFactory.java:288)在org.springframework.jms.connection.singleConnectionFactory.createConnection（singleConnectionFactory.java:225)在org.springframework.jms.support.jms.support.jmsAccessor.createConnection（jmsAccessor.java:184)在AbstractJMSListeningContainer.java:371)在org.springframework.jms.listener.defaultMessageListenerContainer.Instruction SharedConnection(DefaultMessageListenerContainer.java:749)在org.springframework.jms.listener.AbstractJMSListeningContainer.doStart（AbstractJMSListeningContainer.java:278)在gelistenerContainer.java:555)在org.springframework.context.support.defaultLifecycleProcessor.dostart(DefaultLifecycleProcessor.java:166)在org.springframework.context.support.defaultLifecycleProcessor.access$1(DefaultLifecycleProcessor.java:154)在org.springframework.context.support.defaultLifecycleProcessor.java:154)在在org.springframework.context.support.AbstractApplicationContext.FinishRefresh（AbstractApplicationContext.java:908)在org.springframework.context.support.AbstractApplicationContext.Refresh（AbstractApplicationContext.java:428)在org.springframework.context.support.ClasspathXmlApplicationContext.Refresh（AbstractApplicationContext.java:197)在ext.(classpathXmlApplicationContext.java:172)在org.springframework.context.support.classpathXmlApplicationContext.(classpathXmlApplicationContext.java:158)在com.uhg.treasury.customerService.management.server(server.java:61)在com.uh.treasury.customerService.management.server(server.java:43)在在com.ibm.msg.client.wmq.common.internal.reason.createException（reason.java：209）...29更多2014-06-27 11:25:42,512[main]debug-abstractJMSListeningContainer.resumepausedTasks（539）恢复暂停的任务:org.springframework.jms.listener.defaultMessager$AsyncMessageListenerContainer@627a94a9 11:25:42,512[main]ElistenerContainer$AsyncMessageListenerInvoker@5db615c1

Answer 1

我可以确认Spring调用的MQQueueUConnectionFactory.createConnection方法是不传递用户名/密码的版本。这就是为什么您看到MQRC_NOT_AUTHORIZED是因为用户名没有传递给队列管理器。

我不是spring专家，但我认为您添加的新myConnectionFactory2 bean需要引用您的CachingConnectionFactory bean（queueConnectionFactory)，而不是直接引用MQQueueConnectionFactory bean（mqConnectionFactory）。所以改变这个：

<bean id="myConnectionFactory2" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
      <property name="targetConnectionFactory"> <ref bean ="mqConnectionFactory"/> </property>
     <property name="username"> <value>"tbossmqd"</value> </property>
     <property name="password"> <value>"password1"</value> </property>
  </bean>

变成这样：

<bean id="myConnectionFactory2" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
      <property name="targetConnectionFactory"> <ref bean ="queueConnectionFactory"/> </property>
     <property name="username"> <value>"tbossmqd"</value> </property>
     <property name="password"> <value>"password1"</value> </property>
  </bean>