1、IBM Software GroupWebSphere MQ技术交流之一基础篇IBM Software Group议程:消息中间件介绍 WebSphere MQ 基本概念 开发介绍 管理介绍 问题定位IBM Software Group消息中间件介绍IBM Software Group消息中间件与传统会话通信的比较消息中间件与传统会话通信的比较Socket:消息中间件IBM Software Group时间的独立性交互通信交互通信利用消息中间件(利用消息中间件(MQ)通信通信运行运行不运行不运行不运行不运行不运行不运行LogicalConnectionABAAAABBBB不运行不运行运行运行运
2、行运行IBM Software Group消息中间件 消息系统模型 点到点型(Point-To-Point)一对一关系 需要应用自行编程实现一对多工作方式发布/订阅型(Publish/Subscribe)支持事件驱动模型 基于点对点型实现了一对多关系复杂IBM Software GroupWebSphere MQ 功能描述功能描述 Common application programming interface Assured message delivery Time-independent processing Application parallelism Faster applicat
3、ion developmentIBM Software GroupWebSphere MQ 基本概念IBM Software GroupWebSphere MQ基本概念基本概念队列管理器MQIApplicationMQPUTApplicationMQGETSystem队列通道通道消息过过 程程 对对 象象 Queue Manger Queue Local Queue Remote Queue Transmission Queue Dead Queue Alias Queue Channel ListenerIBM Software GroupWMQ的消息的消息消消 息息=消消 息息 描描 述述
4、 符符+应应 用用 程程 序序 数数 据据 消消 息息 描描 述述 符符应应 用用 程程 序序 数数 据据-报文消息-不要求接收端应用程序产生应答消息-请求消息-要求接收端应用程序产生应答消息-应答消息-对前一条请求消息的应答-报告消息-报告一些预料到的或意外的事件MQMD-消息类型(MsgType)-失效时间(Expiry)-优先级(Priority)-持续性(Persistence)-消息标识(MsgId)-相关标识(CorrelId)-应用标识数据(ApplIdentityData)IBM Software Group本地排队应用程序A应用程序B队列管理器getgetputput应用队列
5、1应用队列2IBM Software Group远程队列本地系统本地系统 Application 1Transmission Queue(Local Queue)MQPUTQueue Manager:QM1远端系统远端系统Application 2Destination Queue(Local Queue)MQGETQueue Manager:QM2Message ChannelRemote QueueTCP/IPLU6.2NetBIOSDecNETAlias QueueDead Letter QueueIBM Software Group通道IBM Software Group传输队列头定义
6、IBM Software GroupTrigger触触 发发 方方 式式:FIRSTDEPTHEVERYIBM Software GroupCLUSTERCLUSTER1QMGRIPartial RepositoryIP Address:9.68.58.228Port:1416Full RepositoryQMGR1(Primary Repository Queue Manager)INPUTQIP Address:9.68.58.228Port:1414Full RepositoryQMGR2(Secondary Repository Queue Manager)INPUTQIP Addre
7、ss:9.68.58.228Port:1415TO.QMGR1TO.QMGRATO.QMGR2TO.QMGR1MQ ApplMQPUT INPUTQIBM Software GroupC/S结构IBM Software GroupWMQ开发介绍IBM Software Group开发环境IBM Software Group开发模式与流程 Binding&Client/Server C API MQCONN()complete code,reason code MQOPEN()MQGET()MQPUT()MQCLOSE()MQDISC()MQINQ()/MQSET()/MQPUT1()REASO
8、N CODE mqrc Java Native API and JMSIBM Software Group事务完整性IBM Software Group消息持久化定义IBM Software Group日志的类型IBM Software GroupWMQ管理IBM Software GroupWMQ管理 使用管理命令 产生crtmqm QM 启动strmqm QM 停止endmqm QM 使用MQSC工具执行runmqsc QMName 使用PCF或AI编程接口(JAVA/C接口)使用WMQ资源管理器 提供了基于Eclipse平台的图形配置和管理工具,从而替代了原来Windows-based
9、MQ资源管理器 Supportpac-MS03,IH03,HA相关IBM Software Group安装IBM Software GroupWMQ管理 浏览队列中的消息 使用WMQ提供的资源管理器查看队列中消息的内容 使用例程查看消息 amqsbcg 本地队列名 队列管理器名 使用WMQ的支持包supportPac IH03 MS03:WebSphere MQ配置收集工具配置收集工具 对对队列进行读/写操作 amqsput/amqsget/amqsputc/amqsgetcIBM Software GroupWMQ管理 管理队列管理器 显示队列管理器属性 DIS(DISPLAY)QMGR 修改队列管理器属性 ALT(ALTER)QMGR DEADQ(新死信队列名)管理本地队列 定义本地队列 define ql()显示本地队列属性 display ql()修改本地队列属性 alter ql()删除本地队列 delete ql()清除本地队列中的消息 clear queue()浏览队列中的消息 IBM Software Group基本配置步骤基本配置步骤建立队列管理器启动队列管理器创建对象:本地传输队列,远程队列,传送通道,接收通道,本地队列,死信队列启动通道侦听程序启动传送通道IBM Software Group配置实例IBM Software Group 谢谢!