使用JMS接口接入WebSphereMQ消息.docVIP

在你的应用程序中利用IBM WebSphere MQ消息中间件提供Java消息服务开放接口。 　　IBM WebSphere MQ(WMQ)是一套面向消息的中间件(message-oriented middleware，MOM)，通过使用消息和队列简化应用程序之间的通信，WMQ支持点到点的和发布/订阅消息，支持多种平台，包括Windows、AIX、HP-UX和Sun Solaris，它特别适合目前的异构计算环境。 　　对于Java开发者而言，WMQ为Java应用程序提供了两种接口： 　　1.为Java提供MQ基础类 - 一个基于WMQ本地接口的Java接口。 　　2.MQ JMS - Java消息服务(Java Messaging Service ，JMS)1.1接口的实现。 JMS通过开启Java应用程序发送和接收消息扩展了Java的互操作性，JMS应用程序可以使用点到点或发布/订阅模式进行消息交换。 本文描述的是使用WMQ和JMS进行开发的过程，重心集中在点到点消息，通过下面几步教你如何使用Java类编写JMS接口： 　　1.创建WMQ对象 　　2.创建JMS管理对象 　　3.解释JMS代码 　　4.运行一个实例类发送消息和从WMQ接收消息 　　WMQ安装 　　本文使用的是winxp上的MQ 版本 7(可以从/developerworks/downloads/ws/wmq/learn.html下载试用版)，在windows上的安装是非常简单的，一路默认就可以完成安装。 如果你还没有使用过WMQ也不要担心，你可以使用基于Eclipse的WebSphere MQ管理器，它是一个简单的用于管理WMQ的图形工具。 　　 创建MQ对象：队列管理器和队列 队列是用来存储消息的，直到应用程序处理完毕才释放，队列管理器拥有并管理队列，要创建一个队列管理器和队列，按以下步骤启动WebSphere MQ管理器：开始?所有程序? IBM WebSphere MQ ? WebSphere MQ Explorer。图1显示了启动WebSphere MQ管理器时的样子。 图1 WebSphere MQ 管理器 　　在MQ管理器中执行下列操作创建一个队列管理器： 　　1.在导航视图下，右击“队列管理器”，选择“新建--队列管理器”，启动创建队列管理器向导。 　　2.在第一步中输入队列管理器的名字“TestMQ”，点击“下一步”。如图2所示。 图2 创建队列管理器，第一步：输入队列管理器名称 　　3.在第二步和第三步都点击“下一步”，进入第四步，确定选中了“创建一个TCP/IP监听器”，然后输入一个未使用的端口号，点击“完成”。如图3所示。 图3 创建队列管理器，第四步：检查队列管理器的监听器端口号。 　　接下来创建两个队列：IN.QUEUE 和 OUT.QUEUE。你就可以将消息写入IN.QUEUE，从OUT.QUEUE读取消息。 　　1.在TestMQ下，右击“队列”?“新建”?“本地队列”启动“新建本地队列”向导。 　　2.在名称区域，输入IN.QUEUE，点击“完成”。如图4所示。 图4 创建队列向导：输入队列名称，其它属性值保留默认值 　　3.重复上面的步骤创建好队列OUT.QUEUE。 　创建JMS管理对象 　　JMS定义了一个通用的接口来发送和接收消息，只要与之通信的程序兼容JMS即可，点到点的JMS接口是： 　　1. javax.jms.QueueConnection - 这个接口提供一个到JMS提供程序的连接，用于创建会话对象。 　　2.javax.jms.QueueSession - 这个接口为产生和消耗消息提供上下文呢，包括创建QueueSender和QueueReceiver的方法。 　　3. javax.jms.QueueSender - 这个接口用于向队列发送消息，javax.jms.QueueReceiver用于从队列接收消息。 　　为了让你的代码可以在不同的消息提供程序间有良好的移植性，你必须在你的应用程序中使用javax.jms中的标准JMS接口，所有特定厂家的信息都封装在javax.jms.QueueConnectionFactory 和 javax.jms.Queue中，这些管理对象可以使用厂家提供管理工具进行构建，存储在JNDI命名空间中，JMS应用程序可以从命名空间中检索这些对象，这时就不需要知道是哪个厂家提供的了。 　　按照下面的步骤使用Websphere MQ管理器创建管理对象，存储在基于文件的目录下： 　　1.在JMS-管理对象上点击右键?添加初始上下文。 　　2.在屏幕1上： 　　 为“JNDI存储在哪里”选择“文件系统” 　　 在关联目录处，输入C:\JNDI-Directory(前提是这个目录已经存在