您的位置:首页 > 其它

MQ笔记_3-3_常用的命令

2015-11-27 16:29 232 查看

MQ常用的命令

①. 查看MQ的版本

mqm@bobo-VirtualBox /opt/mqm/bin $ ./dspmqver




②. 队列管理器

2.1 创建队列管理器
./crtmqm -q QM_011_510000
(-q选项, 表示创建缺省队列管理器, 一台机器最多只能有一个缺省队列管理器)



2.2 查看队列管理器
mqm@bobo-VirtualBox /opt/mqm/bin $ ./dspmq  //查看全局




或者进入MQ控制台输入命令
DISPLAY QMSTATUS




2.3 显示队列管理器属性
DISPLAY QMGR




2.3.1 显示队列管理器的字符集
DISPLAY QMGR CCSID




1208 对应 UTF-8

常用的还有

819 — Latin

1381 — GB2312

1383 — Simplified Chinese EUC

1386 — GBK

1392 — GB18030

2.4 启动队列管理器
./strmqm  QM_011_510000




2.5 运行队列管理器(进入MQ控制台)
./runmqsc QM_011_510000




2.6 停止队列管理器mq_test
mqm@bobo-VirtualBox /opt/mqm/bin $ ./endmqm mq_test




2.7 删除队列管理器mq_test
mqm@bobo-VirtualBox /opt/mqm/bin $ ./dltmqm mq_test




③. 队列

3.1 显示所有的队列
display queue(*)




3.2 显示创建时间是下午4点35分23秒的队列
display queue(*) where (crtime eq '16.35.23')




3.3 显示队列Q_TEST的详细信息
display queue(Q_TEST)




3.4 创建队列

3.4.1 创建本地队列(q_test)
DEFINE QLOCAL(q_test)
注意,创建的时候队列名虽可以小写,但是引用的时候一定要大写。



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)




3.6 修改队列(将队列 Q 的最大深度设置为 500)注意,最大深度仅对本地队列(本地队列、本地传输队列)起作用。

ALTER QLOCAL (Q) MAXDEPTH (500)


④. 通道

4.1 显示所有的通道
DISPLAY CHANNEL(*)




4.1.1 显示通道105_510000的详细信息
DISPLAY CHANNEL(105_510000)




4.1.2 显示通道C_SDR的心跳间隔
DISPLAY CHANNEL (C_SDR) HBINT


参数
HBINT
表示两次心跳之间的间隔时间,单位-秒。在发送端如果一定时间内没有新的消息需要传送,则发送端主动发送一个心跳信号,接收端在接收这个信号之后,关闭通道。



4.2 创建通道

4.2.1 创建接收通道(C_RCV)
DEFINE CHANNEL (C_RCV) CHLTYPE (RCVR)




参数
CHLTYPE (RCVR)
表示此通道是接收通道

4.2.2 创建发送通道(C_SDR)
DEFINE CHANNEL (C_SDR) CHLTYPE (SDR) CONNAME ('127.0.0.1 (1414)') XMITQ (XQ)




参数
CHLTYPE (SDR)
表示此通道是发送通道

参数
CONNAME ('127.0.0.1 (1414)')
表示连接目标的地址和端口

参数
XMITQ (XQ)
中指定本地传输队列名

后面还可以继续添加参数
trptype(tcp)
或者
trptype(udp)
指定协议

4.3 删除通道(C_RCV)
DELETE CHANNEL (C_RCV)




注意, 通道只有在停止状态下才可以被删除或修改。

4.4 修改通道(修改通道 C_SDR 的批次消息数量为 20)
ALTER CHANNEL (C_SDR) CHLTYPE (SDR) BATCHSZ (20)


参数
BATCHSZ (20)
表示消息满20条做一次发送。注意,修改通道后需要重启通道以生效。



4.5 启动通道
START CHANNEL (ChannelName)


注意,启动、停止通道都只有在发送通道才有作用。



或者
./runmqchl -c 105_510000  -m QM_011_510000




参数
-c
指定通道

参数
-m
指定队列管理器

4.6 停止通道(105_510000)
STOP CHANNEL (105_510000)




4.7 查看通道的运行状态



DIS CHS(105_510000)
DISPLAY CHANNEL (105_510000)
,后者显示更加详细,前者会转换域名显示真实IP地址。



4.8 测试通道是否畅通
PING CHANNEL(105_510000)




⑤. 监听

注意,启动、停止监听都只有在接收方才有作用。

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




6.2 接收消息
/opt/mqm/samp/bin/amqsget L_105_510000 QM_105_510000


内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  MQ 消息中间件