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