MQ初级入门

MQPrimerAuthor:Esun.YangDate:2010-09-08ObjectUnderstandwhatisMQMastertheBasiccomponentsCandosomeofBasicMQAdministrationCandosomeofSimpleMQproblemdeterminationAgendaMQProductBriefingMQBasicConceptMQOverviewMQInstallationMQSimpleAdministrationMQSimpleTroubleshootingMQProductBriefing在分布式计算环境中，为了集成分布式应用，开发者需要对异构网络环境下的分布式应用提供有效的通信手段。WebSphereMQ本质上是一种消息中间件，用于保证异构应用之间的消息传递。应用程序通过MQ接口进行互连通信，可以不必关心网络上的通信细节，从而将更多的注意力集中于应用本身。消息可靠传递事务处理能力安全要求MQBasicConcept消息(Message)1.在MQ中，我们把应用程序交由MQ传输的数据定义为消息2.消息构成：1.消息描述符(Messagedescriptor或MessageHeader)，描述消息的特征，如：消息的优先级、生命周期、消息Id等；2.消息体(MessageBody)，即用户数据部分。在MQ中，消息分为两种类型，非永久性(non-persistent)消息和永久性(persistent)消息MessageHeaderMessageBodyMessagePropertiesMoreInfoaboutMessagedescriptorDetailplsref=Message%20messag%20descriptor%20ExpiryPriorityPersistenceMsgIdCorrelIdMQBasicConcept队列（Queue)1.队列是消息的安全存放地，队列存储消息直到它被应用程序处理。可以简单地把队列看成一个容器2.消息队列以下述方式工作：1.程序A形成对消息队列系统的调用，此调用告知消息队列系统，消息准备好了投向程序B；2.消息队列系统发送此消息到程序B驻留处的系统，并将它放到程序B的队列中；3.适当时间后，程序B从它的队列中读此消息，并处理此信息。MQBasicConcept3.队列种类：本地队列、远程队列、模板队列、动态队列、别名队列等本地队列又分为普通本地队列和传输队列远程队列是目的队列在本地的定义，它类似一个地址指针，指向远程主机上的某个目的队列，它仅仅是个定义，不真正占用磁盘存储空间。AttributesofobjectsDetailPleaseref=/com.ibm.mq.csqzak.doc/fr18300_.htmCurrentQDepthDefBindDefPersistenceNonPersistentMessageClassMQBasicConceptMQI:MQAPIalsocalledasMQIWebSphereMQScript(MQSC)commandsWebSphereMQExplorerMQOverview(1of4)队列管理器•队列管理器是MQ系统中最上层的一个概念，由它为我们提供基于队列的消息服务,像一数据库实例一样队列通道•通道是MQ系统中队列管理器之间传递消息的管道，它是建立在物理的网络连接之上的一个逻辑概念。•通道类型：1.消息通道：消息通道是用于在MQ的服务器和服务器之间传输消息的，需要强调指出的是，该通道是单向的。2.MQI通道：MQI通道是MQClient和MQServer之间通讯和传输消息用的，与消息通道不同，它的传输是双向的3.Cluster通道：群集(Cluster)通道是位于同一个MQ群集内部的队列管理器之间通讯使用的。ListenerMQOverview(2of4)MQCONNMQOPENPUTAndGETMQCLOSEMQDISCMessageMessageApp1App2QueueMQOverview(3of4)MQworksMQOverview(4of4)MQ的通讯模式1.点对点通讯2.多点广播3.发布/订阅(Publish/Subscribe)模式4.群集(Cluster)MQInstallationOnWindowsOnUnix1.Createmqmgroup2.CreatemqmuserID3.Createfilesystem:/usr/mqm&/var/mqm4.RunsmittyMoreinformation:\AHS_Michelin\Knowledge\MQonSVNMQSimpleAdministrationCreateanewMQinstance:crtmqm-qdefaultqmgr-lccycledlog-lllinerlog-lflogfilesize(4KB)-ldlogpathDeletetheexistingMQinstance:dltmqmStartaMQinstance:strmqmStopaMQinstance:endmqm受控（或停止）-c•只有在所有应用程序都已断开连接之后，队列管理器才停止。所有连接到该队列的新请求都会失败。这是缺省模式。立即-i•队列管理器在完成当前正在处理的所有MQI调用后停止。输入此命令后发出的任何MQI调用都将失败。任何未完成的工作单元将在队列管理器下一次启动时回滚。带等待的受控-w•停止队列管理器的方式与受控选项相同，但是命令提示符要在队列管理器结束之后才返回。抢先-p•队列管理器停止而不等待应用程序断开连接或等待MQI调用完成。使用此模式可能导致不可预料的结果。MQSimpleAdministrationDisplayMQInstancestatus:dspmqStartMQListener:runmqlsr-tTCP-p1414[-mqmgrname]amqsput–Putmessagesonthelocalqueueamqsbcg-Browsethemessagesofthequeueamqsget-Getthemessagesfromthequeuetomakethequeueemptyrcdmqimg-RecoveraqueuefromwhereacheckpointwillbedoneautomaticallyMQSimpleAdministrationMQScript(MQSC)commands:runmqsc•在发送方A：1.定义本地传输队列:defineqlocal(QMB)usage(xmitq)defpsist(yes)2.创建远程队列:defineqremote(QR.TOB)rname(LQB)rqmname(QMB)xmitq(QMB)3.定义发送通道:definechannel(A.TO.B)chltype(sdr)conname('IPofB')xmitq(QMB)+trptype(tcp)•在接收方B：1.定义本地队列QLB:defineqlocal(LQB)2.创建接收通道:definechannel(A.TO.B)chltype(rcvr)trptype(tcp)MQconfigfilesMQConfigurationFile•Unix:/var/mqm/mqs.ini•Windows:storessimilarinformationintheWindowsRegistry(nomqs.ini)QueueManagerConfigurationFile•Unix:/var/mqm/qmgrs/qmgrname/qm.ini•Windows:storessimilarinformationintheWindowsRegistryMQProcessChecktherunningMQprocess•ps–ef|grepamq•ps–ef|grepmqmMQbaseprocess(onUnix)•amqpcseaCommandserver•amqhasmxLogger|•amqharmxLogformatter(linearlogsonly)•amqzllp0Checkpointprocessor•amqzlaa0Queuemanageragents•amqzfumaOAMprocess•amqzxma0Processingcontroller•amqrrmfaRepositoryprocess(forclusters)•amqzdmaaDeferredmessageprocessor•amqrmppaChannelreceiverMQSimpleTroubleshootingChecktheMQobjectsstatus.ErrorlogsTwotypes–QueueManagerErrorLogs&SystemErrorLogsFilenamesAMQERR01.LOG,AMQERR02.LOG&AMQERR03.LOGLocationdependsonOperatingSystem•UNIX&LinuxSystem/var/mqm/errorsQM/var/mqm/qmgrs/qmname/errors•WindowsSystemc:\ProgramFiles\IBM\WebSphereMQ\errorsQMс:\ProgramFiles\IBM\WebSphereMQ\qmgrs\qmname\errorsStartMQtraceandrecreatetheproblem.strmqtrc-mqmgrsname-l2000-tallendmqtrc-mqmgrsnameOtherOS&relatednotes=swg21172370MQSimpleTroubleshootingFFST(First-failuresupporttechnology)providesreportofunexpectedeventhasbeendetectedbyaQM,whichmightaffecttheabilityofthatQMtoperformitsfunction.canbereaddirectlybyanexperiencedMQadministrator.createdsometimeprevioustoexternalsymptomsofaproblembeingobservedcanbeinstrumentalinunderstandingthereasonforaproblembeingexperienced.keepanyFFSTfilescreatedbyMQforareasonableperiodtoprovideittoIBMServicerepresentativesFilenames&Locations(Windows,UNIX)AMQnnnnnnnn_mm.FDC(nnnnnnnn–processID,mm–sequencenumbernormally0)UNIX/var/mqm/errorsWindowsc:\ProgramFiles\IBM\WebSphereMQ\errorsOtherOS&relatedno