24.8. 部署 WebSphere MQ 资源适配器

关于 WebSphere MQ

WebSphere MQ 是 IBM 的面向消息中间件（Messaging Oriented Middleware，MOM），它允许分布式系统上的应用程序彼此通讯。这是通过消息和消息队列来实现的。WebSphere MQ 负责递送消息到消息队列并用消息频道传输数据到其他队列管理者。关于 WebSphere MQ 的更多信息，请参考 WebSphere MQ。

介绍

本节涵盖在 JBoss EAP 6 里部署和配置 WebSphere MQ 资源适配器的步骤。您可以手动编辑配置文件来完成，也可以通过管理 CLI 或使用基于 Web 的管理控制台来完成。

前提条件

在开始之前，您必需检验 WebSphere MQ 资源适配器的版本并理解一些 WebSphere MQ 配置属性。

  • WebSphere MQ 资源适配器是作为 Resource Archive (RAR) 文件（wmq.jmsra-VERSION.rar）提供的。您必须使用 7.5.0.0 或之后的版本。
  • 您必须了解下列 WebSphere MQ 配置属性。关于这些属性的细节，请参考 WebSphere MQ 产品文档。
    • MQ.QUEUE.MANAGER：WebSphere MQ 队列管理者的名称
    • MQ.PORT：用来连接 WebSphere MQ 队列管理者的主机名
    • MQ.PORT：用来连接 WebSphere MQ 队列管理者的服务器频道
    • MQ.QUEUE.NAME：目标队列的名称
    • MQ.TOPIC.NAME：目标主题的名称
    • MQ.PORT：用来连接 WebSphere MQ 队列管理者的端口
    • MQ.CLIENT：传输类型
  • 对于转出连接，您也必须熟悉下列配置属性：
    • MQ.CONNECTIONFACTORY.NAME：提供连接给远程系统的连接工厂实例的名称

注意

下面是 IBM 提供的默认配置，您可以根据需要进行修改。更多信息请参考 WebSphere MQ 文档。

过程 24.8. 手动部署资源适配器

  1. 如果您需要 WebSphereMQ 资源适配器支持事务，您必须重新打包 wmq.jmsra-VERSION.rar 归档，使其包含 mqetclient.jar。您可以使用下列命令： 
    [user@host ~]$ jar -uf wmq.jmsra-VERSION.rar mqetclient.jar
    请用正确的版本号码替换 VERSION。
  2. 复制 wmq.jmsra-VERSION.rar 文件到 EAP_HOME/standalone/deployments/ 目录。
  3. 在服务器配置文件里添加资源适配器。
    1. 在编辑器里打开 EAP_HOME/standalone/configuration/standalone-full.xml 文件。
    2. 在配置文件里找到 urn:jboss:domain:resource-adapters 子系统。
    3. 如果没有为这个子系统定义资源适配器，请首先替换： 
      <subsystem xmlns="urn:jboss:domain:resource-adapters:1.1"/>
      使用下列内容： 
      <subsystem xmlns="urn:jboss:domain:resource-adapters:1.1">
    <resource-adapters>
        <!-- <resource-adapter> configuration listed below -->
    </resource-adapters>
</subsystem>
    4. 资源适配器的配置依赖您是否需要事务支持和恢复。如果您不需要事务支持，请选择下面的第一个配置步骤。如果您需要事务支持，请选择第二个配置步骤。
      • 对于非事务性部署，请用下列内容替换 <!-- <resource-adapter> configuration listed below -->： 
        <resource-adapter>
    <archive>
        wmq.jmsra-VERSION.rar
    </archive>
    <transaction-support>NoTransaction</transaction-support>
    <connection-definitions>
        <connection-definition 
                class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" 
                jndi-name="java:jboss/MQ.CONNECTIONFACTORY.NAME" 
                pool-name="MQ.CONNECTIONFACTORY.NAME">
            <config-property name="hostName">
                MQ.HOST.NAME
            </config-property>
            <config-property name="port">
                MQ.PORT
            </config-property>
            <config-property name="channel">
                MQ.CHANNEL.NAME
            </config-property>
            <config-property name="transportType">
                MQ.CLIENT
            </config-property>
            <config-property name="queueManager">
                MQ.QUEUE.MANAGER
            </config-property>
            <security>
                <security-domain>MySecurityDomain</security-domain>
            </security>
       </connection-definition>
    </connection-definitions>
    <admin-objects>
        <admin-object 
                class-name="com.ibm.mq.connector.outbound.MQQueueProxy" 
                jndi-name="java:jboss/MQ.QUEUE.NAME" 
                pool-name="MQ.QUEUE.NAME">
            <config-property name="baseQueueName">
                MQ.QUEUE.NAME
            </config-property>
            <config-property name="baseQueueManagerName">
                MQ.QUEUE.MANAGER
            </config-property>
       <admin-object class-name="com.ibm.mq.connector.outbound.MQTopicProxy"
                jndi-name="java:jboss/MQ.TOPIC.NAME" pool-name="MQ.TOPIC.NAME">
            <config-property name="baseTopicName">
                MQ.TOPIC.NAME
            </config-property>
            <config-property name="brokerPubQueueManager">
                MQ.QUEUE.MANAGER
            </config-property>
       </admin-object>
      </admin-object>
    </admin-objects>
