副标题#e#
摘 要：本文从以下几个方面简述了IBM公司的贸易通信中间件WebSphere MQ，首先表明白动静、行列和行列打点器的意义，在此基本上通过图示叙述了WebSphere MQ在举办通信时所回收的通信机制，以及此通信机制和通信的各应用措施之间的干系。接着通过一个实例来说明在利用Java编写措施时，如何向行列写入动静。最后简朴的先容了一下MQ的利益及其成长前景。
要害词：通信中间件，行列，行列打点器，MQ
WebSphere MQ（以下简称MQ）是IBM公司享有盛誉的贸易通信中间件。它被世界范畴的很多大型企业遍及回收。它提供一个具有家产尺度、安详、靠得住的动静传输系统。MQ根基由一个动静传输系统和一个应用措施接口构成。应用措施利用MQ的API（动静行列接口MQI）函数和行列打点器（MQ运行时刻的措施）举办通信。行列打点器在事情时，它需要用到工具如行列和通道。同时，行列打点器也是一个工具。图1所示为MQ应用措施在运行时刻的图示。
图1 运行时刻的MQ1
动静是一个信息单位，它由两部门构成：从一个措施发往别的一个措施的应用措施数据以及动静描写符可能动静头。
动静描写符用来标识动静（message ID），同时它还包罗一些节制信息，如动静范例，动静逾期的时间，动静优先级等等。
一条动静的最大长度为100MB，默认的最大动静长度为4MB。动静的最大长度依赖于MQ的版本。MQ第五版支持动静的最大长度为100MB。
行列是一个安详的存储动静的处所，动静的存储一般是有顺序的。因为动静存放在行列中，所以应用措施可以以差异的速度、在差异的时间、差异的所在彼此独立的运行。
动静行列通信是应用措施之间举办通信的一种方法。应用措施在没有专有毗连可能物理毗连的环境下，可以或许通过向行列写入或读出动静举办通信，也即措施之间不是通过相互挪用，而是通过向行列发送数据来举办通信。在这种通信方法下，应用措施不需要具有并发性。对付异步的动静通信，措施发送方不需要专门期待已动员静的回覆，而是可以处理惩罚下一个事件。与之相对的是，同步动静通信在处理惩罚下一个事件之前必需期待已动员静的回覆。对付用户来说，底层的协议是透明的。用户只需要思量会话的措施或数据进口。
MQ应用于客户机/处事器模式可能漫衍式系统。应用措施可以事情在一个事情站上，也可以运行在差异平台的差异呆板上。应用措施具有很好的移植性，可以或许轻松的从一个系统可能平台转移到另一个系统可能平台。措施的编写支持多种语言，包罗Java。同样的，行列也适合很多差异的平台。
因为MQ通过行罗列办通信，所以它可以被当作是利用间接的措施–措施方法通信。措施员可以不指定吸收动静的方针措施的名称，可是可以指定吸收动静的行列的名称，每一个行列和一个措施相接洽，一个措施可以有一个可能多个吸收行列，并且可以有多个输出行列。输出行列包括着许多信息，这些信息可以是用来供处事器处理惩罚的，也可以是返还给发送动静的客户端的回回音息。
利用MQ举办通信时措施员不必担忧方针措施是否可用或是否忙碌，甚至不消思量方针呆板是否正常运行可能是否毗连上了。措施员发送动静给方针行列，而方针行列是和方针措施相接洽的，方针措施大概今朝不行用。不消担忧，MQ可以或许办理这种环境，假如需要，它甚至可以或许启动方针措施。
假如方针措施不行用，动静会逗留在行列中，稍后再被处理惩罚。行列可以在发送动静的呆板中，也可以在吸收动静的呆板中，这取决于两台呆板的两个系统之间是否可以或许成立毗连。应用措施可以成天运行，也可以回收引发机制，所谓引发，就是指当有一条或数条动静达到行列时自动启动某个措施。
图2 动静和行列1
#p#副标题#e#
图2说明白两个应用措施A和B之间是如何举办通信的。可以看到有两个行列，各行列内里存放着要吸收可能发送的动静。
措施和行列之间的方形图暗示MQI（动静行列接口API）。措施就是利用MQI来和MQ的及时措施–行列打点器举办通信的。
简朴地说：MQ的焦点部门是一个可以或许存储动静的处事器及一组可以或许滚动员静的历程，漫衍在多个系统（异地、异种平台）上的应用措施依靠这种机制来互换要处理惩罚的数据2。行列打点器作为一个处事器，把动静以靠得住的方法存储，纵然呆板产生妨碍从头启动后依然不会丢失，其靠得住级别与数据库处事器相等。行列打点器间通过出格的互换机制担保数据不会因为底层网络的妨碍而丢失，而且可以或许在多点间接力式地传送。
#p#分页标题#e#
JMS是J2EE中的一个接口尺度，为JAVA措施界说了一种尺度的利用动静互换数据的编程方法，但JMS自己并不能实现动静的传送，一个挪用JMS的应用措施发出动静挪用后，详细的动静传送事情还需要底层的动静中间件来执行传送事情。JMS的浸染就是使应用措施开拓人员不需要体贴底层的传送软件的种类，同一段措施，既可以用MQ传送，也可以用其他动静中间件来传送，如WEBLOGIC内含的具有动静中间件成果的部件。
MQ软件提供一个JAVA软件包，内里有JMS类库，和一套MQ的类库。不熟悉MQI编程要领的措施员可以用JMS，较量熟悉MQI编程要领的措施则可以用MQ类库来编程。下面的小措施是利用Java实现从行列打点器QM_SERVER中的行列INITQ写入或读出动静。
package transfer;
import com.ibm.mq.*;
public class SendMSG1
{
private MQQueueManager qMgr;//界说一个行列打点器变量
public static void main(String args[])
{
new SendMSG1();
}
public SendMSG1()
{
MQEnvironment.hostname="192.168.1.18";//当地IP
MQEnvironment.channel="CHANNEL1";//用来通信的通道
MQEnvironment.CCSID =1381;
try{
qMgr=new MQQueueManager("QM_SERVER");//行列打点器名称
int openOptions=MQC.MQOO_INPUT_AS_Q_DEF|MQC.MQOO_OUTPUT|MQC.MQOO_INQUIRE;
MQQueue queue=qMgr.accessQueue("INITQ",openOptions,null,null,null);
//成立毗连
MQMessage hello=new MQMessage();//要写入行列的动静
try{
hello.format=MQC.MQFMT_STRING ;
hello.characterSet=1381 ;
hello.writeString("这是测试！");
}
catch(java.io.IOException ex)
{}finally{};
MQPutMessageOptions pmo=new MQPutMessageOptions();
for (int i=1;i<=5;i++)//将动静依次写入行列
{
hello.expiry=-1; //配置动静用不外期
queue.put(hello);//将动静放入行列
}
queue.close() ;//封锁行列
qMgr.disconnect() ; //断开毗连
}
catch(Exception ex)
{}
finally{};
}
}
措施的运行功效如下图3所示：
图3 措施运行功效界面
这个例子仅仅是向行列INITQ写入了5条沟通的动静，虽然，在实际应用中，动静大概是多种多样的，假如要传送数据库的内容，则可以在写入动静时，用一些非凡的标记来将各字段的数据区分隔，那么在动静读出时，也可以按照此非凡的标记来读取数据。依据同样的步调：和行列打点器成立毗连-从行列读打动静—封锁行列—断开毗连，可以用Java写出如何从行列中读出动静。
MQ有很多显著的利益，好比借住在差异的平台上利用沟通的应用措施接口，它能轻松的实现跨平台通信，从而可以或许使开拓人员避开网络的巨大性；好比它对动静的处理惩罚不依赖于时间，在动静建设和发送时，不受时间的限制，增加了处理惩罚的机动性……
总之，MQ的特点以及IBM公司在企业应用规模所支付的庞大尽力，使得它具有极强的生命力。此刻，大量的当局部分、金融、电信和企业用户利用WebSphere MQ作为企业电子商务的基本平台。有来由相信，跟着当局办公自动化、企业信息化的脚步的不绝前进，WebSphere在中国市场上必然会成为一颗刺眼的明星。
