IBM MQ和Spring集成——安全设置

Question

我有一个Spring集成流，它使用入站网关从IBM MQ队列获取消息:

<int-jms:inbound-gateway id="InputGateway"  
   request-destination="RequestQueue"  
         request-channel="RequestChannel"
         reply-channel="ReplyChannel"     
         />

但是，我无法分配安全设置。特别是，我需要用户名，密码和用户身份验证MQCSP = false（由于本文范围之外的原因，我不会详细说明，但我的经纪人将抛出MQRC = 2009否则）。

我已经按照IBM指南连接了jmsTemplate，并且运行良好。这使用来自IBM MQ的官方Spring boot starter，它将友好地创建一个连接工厂，并使用来自application.properties的一些缺省值自动配置它。

ibm.mq.queueManager=myQMName
ibm.mq.channel=myChannel
ibm.mq.connName=myhostname(myPort)
ibm.mq.user=username
ibm.mq.password=*******
ibm.mq.userAuthenticationMQCSP=false

现在，回到Spring集成案例。根据int-jms:inbound-gateway规范，connectionFactory将通过名称(属性:connection-factory)注入到网关中，名称默认设置为“jmsConnectionFactory”

默认情况下，所有需要引用ConnectionFactory的JMS适配器都会自动查找名为jmsConnectionFactory的bean。这就是为什么您在许多示例中看不到连接工厂属性。但是，如果JMS ConnectionFactory具有不同的bean名称，则需要提供该属性。

我看不出有什么方法可以为连接工厂设置一个可预测的名称，以便插入int-jms:inbound-gateway。

现在，采用不同的方法，按照这个例子，我用一个合适的名称创建了我的connectionFactory:

<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
     <property name="transportType" value="1"/>
     <property name="queueManager" value="myQMName"/>
     <property name="hostName" value="myhostname"/>
     <property name="port" value="myPort" />
     <property name="channel" value="myChannel"/>
</bean>

<bean id="secureJmsConnectionAdapter" class="**yourpackages.SecureJMSConnectionAdapter**">
    <property name="targetConnectionFactory" ref="${jms.mq.connection.factory}" />
    <property name="userName" value="${jms.username}"/>
    <property name="pwdAlias" value="${jms.alias}"/>
</bean>

然而，我不清楚如何实现这个SecureJMSConnectionAdapter。

此外，如果我设置了自己的连接工厂，由于 MQAuto 配置类上的此注释，我将丢失所有 MQ 引导启动器自动魔术：

@ConditionalOnMissingBean(value=javax.jms.ConnectionFactory.class)

关于如何将这些片段组合在一起，有什么想法吗？

编辑：为了避免任何人出现任何可能的红鲱鱼，MQRC2009与ibm.mq.user身份验证MQCSP=假无关。

Answer 1

我的一些旧项目我使用了这样的豆子：

<bean id="jmsQueueConnectionFactory"
      class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
    <property name="targetConnectionFactory" ref="jmsConnectionFactory"/>
    <property name="username" value="${jms.username}"/>
    <property name="password" value="${jms.alias}"/>
</bean>

应该可以作为< code > com . IBM . MQ . JMS . mqqueueconnectionfactory 的包装器，但是您必须在目标组件中使用这个< code > jmsqueconnectionfactory 。

虽然看起来上面提到的IBM MQ JMS Spring并没有让我们正确地公开一个< code > JMS connection factory bean。在这种情况下，您可以依赖Spring Integration的默认设置，或者为< code>connection-factory显式使用< code > JMS connection factory 。

此外，对于Spring Boot，您应该考虑远离XML配置，给Spring集成Java DSL一个机会:https://docs . Spring . io/Spring-Integration/docs/5 . 1 . 7 . release/reference/html/# Java-DSL