WebSphere+MQ入门培训教程(PPT).ppt

2023-3-201WebSphere MQ入门培训教程2023-3-202引言v复杂的网络和应用环境v通信的种类vWebSphere MQ的特点2023-3-203现实环境2023-3-204通讯的种类2023-3-205WebSphere MQ的特点2023-3-206索引v1：WebSphere MQ概念和原理v2：WebSphere MQ应用设计v3：WebSphere MQ 方案设计案例介绍2023-3-207： WebSphere MQ概念和原理v1.1概念1.1.1队列管理器1.1.2消息1.1.3队列1.1.4通道1.1.5进程定义1.1.6其它v1.2工作原理2023-3-2081.1.1队列管理器v与数据库的比较v队列管理器构建了独立的WebSphereMQ的运行环境。用来维护和管理消息队列，提供定义、配置、管理、调度以及各种服务功能。2023-3-209与数据库的比较2023-3-2010队列管理器2023-3-20111.1.消息v本质上就是一段数据：消息描述块和应用数据体。消息描述块：是对消息的描述，例如：永久消息。应用数据体：字串，数据结构，二进制。内容（文本，文件，声音，图像）2023-3-2012消息2023-3-20131.1.队列v队列可以看成一个容器，用于存放消息。v队列分为：本地队列，远程队列，别名队列，模板队列。本地队列分为：普通队列，传输队列，初始化队列，目标队列，死信队列，应答队列，命令队列。2023-3-2014队列2023-3-20151.1.通道v通道：一种单向的点对点的通信连接。v通道种类：消息通道和MQI通道。2023-3-2016通道类型通道类型分为：SDR：握手协议的主动方，消息的发送方。RCVR：握手协议的被动方，消息的接收方。SVR：握手协议的主/被动方，消息的发送方。RQSTR：握手协议的主/被动方，消息的接收方。CLNTCONN：Client-Server连接，定义客户端连接定义表，握手协议的主动方，消息的发送方。SVRCONN：Client-Server连接，定义服务器端连接，握手协议的被动方，消息的接收方。CLUSSDR：群集中使用，握手协议的主动方，消息的发送方。CLUSRCVR：群集中使用，握手协议的被动方，消息的接收方。2023-3-2017消息通道 2023-3-2018MQI通道2023-3-20191.1.其它v名称列表v分布列表多家发送v进程定义触发机制2023-3-2020触发机制2023-3-20211.工作原理v核心：存储转发。vPUT和GETv互连通信消息通道消息路由(队列管理器名和队列名)消息传输(MQMD+MQXQH+Body)2023-3-2022本地传递消息2023-3-2023跨网络传递消息2023-3-2024实现双向传输2023-3-2025：WebSphere MQ应用设计v2.1MQ API和数据结构v2.2发送消息设计v2.3接收消息设计v2.4容错设计2023-3-20262.1 MQ API和数据结构vMQ APIvMQI Callv一些数据结构2023-3-2027WebSphere MQ API2023-3-2028MQI Call2023-3-2029MQI的一些数据结构2023-3-20302.2发送消息设计v消息属性v远程队列v应答队列(动态队列)v格式转换v消息分组和分段2023-3-20312.2.1 消息属性v消息标识(MsgId,CorrelId,GroupId)v消息类型(requests,replies, datagrams,reports)v消息格式(Format,Encoding,CodedCharSetId)Format表示消息体的数据结构2023-3-20322.2.2 远程队列2023-3-20332.2.3 本地应答队列2023-3-20342.2.3 远程应答队列2023-3-20352.2.3 发送回执到应答队列2023-3-20362.2.4 Encoding整数的高低字节安排、浮点数的精度和幂的安排，等等。2023-3-20372.2.4 CodedCharSetId指消息的字符所属的文字集，如单字节英语码，双字节汉语码等。2023-3-20382.2.4 Format Fieldv内置格式Text stringsMQ定义的消息格式vTrigger MessagevEvent Message自动转换v消息转换出口应用自定义格式内置格式转换失败2023-3-20392.2.4 格式转换应用vPut messageMQENC_NATIVE -for native encodingMQCCSI_Q_MGR -for the same CCSID as the queue managervPut all messages with a format nameMQFMT_STRINGvMQGET调用设置MQGMO_CONVERTv或者在发送通道设置CONVERT(YES)2023-3-20402.2.5 消息分组和分段v分组v是指从应用逻辑的角度，把若干本身完整、在应用逻辑上又具有相关性的消息从逻辑上分为一组进行处理。 v分段v指把某个大消息从物理上分为若干个消息片段，比如在处理大文件传输时，可以采用消息分段技术。 2023-3-2041消息分组2023-3-2042消息分段2023-3-20432.3接收消息设计v使用MsgId,CorrelId匹配消息MQMO_MATCH_MSG_ID,MQMO_MATCH_CORREL_ID或者MQMO_MATCH_MSG_TOKENMQGMO.Options=MQMO_NONEv等待接收消息MQGMO.Options=MQGMO_WAIT,MQGMO.WaitInterval为等待时间MQGMO.Options=MQGMO_NO_WAITv浏览消息MQGMO_BROWSE_FIRST/NEXTMQGMO_BROWSE_MSG_UNDER_CURSORMQGMO_LOCK2023-3-2044MsgId and CorrelId2023-3-2045MsgId,CorrelId和应用并行2023-3-2046检索消息 2023-3-2047MSGID,CORRELID举例 2023-3-2048Wait message2023-3-2049浏览消息2023-3-20502.4容错设计v出错处理检查完成码和原因码注意关闭打开对象句柄，最后断开与队列管理器连接。v报告消息v处理死信消息2023-3-2051错误处理2023-3-2052report optionsv队列管理器产生的Reports Exception异常Expiration超时COA成功到达COD成功阅读v应用程序产生的ReportsPAN处理成功NAN处理失败QUIT2023-3-2053Feedback Field ValuesvMQFB_NONEvMQFB_EXPIRATIONvMQFB_COAvMQFB_CODvMQFB_PANvMQFB_NANvMQFB_QUIT.2023-3-2054Msgid,Correlid,Reports and Replies2023-3-2055死信队列vWebSphere MQ放消息到死信队列：MCA，如果远程消息不能交付MCA，如果发送消息不能数据转换Trigger Monitor，如果触发消息失败2023-3-2056死信队列2023-3-20573：案例介绍2023-3-2058网络拓扑2023-3-2059运用的MQ技术v通讯方式服务器之间通讯 CCPC-NPC群集功能 NPCvload balancevFail overv消息特性消息分段Report选项优先级失效v队列远程队列，传输队列，接收队列，死信队列，错误队列（应用设计）v触发机制 first通道启动接收应用启动2023-3-2060流程图CCPCNPCQMAQMBQMGWQM2900QMMBFECICS CLIENTCCPCOracleOracleCICSOS/390TXSeries/CICSTXSeries/CICS2023-3-2061系统架构2023-3-2062MQ集群设计CloudQM0000BREPOS(NPC)QMGW(ALIASQM0000)QR(5210_1)RNAME(5210_1)RQMNAME(QM5210)CLUSTER(NPC)QR(QM0000)QL(QM5210)USAGE(XMITQ)QR(1000_1)RNAME(1000_1)RQMNAME(QM1000)CLUSTER(NPC)QL(QM1000)USAGE(XMITQ)QL(0000_1)CLUSTER(NPC)QR(0000_1)RNAME(0000_1)RQMNAME(QM1000)QL(QM1000)USAGE(XMITQ)QL(5210_1)QM5210CHL(0000.5210)CHL(5210.0000)QR(0000_1)RNAME(0000_1)RQMNAME(QM1000)QL(QM1000)USAGE(XMITQ)QL(1000_1)QM1000CHL(0000.1000)CHL(1000.0000)QM0000AREPOS(NPC)QL(0000_1)CLUSTER(NPC)CHL(TO_QM0000B)CLUSTER(NPC)CHL(TO_MQGW)CLUSTER(NPC)CHL(TO_QM0000A)CLUSTER(NPC)CHL(TO_MQGW)CLUSTER(NPC)CLUSTER(NPC)2023-3-2063群集v为了简化点对点通讯模式中的系统配置，MQ提供Cluster(群集)的解决方案。群集类似于一个域(Domain)，群集内部的队列管理器之间通讯时，不需要两两之间建立消息通道，从而大大简化了系统配置。此外，群集中的队列管理器之间能够自动进行负载均衡，当某一队列管理器出现故障时，其它队列管理器可以接管它的工作，从而大大提高系统的高可靠性。 2023-3-2064群集2023-3-2065Load-balance2023-3-2066Fail-over2023-3-2067总结vMQ的概念和原理 （系统架构）v应用的设计MQ API和数据结构发送应用-远程队列，消息结构接收应用-匹配发送应用容错设计-应用的完整性