集成 WebSphere Message Broker 与 Apache ActiveMQ

简介

Apache ActiveMQ（以下简称 ActiveMQ）是最流行、最强大的开源消息代理和消息服务器。它支持 JMS 1.1 和 J2EE 1.4。因为许多企业正在将开源技术集成到其消息基础架构中，所以本文将使用一个示例消息来展示如何配置 IBM® WebSphere® Message Broker（以下简称 Message Broker），使它能够以 JMS 提供程序的身份与 Apache ActiveMQ 集成。

为了展示 Message Broker 与 ActiveMQ 的集成，本文将使用集成即服务 (IaaS) 提供程序 Meddius，它使用 ActiveMQ 通过 JMS 提供了一个 HL7 解决方案。在下图中，ActiveMQ 通过 JMS 从 Meddius 接收 HL7 消息，将它们转发给 Message Broker（它使用自己的 Compute 节点来处理它们），然后将 HL7 事务写入一个数据库表中。

图 1

配置 ActiveMQ

1. 从 Apache ActiveMQ 网站 将 ActiveMQ V5.7 下载并安装到一台安装了 Message Broker Toolkit 的 Microsoft Windows 机器上。
2. 完成安装之后，启动 ActiveMQ 消息代理：运行批处理文件 apache-activemq-5.6.0\bin\activemq.bat。直到在控制台输出中看到以下消息：
   
   图 2
   
   
   
3. 打开一个浏览器窗口，然后在 URL 框中输入 http://localhost:8161/admin，以便打开 ActiveMQ 管理控制台：
   
   图 3
   
   
   
4. 单击 Queues 选项卡并创建两个队列：IN.Q 和d OUT.Q：
   
   图 4
   
   
   
5. 创建一个包含如下所示内容的 JNDI 属性文件，将它保存为 jndi.properties：

   java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory java.naming.provider.url = vm://localhost connectionFactoryNames = connectionFactory, queueConnectionFactory, topicConnectionFactory queue.jmsINQ = IN.Q queue.jmsOUTQ = OUT.Q

   
   

   jmsINQ 和 jmsOUTQ 分别对应于物理队列 IN.Q 和 OUT.Q 的 JMS 目标。

6. 也可使用一个名为 ConnectionFactory 的预定义连接工厂，为实际队列名称添加 dynamicQueues/ 作为前缀，以避免创建 jndi.properties 文件。

配置 WebSphere Message Broker

1. 将 ActiveMQ JAR 文件 activemq-all-5.6.0.jar 复制到 Message Broker 共享类目录。
2. 将上面创建的 jndi.properties 文件复制到 Message Broker 类目录。

配置消息流

1. 启动 Message Broker Toolkit 并创建一个消息流，如下所示：
   
   图 6
   
   
   
2. 这个消息流从 jmsINQ 读取消息，处理它们，然后将 HL7 事务写入一个数据库表中。
3. 配置 JMS Input 节点的 JMS 连接参数，如下所示：
   
   图 7
   
   
   

   也可定义一个 JMSProvider 可配置服务，将该节点配置为使用该可配置服务。如果选择创建动态队列而不使用 jndi.properties 文件，那么可以将连接工厂名配置为 ConnectionFactory。

4. 配置 JMS Input 节点的 Basic 选项卡，如下所示。如果选择创建动态队列，那么可以将源队列配置为 dynamicQueues/IN.Q。
   
   图 8
   
   
   
5. 将处理节点添加到 Compute 节点中，然后创建 SQL 查询，将已处理的事务写入 Database 节点中的某个数据库表中。
6. 编译消息流并创建一个 BAR 文件。
7. 如果代理正在运行，则停止它。
8. 启动代理。
9. 使用您创建的 BAR 文件来部署消息流。
10. 检查代理日志文件，确保已建立 JMS 与 ActiveMQ 的连接。

测试消息流

1. 在 ActiveMQ 管理控制台上，单击 Send 选项卡：
   
   图 9
   
   
   
2. 将一个示例 HL7 消息放在 IN.Q 上：
   
   图 10
   
   
   测试消息正文的详细内容如下所示：

   MSH|^~\&|EPIC|EPICADT|SMS|SMSADT|199912271408|CHARRIS|ADT^A04|1817457|D|2.5| PID||0493575^^^2^ID 1|454721||DOE^JOHN^^^^|DOE^JOHN^^^^|19480203|M||B|254 MYSTREET AVE^^MYTOWN^OH^44123^USA||(216)123-4567|||M|NON|400003403~1129086| NK1||ROE^MARIE^^^^|SPO||(216)123-4567||EC||||||||||||||||||||||||||| PV1||O|168 ~219~C~PMA^^^^^^^^^||||277^ALLEN MYLASTNAME^BONNIE^^^^|||||||||| ||2688684|||||||||||||||||||||||||199912271408||||||002376853

3. 检查数据库，确保 HL7 事务已经写入数据库表中。

结束语

本文介绍了如何配置 WebSphere Message Broker JMS 节点，使它能够作为一个 JMS 提供程序与开源的 Apache ActiveMQ 消息服务器进行通信。您可以扩展上述解决方案，添加一个 JMSOutput 节点来实现请求-响应场景。