浅谈消息中间件IBM WebSphere MQ

Websphere MQ入门教程——使用IBM Websphere MQ提纲前言今天，大多数企业都希望他们的硬件和软件提供者不只受限于一家厂商，相反，大家普遍认为应当面向多家厂商能够运行多种软件的多种硬件平台，这些硬件平台既可以是大型机，也可以是笔记本计算机。

其中包括传统的中央集中式系统，通常指大型企业所采用的大型机，部门级小型计算机和个人用个人计算机或工作站。

通常这些平台是在“混乱”中发展起来的，当时它们的成长既有独立性又有偶然性。

混乱造成的结果是由企业“玻璃房子”控制的清静、秩序井然的世界退化成了一个个独立而分散的部门，并要求任务能够满足其独立而分散的需求。

有些公司一直在寻求一种成熟的策略，以便在企业范围内扩展应用和数据，使其距最终用户最近。

这种需求在设计时，存在许多限制，因为目前的交互式主要是同步形式，它要求对方一直处于通讯状态，这必然会大大增加网络代价。

目前，许多企业都是由一些相对于整体业务问题而孤立的解决方案所组成的自动化孤岛。

在信息共享的大环境下，如果能在这些孤岛之间架起桥梁，那么效率和利润都将得到提高。

从我们与不同行业客户与服务提供者广泛接触的经验来看，这种沟通非常必要，而且正变得越来越重要。

有些公司已经找到了连接网络若干个部分的解决方案，它们或者是自行开发的或者只有较窄的应用领域。

如IBM用户事务处理的CICS就有这样的连接功能，但数据处理软件的设计、维护和开发通常都非常昂贵。

因此需要一种通用软件，它能够集成多个运行于供应商所提供的系统上的应用程序。

这种软件不仅成本不高，而且可以可靠地处理很高的吞吐量，消息中间件正是解决这种互连问题的解决方案。

商业消息中间件的出现保证了消息传输的可靠性，高效率和安全性，同时也减少了系统的开发周期。

目前应用最多的消息中间件产品为IBM Websphere MQ。

本文就针对Websphere MQ的体系结构、管理和开发进行详细的阐述，希望对读者有所帮助。

TongLINK/Q与MQ对比分析报告1.产品简介1.1WEBBSPHERE MQWebSphere MQ是IBM公司的一款消息中间件产品，具有非常大的知名度和市场占有率。

1.2TONGLINK/QTongLINK/Q是东方通科技自主研发的一款消息中间件产品，在国内拥有非常大的市场占有率，当前最新版本为V7.0。

TOngLINK/Q7.0提供了如下新的功能特性：⏹多核心，处理效率更高核心进程数可灵活配置，极大提高处理效率，可充分利用系统资源（CPU、内存）⏹网络结构更加灵活节点间可灵活建立连接关系，适应性更强⏹队列分组，管理效率提高队列更清晰，不会相互干扰，管理效率更高设立逻辑队列，减少系统开销逻辑队列不占用系统资源，可避免多队列时，系统开销过大⏹系统可动态调整与扩展在线调整配置参数，即时生效，无需重新启动系统⏹B/S远程配置管理可在任何地点通过浏览器登录管理界面，进行系统管理和监控，维护方便⏹完整的发布订阅支持跨越节点进行发布订阅⏹支持组消息保证一组消息都达到目的地后才统一提交给应用，确保业务处理对消息顺序的要求⏹支持消息事务支持消息传输过程的事物控制，可以包含发送、接收或接收发送混合事物，任务统一提交或回滚，保证事物的一致性、完整性⏹支持消息浏览用户可通过浏览功能，查看有无属于自己的消息，再决定是否接受消息，使用更加灵活⏹管理工具更加强大用户可通过工具对系统的运行过程进行实时的监控，对系统对象进行修改、删除、停止等操作⏹全面支持JMS1.1⏹支持灵活应用触发⏹提供系统配置接口2.技术分析为了准备掌握和了解三个产品在功能方面的差异，以下将针对具体的功能细节进行对比。

