我们最近发现大量的客户都有一个同样的问题：在运行于JBoss Wildfly 7中的HornetQ JMS实现和独立运行的ActiveMQ服务器之间，如何才能建立一个桥接。ActiveMQ作为一个独立运行的消息代理（message broker），一直是一个可靠的选择。而且随着Red Hat已经收购了Fusesource（译者注：Fusesource是ActiveMQ项目的维护组织，Red Hat此前在2006年收购了JBoss，现在JBoss和Fusesource都是Red Hat旗下的开源组织），在等待JBoss AMQ版本的ActiveMQ推出期间（译者注：JBoss基于ActiveMQ定制了一个新MQ，官方名称为JBoss A-MQ），这个问题尤其突出。
不使用桥接当然也是可能的，直接可以把ActiveMQ引入到JBoss，然后使用ActiveMQ上暴露的JMS队列。但是这个方式的缺点在于，如果ActiveMQ服务器由于某些原因停止工作的话，运行于JBoss中的JMS生产者将会失败，消费者也将会断开连接并且需要重连（译者注：原文拼写错误，误将reconnect拼写为reconnet）。一个更好的架构是，JBoss中的生产者先入列到一个本地HornetQ队列，然后将这些消息桥接到外部的ActiveMQ代理。在这个架构中，生产者可以在ActiveMQ宕机期间持续地入列消息，等到ActiveMQ再次工作时这些消息将会从HornetQ传输到ActiveMQ。
配置桥接的过程是相当简单的,我们需要做以下的事情:
1. 下载ActiveMQ资源适配器归档文件 2. 在WildFly 7中安装和配置资源适配器 3. 在WildFly 7内嵌的HornetQ实例中,创建一个本地JMS队列 4. 在本地队列和远程ActiveMQ队列之间,创建一个JMS桥接.
为了开始, 我下载了ActiveMQ资源适配器,从这个页面:http://repo1.maven.org/maven2/org/apache/activemq/activemq-rar/ 下一步,我们需要使用如下的命令,为activemq资源适配器,创建一个JBoss模块,:
mkdir modules/system/layers/base/org/activemq/main cd modules/system/layers/base/org/activemq/main unzip ~/activemq-rar-5.9.0.rar
这将会创建一个包含模块层次结构的目录,并将activemq资源适配器文件解压到此目录.JBoss只支持把拓展的资源适配器作为模块,所以我们解压归档文件的内容.同时,我们需要在activemq/main目录,创建一个包含如下内容的module.xml文件.这是为了让JBoss区分,哪些jar文件需要加装,哪些类不需要和其它模块共享(我们不希望和任何库的实现相冲突).
<module xmlns="urn:jboss:module:1.1" name="org.apache.activemq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> <resources> <resource-root path="."/> <resource-root path="activemq-broker-5.9.0.jar"/> <resource-root path="activemq-client-5.9.0.jar"/> <resource-root path="activemq-jms-pool-5.9.0.jar"/> <resource-root path="activemq-kahadb-store-5.9.0.jar"/> <resource-root path="activemq-openwire-legacy-5.9.0.jar"/> <resource-root path="activemq-pool-5.9.0.jar"/> <resource-root path="activemq-protobuf-1.1.jar"/> <resource-root path="activemq-ra-5.9.0.jar"/> <resource-root path="activemq-spring-5.9.0.jar"/> <resource-root path="aopalliance-1.0.jar"/> <resource-root path="commons-pool-1.6.jar"/> <resource-root path="commons-logging-1.1.3.jar"/> <resource-root path="hawtbuf-1.9.jar"/> <resource-root path="spring-aop-3.2.4.RELEASE.jar"/> <resource-root path="spring-beans-3.2.4.RELEASE.jar"/> <resource-root path="spring-context-3.2.4.RELEASE.jar"/> <resource-root path="spring-core-3.2.4.RELEASE.jar"/> <resource-root path="spring-expression-3.2.4.RELEASE.jar"/> <resource-root path="xbean-spring-3.14.jar"/> </resources> <exports> <exclude path="org/springframework/**"/> <exclude path="org/apache/xbean/**"/> <exclude path="org/apache/commons/**"/> <exclude path="org/aopalliance/**"/> <exclude path="org/fusesource/**"/> </exports> <dependencies> <module name="Javax.api"/> <module name="org.slf4j"/> <module name="javax.resource.api"/> <module name="javax.jms.api"/> <module name="javax.management.j2ee.api"/> </dependencies> </module>
要对模块进行配置我们需要编辑JBoss的配置文件，这里我从standalone-full.xml开始，因为它已经对HornetQ进行了配置(这节省了我们很多时间)。我们需要添加activeMQ资源适配器，把下面这一行
<subsystem xmlns="urn:jboss:domain:resource-adapters:1.0"/>
改成
<subsystem xmlns="urn:jboss:domain:resource-adapters:1.1"> <resource-adapters> <resource-adapter id="activemq-rar.rar"> <module slot="main" id=" org.apache.activemq "/> <transaction-support>NoTransaction</transaction-support> <config-property name="ServerUrl"> tcp://localhost:61616 </config-property> <connection-definitions> <connection-definition class-name="org.apache.activemq.ra.ActiveMQManagedConnectionFactory" jndi-name=" java:/AMQConnectionFactory " enabled="true" use-java-context="true" pool-name="AMQConnectionFactory"/> </connection-definitions> <admin-objects> <admin-object class-name="org.apache.activemq.command.ActiveMQQueue" jndi-name=" queue/JMSBridgeTargetQ " use-java-context="true" pool-name="target_queue"> <config-property name="PhysicalName"> JMSBridgeTargetQ </config-property> </admin-object> </admin-objects> </resource-adapter> </resource-adapters> </subsystem>
这样就创建了一个资源适配器，它使用了我们刚才创建的org.apache.activemq 模块，并连接到了运行在 tcp://localhost:61616上的远程ActiveMQ服务器上。它注册了一个连接工厂，名叫java:AMQConnectionFactory 使得我们可以连到远程服务器上，也创建了一个名为queue/JMSBridgeTargetQ的本地JNDI，该JNDI将被绑定到名为JMSBridgeTargetQ的ActiveMQ队列上。
下一步就是配置桥接器和本地队列。我们来编辑hornetq子系统，在hornetQ 服务器的定义后面，添加一个JMS桥接器。
<jms-bridge name="simple-jms-bridge"> <source> <connection-factory name=" ConnectionFactory "/> <destination name=" queue/JMSBridgeSourceQ "/> </source> <target> <connection-factory name=" AMQConnectionFactory "/> <destination name=" queue/JMSBridgeTargetQ "/> </target> <quality-of-service>AT_MOST_ONCE</quality-of-service> <failure-retry-interval>1000</failure-retry-interval> <max-retries>-1</max-retries> <max-batch-size>10</max-batch-size> <max-batch-time>100</max-batch-time> </jms-bridge> .
这样就创建了一个桥接器，它使用名为ConnectionFactory 的连接工厂来消耗本地队列里的消息，该队列对应的JNDI名字是queue/JMSBridgeSourceQ。随后它将使用一个名为AMQConnectionFactory 的连接工厂(它由我们的资源适配器创建)来把消息发送到JNDI名称为queue/JMSBridgeTargetQ的本地队列中。我们的资源适配器会把这映射到远程ActiveMQ队列中。我们也需要在该配置文件的jms-destinations部分里，创建一个名为JMSBridgeSourceQ 的本地队列。
<jms-destinations> <jms-queue name="JMSBridgeSourceQueue"> <entry name=" java:/queue/JMSBridgeSourceQ "/> <entry name="java:jboss/exported/jms/queue/JMSBridgeSourceQ "/> <durable>true</durable> </jms-queue> </jms-destinations>
这个队列有两个JNDI名称，使得它可以同时从内部(被桥接器)和外部(被客户端)访问到.
为了在ActiveMQ创建一个通信目的地, 我们通过bin/activemq开始命令启动ActiveMQ,并使用ActiveMQ hawtio控制台(http://localhost:8161/hawtio),通过浏览ActiveMQ -> Broker -> Localhost -> Queue并选择Create来创建一个新的JMS队列.在这个例子中设置队列名为JMSBridgeTargetQ.
这就是所有必需的配置文件.我们应该可以启动WildFly服务,看到桥接开始工作并连接到ActiveMQ.
13:43:11,959 INFO [org.jboss.as.remoting] (MSC service thread 1-2) JBAS017100: Listening on 127.0.0.1:9999 13:43:12,447 INFO [org.jboss.as.remoting] (MSC service thread 1-2) JBAS017100: Listening on 127.0.0.1:4447 13:43:12,452 INFO [org.jboss.as.connector.deployers.RaXmlDeployer] (MSC service thread 1-2) IJ020001: Required license terms for file:/home/matt/jboss-as-7.2.0.Final/modules/system/layers/base/org/apache/activemq/main/./ 13:43:12,511 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-2) JBAS010406: Registered connection factory java:/AMQConnectionFactory 13:43:12,522 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-2) JBAS010405: Registered admin object at java:/queue/JMSBridgeTargetQ 13:43:12,538 INFO [org.hornetq.core.server] (MSC service thread 1-1) HQ221024: Started Netty Acceptor version 3.6.2.Final-c0d783c 127.0.0.1:5455 for CORE protocol 13:43:12,550 INFO [org.jboss.as.connector.deployers.RaXmlDeployer] (MSC service thread 1-2) IJ020002: Deployed: file:/home/matt/jboss-as-7.2.0.Final/modules/system/layers/base/org/apache/activemq/main/./ 13:43:12,555 INFO [org.hornetq.core.server] (MSC service thread 1-1) HQ221024: Started Netty Acceptor version 3.6.2.Final-c0d783c 127.0.0.1:5445 for CORE protocol 13:43:12,558 INFO [org.hornetq.core.server] (MSC service thread 1-1) HQ221009: Server is now live 13:43:12,561 INFO [org.hornetq.core.server] (MSC service thread 1-1) HQ221003: HornetQ Server version 2.3.0.CR1 (buzzzzz!, 122) [1ef84f49-88d8-11e3-a2ac-f9239574df9d] 13:43:12,584 INFO [org.jboss.as.connector.subsystems.datasources] (MSC service thread 1-1) JBAS010400: Bound data source [java:jboss/datasources/ExampleDS] 13:43:12,600 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-1) JBAS010401: Bound JCA ConnectionFactory [java:/AMQConnectionFactory] 13:43:12,611 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-1) JBAS010401: Bound JCA AdminObject [java:/queue/JMSBridgeTargetQ] 13:43:12,683 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 58) JBAS011601: Bound messaging object to jndi name java:jboss/exported/jms/RemoteConnectionFactory 13:43:12,686 INFO [org.hornetq.core.server] (ServerService Thread Pool -- 60) HQ221005: trying to deploy queue jms.queue.JMSBridgeSourceQueue 13:43:12,733 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 60) JBAS011601: Bound messaging object to jndi name java:jboss/exported/jms/queue/JMSBridgeSourceQ 13:43:12,738 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 60) JBAS011601: Bound messaging object to jndi name java:/queue/JMSBridgeSourceQ 13:43:12,747 INFO [org.jboss.as.messaging] (ServerService Thread Pool -- 59) JBAS011601: Bound messaging object to jndi name java:/ConnectionFactory 13:43:12,916 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-2) JBAS010406: Registered connection factory java:/JmsXA 13:43:12,968 INFO [org.hornetq.ra] (MSC service thread 1-2) HornetQ resource adaptor started 13:43:12,969 INFO [org.jboss.as.connector.services.resourceadapters.ResourceAdapterActivatorService$ResourceAdapterActivator] (MSC service thread 1-2) IJ020002: Deployed: file://RaActivatorhornetq-ra 13:43:12,974 INFO [org.jboss.as.connector.deployment] (MSC service thread 1-1) JBAS010401: Bound JCA ConnectionFactory [java:/JmsXA] 13:43:13,286 INFO [org.jboss.messaging] (ServerService Thread Pool -- 58) JBAS011610: Started JMS Bridge simple-jms-bridge 13:43:13,439 INFO [org.jboss.as] (Controller Boot Thread) JBAS015961: Http management interface listening on http://127.0.0.1:9990/management 13:43:13,440 INFO [org.jboss.as] (Controller Boot Thread) JBAS015951: Admin console listening on http://127.0.0.1:9990 13:43:13,440 INFO [org.jboss.as] (Controller Boot Thread) JBAS015874: JBoss AS 7.2.0.Final "Janus" started in 9912ms - Started 169 of 228 services (58 services are passive or on-demand)
我们现在可以在JBoss的JMSBridgeSourceQ里面放置消息,它们最后将处于ActiveMQ的JMSBridgeTargetQ之中.
将桥接的消息流方向反过来也是可能的,尽管消费者的桥接和生产者的桥接并非同样至关重要.消费者的桥接,通常更倾向于直接从映射的JNDI名字(在queue/JMSBridgeTargetQ里面,由资源适配器创建)获取消息,而不是将消息放置在本地队列后,再从本地获取消息.
