发文章
发文工具
撰写
网文摘手
文档
视频
思维导图
随笔
相册
原创同步助手
其他工具
图片转文字
文件清理
AI助手
留言交流
WebSphere MQ 入门指南这是一篇入门指南。我们从最基本的概念说起;
对于MQ,我们需要知道4个名词:队列管理器、队列、消息、通道;对于编程设计人员,通常更关心消息和队列,对于维护管理人员,通常 会更关心队列管理器和通道。如果我们把队列管理器比作是数据库,那么队列就是其中的一张表,消息就是表中的一条记录。
队列:我们可以简单地把队列看成一个容器,用于存放消息。
队列管理器:队列管理器构建了独立的 MQ 的运行环境,它是消息队列的管理者,用来维护和管理消息队列。
消息:MQ中的最小对象;默认情况下,消息缺省可以达到 4MB。消息可以分成持久消息和非持久消息。所谓“持久”的 意思,就是在MQ 队列管理器重启动后,消息是否仍然能保持。持久的消息写入或读出队列的同时会在 Log 中记录,所以性能上比非持久消息差不少。
通道:通道则是两个队列管理器之间的一种单向的点对点的通信连接, 消息在通道中只能单向流动。队列管理器之间的通信是通过配置通道来实现 的,通道两侧的队列管理器对这个通道的相关参数应该能对应起来。在通道上可以配置不同的通信协议,这样就使得编程接口与通信协议无关。通道两端的 配置必须匹配,且名字相同,否则无法连通。
RUNMQSC:命令行交互界面管理工具;作为维护人员的我们,与MQ打交道有两种方式,一种是通过MQ提供的二进制命令工具(在mq安装目录的bin目录下),另一种方式则是通过命令行交互管理工具;这二者在功能上有很多是重合的,但并非完全可替代;RUNMQSC是一个通用的 MQ 对象管理工具,使用 MQSC命令集可以对 MQ 对象进行全方位的管理,也是各种管理方式最直接、最全面的一种。RUNMQSC 运行的命令集称为 MQSC (MQ Script Command)";在 RUNMQSC 中大小写无关,所有的命令会先转换成全大写再提交执行。所以如果要 表示大小相关的字串,比如对象名,则用引号将字串包住。输入以下命令启动MQSC命令:runmqsc [queueManagerName]
ok,概念介绍完了,下面就是通过示例来学习如何使用他们;首先,我们需要创建队列管理,用来存放队列。有了队列管理器后,就可以创建队列;队列创建了,就可以用来放入和取出消息;
eg:创建一个名为QM_MEMDB的队列管理器:
crtmqm -q QM_MEMDB >Directory '/var/mqm/qmgrs/QM_MEMDB' created.
所有创建的队列管理器在/var/mqm/qmgrs目录下都会有对应文件名的子目录生成;(至于为什么是/var/mqm,这个配置在安装目录下的mq配置文件中配置samp/mqs.ini)从这里我们可以确定,队列管理器的创建是一个持久化的操作,当MQ服务器停止后再启动时,队列管理器都还是存在的;
启动名为QM_MMEDB的队列管理器:
/opt/mqm/bin$./strmqm QM_MEMDB >WebSphere MQ queue manager 'QM_MEMDB' started using V7.5.0.0.
(停止mq队列管理器:endmqm)
队列及消息属于MQ的对象,MQ的对象管理一般使用mqsc命令交互工具来管理;对于创建队列的操作,最好先写好放在一个文件里,然后调用;eg,我们在队列管理器QM_MEMDB中定义一个TEST1队列:
vi define_memdb.tst: define qlocal (TEST1) DEFPSIST(YES) MAXDEPTH(150000)
然后调用mqsc来创建:
/var/mqm/sh$runmqsc QM_MEMDB < define_memdb.tst > out.txt
创建的结果信息输出到out.txt:
1 : define qlocal (TEST1) DEFPSIST(YES) MAXDEPTH(150000) AMQ8006: WebSphere MQ queue created. One MQSC command read. No commands have a syntax error. All valid MQSC commands were processed.
基本队列操作命令分成两类, 一类在 MQ Server 端运行, 它们是 amqsput、 amqsget、amqsbcg。另一类在 MQ Client 端运行,它们是 amqsputc、amqsgetc、amqsbcgc从Server端将消息放入队列的命令格式:
amqsput amqsput QueueName [QueueManagerName]
amqsput和 amqsputc 可以将消息放入队列中, 程序把之后的每一行标准输入作为一条独立的消息,读到 EOF 或空行时退出。注意,UNIX 上的 EOF 为 Ctrl+D。可以将标准输入重定向到文件。队列中每放入一条消息,队列深度增加一。eg:
/var/mqm/sh$amqsput TEST1 QM_MEMDB
查看队列管理器QM_MEMDB中名为TEST1的队列:
/var/mqm/sh$amqsbcg TEST1 QM_MEMDB
amqsget 和 amqsgetc 可以将消息从队列中全部读出并显示。读空后再等待 15 秒,在这段时间内如果有新的消息到达会一并读出。强行中断该程序用 Ctrl+C 。amqsget 和 amqsgetc 执行后队列应该为空,即队列深度为零。
以上是单个服务器的单个队列管理器中完成的操作,如果需要跨队列管理器或跨机通信,我们需要MQ命令服务器和MQ监听器,当然,少不了建立通道;
WebSphere MQ 命令服务器是队列管理器的一个组件,用来对外来的命令消息进行解释和执行。在远程管理和编程管理的应用中,需要启动命令服务器。一个队列管理器最多只有一个命令服务器,缺省情况下在创建队列管理器时由系统一并创建。启动与停止:strmqcsvendmqcsvdspmqcsv启动后执行下,观察状态,看到正在运行:/opt/mqm/bin$dspmqcsv QM1WebSphere MQ Command Server Status . . : Running
WebSphere MQ 中监听器也是队列管理器的一个组件,用来监听外来的连接请求并相应地做出反应。监听器通常需要先配置,然后才能运行,配置参数与监听器选择的通信协议有关。当然,也可以在第一次启动监听器时将配置参数传入,隐式地进行配置。一个队列管理器可以有多个监听器,分别应用于不同的通信协议或同一协议的不同参数。比如 TCP/IP 的不同端口。
通道的配置和建立下面单独拿出来讲解;over。
《精通 WebSphere MQ》本书讲解的MQ版本为5.3,有些老,不过操作命令都没有变化;逻辑清晰,还不错;涉及到MQ的新特性,比如发布/订阅方面,就不用看这本书了,转到参考2:《Application Programming Reference MQV7》
Posted by: 大CC | 03DEC,2013博客:blog.me115.com
来自: 昵称10504424 > 《工作》
0条评论
发表
请遵守用户 评论公约
IBM WebSphere MQ 系列(四) 使用MQ命令
IBM WebSphere MQ 系列(四) 使用MQ命令。结合上节使用到的MQ命令,本节系统阐述MQ的命令。一、MQ命令集合。ALTER 队列。MQAI:除了PCF...
MQ笔记
有四种类型:本地队列(LocalQueue)、远程队列(RemoteQueue)、别名队列(AliasQueue)和模型队列(ModelQueue),最常用到的是本地队列和远程队列。每个队列管理器都具有唯一的名称并且管理在该队列管理器上...
WebSphere MQ 安全系列,第 1 部分: WebSphere MQ 认证及访问权限管理
WebSphere MQ 安全系列,第 1 部分: WebSphere MQ 认证及访问权限管理。从以上命令看以看出,使用 setmqaut 命令给用户 test1 赋予了对...
IBM Message Broker笔记系列(三) .
安装好MQ后,创建一个队列管理器(简称QM),名为TESTQM(MQ里面的对象是区分大小写的,为了避免不必要的麻烦,这里统一用大写,以下划...
如何进行WebShpere MQ 运行故障的定位分析和排除
如何进行WebShpere MQ 运行故障的定位分析和排除任何一种软件,都会存在一定的系统管理工作,WebSphere MQ也不例外,在使用WebSphere MQ(以下简称MQ)时,我们可能会由于配置的原因或者由于系统的原因...
IBM MQ 使用指南
IBM MQ 使用指南IBM MQ 使用指南。8)从队列中取出消息 amqsget QName QmgrName 如果队列是默认队列管理器中的队列,可以不带其队列管理器的名字。5.如果被管理队列管理器上的操作用户与管理队列管理...
企业服务总线解决方案剖析,第 4 部分: 企业服务总线的实施策略与总线集成
队列管理器的名称也很重要,前面说过,消息传递引擎在MQ看来就类似一个远程的MQ,而MQ与SIBus的通信方式与普通的远程主机上的MQ的通信的...
WebSphere MQ V7新功能(3)
WebSphere MQ V7新功能(3)MQ V7.0 将 JMS 配置集成到了基于 Eclipse 的图形工具 MQ Explorer 中,从而方便了 JMS 解决方案的设计和部署,从而实现的诸如连接工厂和目标这类的 JMS 对象可以与 MQ 队列和...
消息中间件 MQ 企业级方案设计,第 1 部分: 异步通信与负载均衡
消息中间件 MQ 企业级方案设计,第 1 部分: 异步通信与负载均衡 引言。本系列以使用 IBM 大型机服务器的客户为主要对象,对异步通信与同...
微信扫码,在手机上查看选中内容