linux下 MQ第二弹：队列管理器的配置，实现双机MQI通道异步双向通信,亲测!!

蔚落 2022-10-02 10:57 2阅读 0赞

本人前面文章一提到MQ 在linux下的安装，在此只描述队列管理器的配置，实现MQI通道的双向通讯。

一下方法我已亲测！！

贴出A，B两机的MQ配置记录：

**A机：**

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*--创建QMA队列管理器

crtmqm -ld /var/mqm/log -lc -lf 16384 -lp 5 -ls 2 QMA

\#\*\*--启动QMA队列管理器

strmqm QMA

\#\*\*--进入QMA队列管理器的管理交互界面

runmqsc QMA

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义QMA本地队列

DEF QL(QU\_QMA) MAXDEPTH(100000) DEFPSIST(YES) REPLACE

\#\*\*----定义死信队列

DEF QL(DEADQ) MAXDEPTH(100000) DEFPSIST(YES) REPLACE

\#\*\*----把死信队列DEADQ设置为队列管理器默认的死信队列

ALTER QMGR DEADQ(DEADQ)

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义监听

DEF LISTENER(LSNTCP) TRPTYPE(TCP) PORT(1414) BACKLOG(0) CONTROL(QMGR)

START LISTENER(LSNTCP)

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义服务器连接通道

DEFINE CHANNEL(SYSTEM.ADMIN.SVRCONN) CHLTYPE(SVRCONN) TRPTYPE(TCP) MCAUSER('mqm') REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义到队列管理器QMB的远程队列

DEF QR(QR\_QMA\_QMB) RNAME(QU\_QMB) RQMNAME(QMB) XMITQ(XMA) DEFPSIST(YES) REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义到队列管理器QMB的通信队列

DEF QL(XMA) USAGE(XMITQ) MAXDEPTH(100000) TRIGGER TRIGTYPE(FIRST) INITQ(SYSTEM.CHANNEL.INITQ) DEFPSIST(YES) TRIGDATA(CH\_QMA\_QMB) REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义发送消息到QMB的发送通道

DEF CHL(CH\_QMA\_QMB) CHLTYPE(SDR) LOCLADDR(192.168.19.189) CONNAME('192.168.19.144(1424)') XMITQ(XMA) TRPTYPE(TCP) REPLACE

\#\*\*----定义从QMB接收消息的接收通道

DEF CHL(CH\_QMB\_QMA) CHLTYPE(RCVR) TRPTYPE(TCP) REPLACE

\#\*\*----启动通道

START CHL(CH\_QMA\_QMB)

\#\*\*----退出交互界面

END

$ cd /opt/mqm/samp/bin

$ ./amqsput QR\_QMA\_QMB QMA

Sample AMQSPUT0 start

target queue is QR\_QMA\_QMB

123

abc

Ctrl+c(退出输入消息)

在B机执行

$ ./amqsget QU\_QMB QMB

Sample AMQSGET0 start

message <123>

message <abc>

**B机：**

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*--创建QMB队列管理器

crtmqm -ld /var/mqm/log -lc -lf 16384 -lp 5 -ls 2 QMB

\#\*\*--启动QMB队列管理器

strmqm QMB

\#\*\*--进入QMB队列管理器的管理交互界面

runmqsc QMB

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义QMB本地队列

DEF QL(QU\_QMB) MAXDEPTH(100000) DEFPSIST(YES) REPLACE

\#\*\*----定义死信队列

DEF QL(DEADQ) MAXDEPTH(100000) DEFPSIST(YES) REPLACE

\#\*\*----把死信队列DEADQ设置为队列管理器默认的死信队列

ALTER QMGR DEADQ(DEADQ)

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义监听

DEF LISTENER(LSNTCP) TRPTYPE(TCP) PORT(1424) BACKLOG(0) CONTROL(QMGR)

START LISTENER(LSNTCP)

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义服务器连接通道

DEFINE CHANNEL(SYSTEM.ADMIN.SVRCONN) CHLTYPE(SVRCONN) TRPTYPE(TCP) MCAUSER('mqm') REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义到队列管理器QMA的远程队列

DEF QR(QR\_QMB\_QMA) RNAME(QU\_QMA) RQMNAME(QMA) XMITQ(XMB) DEFPSIST(YES) REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义到队列管理器QMA的通信队列

DEF QL(XMB) USAGE(XMITQ) MAXDEPTH(100000) TRIGGER TRIGTYPE(FIRST) INITQ(SYSTEM.CHANNEL.INITQ) DEFPSIST(YES) TRIGDATA(CH\_QMB\_QMA) REPLACE

\#\*\*－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－

\#\*\*----定义发送消息到QMA的发送通道

DEF CHL(CH\_QMB\_QMA) CHLTYPE(SDR) LOCLADDR(192.168.19.144) CONNAME('192.168.19.189(1414)') XMITQ(XMB) TRPTYPE(TCP) REPLACE

\#\*\*----定义从QMA接收消息的接收通道

DEF CHL(CH\_QMA\_QMB) CHLTYPE(RCVR) TRPTYPE(TCP) REPLACE

\#\*\*----启动通道

START CHL(CH\_QMB\_QMA)

\#\*\*----退出交互界面

END

$ ./amqsget QU\_QMB QMB

Sample AMQSGET0 start

message <123>

message <abc>

no more messages

Sample AMQSGET0 end

$ ./amqsput QR\_QMB\_QMA QMB

Sample AMQSPUT0 start

target queue is QR\_QMB\_QMA

111

aaa

Ctrl+c(退出输入消息)

在A机执行：

$ ./amqsget QU\_QMA QMA

Sample AMQSGET0 start

message <111>

message <aaa>

**注意：**

确保双机联通，防火墙关闭，检查端口是否已在监听！

也可以直接在一台机器上面实验，只要把iP改为127.0.0.1 ，端口不同，队列管理器名字不同即可！！

转载于:https://blog.51cto.com/boyishachang/1255356

linux下 MQ第二弹：队列管理器的配置，实现双机MQI通道异步双向通信,亲测!!

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关在Linux系统下安装配置Nginx---亲测可用

相关 IBM MQ双机通信试验（原创）

相关 php双向队列是什么意思,PHP双向队列，双端队列代码

相关 linux下 MQ第二弹：队列管理器的配置，实现双机MQI通道异步双向通信,亲测!!

相关 Linux虚拟机配置网络环境（亲测）

相关 SpringBoot整合IBM MQ，多个队列管理器通信

相关 linux下开机自启动脚本（亲测）

相关 MQ 双向队列 request-response模式

相关 SpringBoot 拦截器的配置——亲测可用

相关 linux进程间通信之管道（无名管道pipe）实现全双工双向通信