2.1功能对比3.分析与技术总结3.1T ongLINK/Q与MQ比较，T ONGLINK/Q自身独特的技术优势⏹简单易用的文件传输使用TongLINK/Q进行文件传输时，用户只需提供文件名和目的地，TongLINK/Q将会将文件自动传递到目标地址。

WebSphere MQ一小时快速入门一、什么是中间件中间件是处于应用软件和系统软件之间的通用服务，是一类以自己的复杂换取企业应用简单化的可复用的基础软件。

中间件主要分为消息中间件、应用服务器中间件、交易中间件等等。

而今天，笔者晓奕主要向大家介绍的正是IBM厂商的消息中间件WebSphere MQ。

二、WebSphere MQ简介Websphere MQ是IBM的商业消息通讯中间件(Commercial Messaging Middleware)。

Websphere MQ提供一个具有工业标准、安全、可靠的消息传输系统。

它可实施在广泛的IBM和非I BM平台上，它的功能是控制和管理一个集成的商业应用，使得组成这个商业应用的多个分支程序(模块)之间通过传递消息完成整个工作流程。

通过使用WebSphere MQ用户可以简单方便的开发出可靠、高效的分布式应用系统。

三、WebSphere MQ主要对象消息是对使用它的应用程序有意义的以字节为单位的字符串。

消息可以用来实现在相同或不同平台上应用程序间的通信。

队列是用于存储消息的数据结构。

按功能可以分为本地队列、远程队列、传输队列、模板队列、别名队列、死信队列等等。

队列管理器在WebSphere MQ中队列管理器是基本的软件系统，队列管理器可看成是队列和其他对象的容器。

通道是一种提供从一个队列管理器到另一个队列管理器的通信路径。

它又叫消息通道，用在分布式的队列把消息从一个队列管理器发送到另一个队列管理器。

按照定义可以分为发送通道(Sender)、接收通道(Receiver)、服务器通道(Server)、请求器通道(Requester)等。

MQSC命令是用来管理队列管理器对象，包括队列管理器本身、通道、队列和进程定义。

可以使用 runmqsc 向队列管理器发出 MQSC 命令。

四、WebSphere MQ体系结构WebSphere MQ的体系结构如图所示，它是由许多对象所组成的，主要包括队列管理器、队列、通道、进程定义等对象。

IBMWebSphereMQ几个特性的应用IBMWebSphereMQ消息中间件有很多的特性和优点，使用IBMWebSphereMQ可以简化和优化消息通讯的应用设计。

为了满足用户各种不同的应用的通讯需求，IBMWebSphereMQ采用了大量业界领先的技术，并拥有许多先进的功能，其中很多是其他厂商所无能为力的。

将这些技术和功能应用到客户的通讯系统之中，可以简化应用逻辑，优化系统架构，从而提高整个系统的可靠性、可用性和可扩展性。

下面将介绍怎样使用IBMWebSphereMQ的一些特性来简化程序。

1.利用消息的COA机制处理接收回执在通讯应用处理中，如果数据的发送方需得到接收方结果收妥的确认后方可进行。

我们可以利用MQ的消息的COA （ConfirmOnArrival）机制来实现。

所谓COA机制，是指当消息从源地址发往目的地址时，当消息到达目的队列之后，由MQ系统本身自动产生一个应答，返回给源地址，返回的消息的内容可以是原始消息的前100个字节或者是原始消息的全部内容。

当从发送方向接收方发送数据时，在消息中设置COA标志，当消息到达接收方时，接收方的MQ系统会自动产生一个应答，反馈给发送方，发送方只有在收到此应答消息时，才对接收行进行相应业务处理。

