MQ笔记_3-3_常用的命令
2015-11-27 16:29
232 查看
MQ常用的命令
①. 查看MQ的版本mqm@bobo-VirtualBox /opt/mqm/bin $ ./dspmqver
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_151.png)
②. 队列管理器
2.1 创建队列管理器
./crtmqm -q QM_011_510000(-q选项, 表示创建缺省队列管理器, 一台机器最多只能有一个缺省队列管理器)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33100.png)
2.2 查看队列管理器
mqm@bobo-VirtualBox /opt/mqm/bin $ ./dspmq //查看全局
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_200.png)
或者进入MQ控制台输入命令
DISPLAY QMSTATUS
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_201.png)
2.3 显示队列管理器属性
DISPLAY QMGR
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_300.png)
2.3.1 显示队列管理器的字符集
DISPLAY QMGR CCSID
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33150.png)
1208 对应 UTF-8
常用的还有
819 — Latin
1381 — GB2312
1383 — Simplified Chinese EUC
1386 — GBK
1392 — GB18030
2.4 启动队列管理器
./strmqm QM_011_510000
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33110.png)
2.5 运行队列管理器(进入MQ控制台)
./runmqsc QM_011_510000
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33120.png)
2.6 停止队列管理器mq_test
mqm@bobo-VirtualBox /opt/mqm/bin $ ./endmqm mq_test
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_600.png)
2.7 删除队列管理器mq_test
mqm@bobo-VirtualBox /opt/mqm/bin $ ./dltmqm mq_test
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_700.png)
③. 队列
3.1 显示所有的队列
display queue(*)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_400.png)
3.2 显示创建时间是下午4点35分23秒的队列
display queue(*) where (crtime eq '16.35.23')
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_401.png)
3.3 显示队列Q_TEST的详细信息
display queue(Q_TEST)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_402.png)
3.4 创建队列
3.4.1 创建本地队列(q_test)
DEFINE QLOCAL(q_test),注意,创建的时候队列名虽可以小写,但是引用的时候一定要大写。
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33160.png)
3.4.2 创建本地传输队列
DEFINE QLOCAL(L_011_510000) usage (xmitq) defpsist(yes)
参数
usage (xmitq)表示此队列为传输队列
参数
defpsist(yes)表示此队列为持久化队列。持久化队列的消息在队列管理器停止时是可以保存的,非持久化队列,队列管理器停止时消息不会被保存。
3.4.3 创建远程队列
DEFINE QREMOTE(R_011_105_510000) rname(L_105_510000) rqmname(QM_105_510000) xmitq(L_011_510000)
参数
rname指定接收方本地队列名
参数
rqmname指定接收方队列管理器名
参数
xmitq指定发送方传输队列名
3.4.4 创建本地队列 Q。 如果 Q 已存在, 则保留队列中原有的消息并将其属性全部重置为缺省值。
DEFINE QLOCAL (Q) REPLACE
3.5 删除队列Q_TEST
DELETE QLOCAL(Q_TEST)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_500.png)
3.6 修改队列(将队列 Q 的最大深度设置为 500)注意,最大深度仅对本地队列(本地队列、本地传输队列)起作用。
ALTER QLOCAL (Q) MAXDEPTH (500)
④. 通道
4.1 显示所有的通道
DISPLAY CHANNEL(*)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33170.png)
4.1.1 显示通道105_510000的详细信息
DISPLAY CHANNEL(105_510000)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33181.png)
4.1.2 显示通道C_SDR的心跳间隔
DISPLAY CHANNEL (C_SDR) HBINT
参数
HBINT表示两次心跳之间的间隔时间,单位-秒。在发送端如果一定时间内没有新的消息需要传送,则发送端主动发送一个心跳信号,接收端在接收这个信号之后,关闭通道。
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33210.png)
4.2 创建通道
4.2.1 创建接收通道(C_RCV)
DEFINE CHANNEL (C_RCV) CHLTYPE (RCVR)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33190.png)
参数
CHLTYPE (RCVR)表示此通道是接收通道
4.2.2 创建发送通道(C_SDR)
DEFINE CHANNEL (C_SDR) CHLTYPE (SDR) CONNAME ('127.0.0.1 (1414)') XMITQ (XQ)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33200.png)
参数
CHLTYPE (SDR)表示此通道是发送通道
参数
CONNAME ('127.0.0.1 (1414)')表示连接目标的地址和端口
参数
XMITQ (XQ)中指定本地传输队列名
后面还可以继续添加参数
trptype(tcp)或者
trptype(udp)指定协议
4.3 删除通道(C_RCV)
DELETE CHANNEL (C_RCV)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33220.png)
注意, 通道只有在停止状态下才可以被删除或修改。
4.4 修改通道(修改通道 C_SDR 的批次消息数量为 20)
ALTER CHANNEL (C_SDR) CHLTYPE (SDR) BATCHSZ (20)
参数
BATCHSZ (20)表示消息满20条做一次发送。注意,修改通道后需要重启通道以生效。
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33230.png)
4.5 启动通道
START CHANNEL (ChannelName)
注意,启动、停止通道都只有在发送通道才有作用。
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33240.png)
或者
./runmqchl -c 105_510000 -m QM_011_510000
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33250.png)
参数
-c指定通道
参数
-m指定队列管理器
4.6 停止通道(105_510000)
STOP CHANNEL (105_510000)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33260.png)
4.7 查看通道的运行状态
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33270.png)
DIS CHS(105_510000)与
DISPLAY CHANNEL (105_510000),后者显示更加详细,前者会转换域名显示真实IP地址。
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33280.png)
4.8 测试通道是否畅通
PING CHANNEL(105_510000)
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_3006.png)
⑤. 监听
注意,启动、停止监听都只有在接收方才有作用。
5.1 启用监听
./runmqlsr -m QM_105_510000
5.2 停止监听
./endmqlsr -m QM_105_510000
⑥. 消息
6.1 发送消息
/opt/mqm/samp/bin/amqsput R_011_105_510000 QM_011_510000
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33290.png)
6.2 接收消息
/opt/mqm/samp/bin/amqsget L_105_510000 QM_105_510000
![](http://7xim2e.com1.z0.glb.clouddn.com/MQ_33300.png)
相关文章推荐
- java结合WebSphere MQ实现接收队列文件功能
- JMS-使用消息队列优化网站性能
- 架构优化 - 应用,MQ Broker,业务处理分层
- rabbitmq学习
- IBM WebSphere MQ介绍安装以及配置服务详解
- Websphere MQ 7.0.0 For Linux版安装
- Fourinone四合一分布式计算框架整体介绍
- IBM MQ常用命令
- AMQP协议
- IBM-MQ安装及使用实例
- 了解MSMQ
- 开源消息中间件分析
- PC远程多媒体通信 (Notes)
- Metaq的一些简单机制
- wikipedia上的AMQP介绍
- boost::thread线程创建方式总结
- 软件产业中构件技术与中间件应用
- 中间件讨论--构筑复杂分布式应用的关键技术
- J2EE开源消息中间件大比拼
- 关于多播传输速率与可靠性之间的矛盾