基于WebSphere MQ的收发消息程序[Java编程]

摘 要:本文从以下几个方面简述了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

　　以上是“基于WebSphere MQ的收发消息程序[Java编程]”的内容，如果你对以上该文章内容感兴趣，你可以看看七道奇为您推荐以下文章：