2.利用MQ机制实现网络超时和业务处理超时处理在有些客户业务系统中，数据的发送和接收有两种情况需要特殊处理，一种是发生网络故障，数据没有在指定的时间内到达接收方情况下的超时处理；另一种情况是，在指定时间内，尚未发出的数据要从MQ的队列清除，对此两种情况的解决方案如下：网络故障，数据没有在指定的时间内到达接收方情况下的超时处理把数据从发送方送到接收方，若发生网络故障，数据将无法在规定的时间内被发出，为此我们可以采用如下方案，在方案中我们可以利用到MQ的以下三种机制：MQ消息生命周期：MQ的消息可以设定生命周期，在消息指定生命周期到达时，可以自动将消息删除或取出进行其他处理。

WebSphere MQ的工作原理介绍Websphere MQ是IBM的商业通讯中间件(Commercial Messaging Middlew are)。

Websphere MQ提供一个具有工业标准、安全、可靠的消息传输系统。

它的功能是控制和管理一个集成的商业应用，使得组成这个商业应用的多个分支程序(模块)之间通过传递消息完成整个工作流程。

Websphere MQ基本由一个消息传输系统和一个应用程序接口组成，其资源是消息和队列(Messaging and Queuing)。

消息：消息就是一个信息单元，这个信息单元可以是一个请求（Request message），也可以是一个应答(Reply message)，或者是一个报告(Report message)或一份报文(Datagram messge)。

一个消息包含两个因素——消息描述(用于定义诸如消息传输目标等)和数据消息(如应用程序数据或数据库查询等)。

程序之间的通信通过传递消息而非直接调用程序。

队列:一个安全的存储消息的地方，消息的存储一般是顺序的，队列是消息分阶段地传送和接收。

因为消息存放在队列中，所以应用程序可以相互独立的运行，以不同的速度，在不同的时间，在不同的地点。

消息传输系统：用于确保队列之间的消息提供，包括网络中不同系统上的远程队列之间的消息提供。

并保证网络故障或关闭后的恢复。

应用程序接口：应用程序和消息系统之间通过Websphere MQ AP I实现的接口Websphere MQ AP I在所有Websphere MQ平台上是一致的。

AP I只有14个调用，2个关键动词：发送(P UT)和接收(GE T)。

WebSphere MQ是一个消息队品，专门负责在各种平台间传送数据，能保证数据在不稳定的数据线路上传送时不会丢失或重复，本文主要向大家介绍WebSphere MQ的工作原理.适用操作系统：跨平台WebSphere MQ 是IBM用于通讯的中间件产品，它为分布式环境下进行程序到程序之间通信提供了灵活、快速并且易于使用的解决方法。

浅谈消息中间件IBM WebSphere MQ
王建;江婷
【期刊名称】《微型机与应用》
【年(卷),期】2010(029)005
【摘要】详细地论述了MQ的基本概念、工作原理、基本配置及其在实际中的应用.
【总页数】4页(P6-8,11)
【作者】王建;江婷
【作者单位】中国科学技术大学,苏州软件学院,江苏,苏州,215123;上海南洋高科技有限公司,上海,201400
【正文语种】中文
【中图分类】TP319
【相关文献】
1.IBM消息中间件WebSphere MQ的应用 [J], 高宁
2.用消息中间件Websphere MQ获取OPC应用的实时数据方法 [J], 张江洋;胡战虎
3.IBM消息中间件WebSphere MQ的应用 [J], 高宁
4.基于IBM WebSphere MQ的商业银行数据推送技术的应用 [J], 杜丛强;曾庆妍;
5.基于Zabbix实现对消息中间件IBM WebSphere MQ队列及通道的自动发现与监控 [J], 欧杰
因版权原因，仅展示原文概要，查看原文内容请购买。

WEBSPHERE MQ实践最近以来，工作中一直在使用WebSphere的MQ产品，切实感觉到MQ作为消息中间件，在消息传递方面的强大功能，本文将详细描述MQ通讯的原理，并结合实例向大家展示MQ在java开发方面的一些技巧，由于很少在网上看到关于MQ比较复杂一点的通讯实例，抛砖引玉，希望对大家有所帮助。

