zoukankan      html  css  js  c++  java

  • 如何在 JBoss 里配置 IBM MQ

    在本文中，我将告诉大家如何在JBoss里安装、配置WebSphere MQ资源适配器。

    安装WebSphere MQ资源适配器: 　　
    从安装目录复制wmq.jmsra.rar文件到服务器的部署目录中，例如：<安装路径>/server/default/deploy。此时资源适配器将会自动选择服务器。

    安装WebSphere MQ扩展事务客户端: 　　
    WebSphere MQ扩展事务客户端允许你使用XA分布式事务，并用客户端模式连接到WebSphere MQ队列管理器。要将客户端安装在JBoss，需要从安装目录复制com.ibm.mqetclient.jar文件到服务器的lib目录中，例如<安装路径>/server/default/lib。

    为你的应用程序配置资源适配器: 　　
    WebSphere MQ资源适配器允许你定义一些全局的属性。在JBoss中JCA出站流的资源定义在-ds.xml文件，名为wmq.jmsra-ds.xml。
    此文件的概要如下:

    1<?xml version="1.0" encoding="UTF-8"?>
    2<connection-factories>
    3  <!-- mbeans defining JCA administered objects -->
    4  <mbean/>
    5  <!-- JCA Connection factory definitions -->
    6  <tx-connection-factory/>
    7</connection-factories>

    从上可以看出JCA连接工厂的定义在<tx-connection-factory>元素，而且JMS队列和主题被定义在JCA的管理对象mbean里面。

    简单的两个队列-入站和出站的完整示例如下:

    01<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
    02<connection-factories>
    03    <tx-connection-factory>
    04        <jndi-name>jms/MyAppConnectionFactory</jndi-name>
    05        <rar-name>wmq.jmsra.rar</rar-name>
    06        <use-java-context>true</use-java-context>
    07        <connection-definition>javax.jms.QueueConnectionFactory</connection-definition>
    08        <min-pool-size>8</min-pool-size>
    09        <max-pool-size>36</max-pool-size>
    10        <config-property type="java.lang.String" name="channel">${channel}</config-property>
    11        <config-property type="java.lang.String" name="hostName">${hostName}</config-property>
    12        <config-property type="java.lang.String" name="port">1414</config-property>
    13        <config-property type="java.lang.String"name="queueManager">${queueManager}</config-property>
    14        <config-property type="java.lang.String"name="transportType">CLIENT</config-property>
    15        <config-property type="java.lang.String" name="username">munish</config-property>
    16        <security-domain-and-application>JmsXARealm</security-domain-and-application>
    17        <xa-transaction/>
    18    </tx-connection-factory>
    19    <mbean name="imq.queue:name=MY.APP.INBOUND.QUEUE"code="org.jboss.resource.deployment.AdminObject" >
    20  <attribute name="JNDIName">jms/IncomingQueue</attribute>
    21  <depends optional-attribute-name="RARName">jboss.jca:name='wmq.jmsra.rar',service=RARDeployment</depends>
    22  <attribute name="Type">javax.jms.Queue</attribute>
    23  <attribute name="Properties">
    24   baseQueueManagerName=${queueManager}
    25   baseQueueName=MY.APP.INBOUND.QUEUE
    26    </attribute>
    27    </mbean>
    28    <mbean name="imq.queue:name=MY.APP.OUTBOUND.QUEUE"code="org.jboss.resource.deployment.AdminObject">
    29        <attribute name="JNDIName">jms/OutgoingQueue</attribute>
    30        <depends optional-attribute-name="RARName">jboss.jca:name='wmq.jmsra.rar',service=RARDeployment</depends>
    31        <attribute name="Type">javax.jms.Queue</attribute>
    32        <attribute name="Properties">
    33            baseQueueManagerName=${queueManager}
    34            baseQueueName=MY.APP.OUTBOUND.QUEUE
    35        </attribute>
    36    </mbean>
    37</connection-factories>

    在JBoss启动脚本中占位符属性被定义为：
    -Dchannel=MQTEST -DhostName=localhost -DqueueManager=TST_MGR

    配置入站消息传递: 
    消息传递配置在jboss.xml文件中，这个文件的内容会有所不同，但大致如下:
    jboss.xml

    01<jboss xmlns="http://www.jboss.com/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    02 xsi:schemaLocation="http://www.jboss.com/xml/ns/javaee
    03 http://www.jboss.org/j2ee/schema/jboss_5_0.xsd" version="5.0">
    04 <enterprise-beans>
    05  <message-driven>
    06   <ejb-name>MyMessageBean</ejb-name>
    07    <!--  Make sure following System properties are defined in JBoss before deploying the application   -->
    08     <activation-config>
    09                     <activation-config-property>
    10                             <activation-config-property-name>DestinationType</activation-config-property-name>
    11                             <activation-config-property-value>javax.jms.Queue</activation-config-property-value>
    12                     </activation-config-property>
    13                     <activation-config-property>
    14                             <activation-config-property-name>destination</activation-config-property-name>
    15                             <activation-config-property-value>MY.APP.INBOUND.QUEUE</activation-config-property-value>
    16                     </activation-config-property>
    17                     <activation-config-property>
    18                             <activation-config-property-name>channel</activation-config-property-name>
    19                             <activation-config-property-value>${channel}</activation-config-property-value>
    20                     </activation-config-property>
    21                     <activation-config-property>
    22                             <activation-config-property-name>hostName</activation-config-property-name>
    23                             <activation-config-property-value>${hostName}</activation-config-property-value>
    24                     </activation-config-property>
    25                     <activation-config-property>
    26                             <activation-config-property-name>port</activation-config-property-name>
    27                             <activation-config-property-value>1414</activation-config-property-value>
    28                     </activation-config-property>
    29                     <activation-config-property>
    30                             <activation-config-property-name>queueManager</activation-config-property-name>
    31                             <activation-config-property-value>${queueManager}</activation-config-property-value>
    32                     </activation-config-property>
    33                     <activation-config-property>
    34                             <activation-config-property-name>transportType</activation-config-property-name>
    35                             <activation-config-property-value>CLIENT</activation-config-property-value>
    36                     </activation-config-property>
    37                     <activation-config-property>
    38                             <activation-config-property-name>username</activation-config-property-name>
    39                             <activation-config-property-value>munish</activation-config-property-value>
    40                     </activation-config-property>
    41              </activation-config>
    42               <!-- instruct the MDB to use the WebSphere MQ resource adapter -->
    43           <resource-adapter-name>wmq.jmsra.rar</resource-adapter-name>
    44     </message-driven>
    45 </enterprise-beans>
    46</jboss>

    必须指定目标类型和名称属性。其他属性都是可选的，如果省略，将使用其默认值。

    一个简单的MDB定义入站消息如下所示:

    01/**
    02 * This message driven bean is used to collect asynchronously received messages.
    03 *
    04 * <a href="http://my.oschina.net/arthor" class="referer" target="_blank">@author</a>  Munish Gogna
    05 */
    06@MessageDriven(mappedName = "jms/IncomingQueue")
    07public final class MyMessageBean implements javax.jms.MessageListener {
    08  private static final org.apache.log4j.Logger LOGGER = org.apache.log4j.Logger.getLogger(MyMessageBean.class);
    09  public void onMessage(final javax.jms.Message message) {
    10    LOGGER.info("Received message: " + message);
    11    // TODO - do processing with the message here
    12  }
    13}

    一个简单的java类发送消息到输出队列如下所示：

    01/**
    02 * This class is used to send text messages to a queue.
    03 *
    04 * <a href="http://my.oschina.net/arthor" class="referer" target="_blank">@author</a>  Munish Gogna
    05 */
    06public final class MessageSender {
    07  private static final org.apache.log4j.Logger LOGGER = org.apache.log4j.Logger.getLogger(MessageSender.class);
    08  /**
    09   * A coarse-grained method, nothing fancy. In actual applications please re factor the code and
    10   * handle the exceptions properly.
    11   *
    12   * @throws Exception
    13   */
    14  public void send(final String message) throws Exception {
    15    if (message == null) {
    16      throw new IllegalArgumentException("Parameter message cannot be null");
    17    }
    18    javax.jms.QueueConnection connection = null;
    19    javax.jms.Session session = null;
    20    try {
    21      javax.naming.Context fContext = new javax.naming.InitialContext();
    22      javax.jms.QueueConnectionFactory fConnectionFactory = (javax.jms.QueueConnectionFactory) fContext
    23          .lookup("java:jms/MyAppConnectionFactory");
    24      connection = fConnectionFactory.createQueueConnection();
    25      session = connection.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
    26      final javax.naming.Context jndiContext = newjavax.naming.InitialContext();
    27      final javax.jms.Destination destination = (javax.jms.Destination) jndiContext.lookup("jms/OutgoingQueue");
    28      final javax.jms.MessageProducer messageProducer = session.createProducer(destination);
    29      final javax.jms.TextMessage textMessage = session.createTextMessage(message);
    30      messageProducer.send(textMessage);
    31      messageProducer.close();
    32    } catch (Exception nex) {
    33      throw nex;
    34    } finally {
    35      if (session != null) {
    36        try {
    37          session.close();
    38        } catch (JMSException e) {
    39          LOGGER.error("Failed to close JMS session", e);
    40        }
    41      }
    42      if (connection != null) {
    43        try {
    44          connection.close();
    45        } catch (JMSException e) {
    46          LOGGER.error("Failed to close JMS connection", e);
    47        }
    48      }
    49    }
    50  }
    51}

    最终RFHUTILC.EXE可用于连接到远程队列 

    原文地址：http://www.oschina.net/question/157182_58109
  • 相关阅读:
    [论文收集]Web service security (尤其是RBAC)相关的论文 [更新中]
    [文章摘录] The Case for Cloud Computing (ITPro, 2009)
    [文章摘录] 网络计算系统的分类研究 (计算机学报, 2008)
    文献综述的写法
    [转]VS2005常用快捷键大全
    什么是存储过程
    使用冒泡法对数组排序
    ASP.NET中使用Global.asax文件
    轻松掌握Ajax.net系列教程
    客户端回调实现gridView无刷新分页
  • 原文地址：https://www.cnblogs.com/inteliot/p/2552874.html
Copyright © 2011-2022 走看看