</resource-adapter>
        请确保用 RAR 名称里的实际版本替换 VERSION。
      • 对于事务性部署，请用下列内容替换 <!-- <resource-adapter> configuration listed below -->： 
        <resource-adapter>
    <archive>
        wmq.jmsra-VERSION.rar
    </archive>
    <transaction-support>XATransaction</transaction-support>
    <connection-definitions>
        <connection-definition 
                class-name="com.ibm.mq.connector.outbound.ManagedConnectionFactoryImpl" 
                jndi-name="java:jboss/MQ.CONNECTIONFACTORY.NAME" 
                pool-name="MQ.CONNECTIONFACTORY.NAME">
            <config-property name="hostName">
                MQ.HOST.NAME
            </config-property>
            <config-property name="port">
                MQ.PORT
            </config-property>
            <config-property name="channel">
                MQ.CHANNEL.NAME
            </config-property>
            <config-property name="transportType">
                MQ.CLIENT
            </config-property>
            <config-property name="queueManager">
                MQ.QUEUE.MANAGER
            </config-property>
           <security>
                <security-domain>MySecurityDomain</security-domain>
            </security>
            <recovery>
                <recover-credential>
                    <user-name>USER_NAME</user-name>
                    <password>PASSWORD</password>
                </recover-credential>
            </recovery>
        </connection-definition>
    </connection-definitions>
    <admin-objects>
        <admin-object 
                class-name="com.ibm.mq.connector.outbound.MQQueueProxy" 
                jndi-name="java:jboss/MQ.QUEUE.NAME" 
                pool-name="MQ.QUEUE.NAME">
            <config-property name="baseQueueName">
                MQ.QUEUE.NAME
            </config-property>
            <config-property name="baseQueueManagerName">
                MQ.QUEUE.MANAGER
            </config-property>
        </admin-object>
        <admin-object class-name="com.ibm.mq.connector.outbound.MQTopicProxy"
                jndi-name="java:jboss/MQ.TOPIC.NAME" pool-name="MQ.TOPIC.NAME">
            <config-property name="baseTopicName">
                MQ.TOPIC.NAME
            </config-property>
            <config-property name="brokerPubQueueManager">
                MQ.QUEUE.MANAGER
            </config-property>
        </admin-object>
    </admin-objects>
</resource-adapter>
        请确保用 RAR 名称里的实际版本替换 VERSION。您也必须用有效的用户名和密码替换 USER_NAME 和 PASSWORD。

        注意

        为了支持事务， <transaction-support> 元素要设置为 XATransaction。为了支持 XA 恢复，<recovery> 元素要添加至连接定义里。
    5. 如果您想将 JBoss EAP 6 里的默认 EJB3 消息系统 HornetQ 修改为 WebSphere MQ，请这样修改 urn:jboss:domain:ejb3:1.2 子系统：
      替换： 
      <mdb>
    <resource-adapter-ref resource-adapter-name="hornetq-ra"/>
    <bean-instance-pool-ref pool-name="mdb-strict-max-pool"/>
</mdb>
      为： 
      <mdb>
    <resource-adapter-ref resource-adapter-name="wmq.jmsra-VERSION.rar"/>
    <bean-instance-pool-ref pool-name="mdb-strict-max-pool"/>
</mdb>
      请确保用 RAR 名称里的实际版本替换 VERSION。

过程 24.9. 修改 MDB 代码来使用资源适配器

  • 在 MDB 代码里这样配置 ActivationConfigProperty 和 ResourceAdapter 
    @MessageDriven( name="WebSphereMQMDB", 
    activationConfig =
    {
        @ActivationConfigProperty(propertyName = "destinationType",propertyValue = "javax.jms.Queue"),
        @ActivationConfigProperty(propertyName = "useJNDI", propertyValue = "false"),
        @ActivationConfigProperty(propertyName = "hostName", propertyValue = "MQ.HOST.NAME"),
        @ActivationConfigProperty(propertyName = "port", propertyValue = "MQ.PORT"),
        @ActivationConfigProperty(propertyName = "channel", propertyValue = "MQ.CHANNEL.NAME"),
        @ActivationConfigProperty(propertyName = "queueManager", propertyValue = "MQ.QUEUE.MANAGER"),
        @ActivationConfigProperty(propertyName = "destination", propertyValue = "MQ.QUEUE.NAME"),
        @ActivationConfigProperty(propertyName = "transportType", propertyValue = "MQ.CLIENT")
    })
    @ResourceAdapter(value = "wmq.jmsra-VERSION.rar")
@TransactionAttribute(TransactionAttributeType.NOT_SUPPORTED)
public class WebSphereMQMDB implements MessageListener {
}
    请确保用 RAR 名称里的实际版本替换 VERSION。
提交 bug 报告