简介WebSphere MQ是一种面向对象的消息中间件，用于异构应用之间的消息传递，应用程序通过MQ接口进行通讯，WebSphere MQ支持多协议消息通讯，可以最大限度地简化网络编程，同时MQ支持多种平台，对消息支持交易式的提交和回滚，是一款非常不错的产品。

本文首先将介绍MQ的通讯的一些知识，然后结合java开发实例，着重描述MQ在两个队列管理器的同步通讯过程，其中包括MQ的安装、配置、相关java代码开发等。

MQ基础知识MQ的通讯过程中一般会用到这么几个组建：队列管理器、队列、通道，接下来就本文会使用到的一些基础感念做简单介绍。

消息消息就是MQ通讯的内容，是应用程序之间传递的信息载体，消息（按照WebSphere MQ 队列管理器启动后，是否仍然保持）分为持久消息和非持久消息，一般把异步通讯配置为持久消息，同步通讯配置为非持久消息，本文有些地方也将消息称为报文。

队列队列就是消息的寄存器，在通讯时，消息被添加到队列中后发送出去。

队列分为本地队列、远程队列、别名队列等，本地队列是当前队列管理器中需要配置的，区别于本地队列，远程队列是指向远程队列管理器中的本地队列，本地队列又分为本地初始化队列、传输队列、目标队列、死进队列等，初始化队列作为消息触发，传输队列用来暂存待传输的消息，如果消息没有发送出去，最终会存放在死进队列中。

本文中主要本地初始化队列、本地传输和远程队列。

队列管理器队列管理器也就是MQ的运行环境，维护和管理消息队列，向应用程序提供消息服务。

应用程序连接到队列管理器的监听端口，访问队列管理器的队列，接收并发送消息，本文将建立2个队列管理器，模拟2个不同物理地址的MQ通讯，分别用来进行消息（报文）的发送端和接收端。

1 WebSphere MQ出现的背景许多企业随着自身规模不断壮大和信息化建设的加快，会出现不同部门有不同的应用系统，不同子系统完成不同的功能，但各个系统之间往往互不相连或联系很少，而形成诸多内部“信息孤岛”的现象。

因此，每次互联都需要单独设立1个项目，将双方的应用系统进行改造。

浪费了许多人力物力，直接影响企业内部整个运作，影响企业的快速决策，对企业长期的发展形成瓶颈。

面对这种情况，如何使企业像是一个有机的生物体，有能力进行自身的新陈代谢，自我更新，各个子系统分工明确，互相之间又具备有机的联系。

系统的整合是个好办法，换句话说，就是不需要改造各个子系统，而是借助某种中间件来加强子系统间的联系。

IBM WebSphere MQ就是这样一个优秀的用于应用系统间联系的软件。

它是IBM的商业通信中间件，由1个消息传输系统和1个应用程序接口组成，其资源是消息和队列。

它提供一个具有工业标准、安全、可靠的消息传输系统，实现控制和管理集成的商业应用，使得组成这个商业应用的多个子系统之间通过传递消息完成整个工作流程。

通过消息传递，将不同子系统有效地联系起来，每个子系统都可以对外提供自身的功能，其中消息是应用系统之间请求、应答和中间结果的载体。

不断流动的消息将松耦合关系的应用系统串起来，使它们之间的关系变成了功能叠加。

WebSphere MQ可以屏蔽不同的通信协议之间的差别，可以最大限度地简化网络编程的复杂性；同时，它支持多种平台，对消息支持交易式的提交和回滚。

2 WebSphere MQ的基本概念[1]2.1 消息消息是WebSphere MQ中最小的概念，是一段数据，是应用程序之间传递的信息载体。

消息分为持久和非持久消息；可以是1个请求、1个应答、1个报告或1份报文等。

1个消息大致分成两部分：消息数据头和应用数据体。

前者是对消息属性的描述，后者是应用间传送的数据消息，可以是字串、数据结构甚至二进制数据。

2.2 队列队列可以看作是用于存储消息的容器，并且存储是有顺序的。