以下为mq server对server模式
///////////////////// 发送方某机构 mq配置信息(客户)///////////////////////////////////////
地址:21.24.23.16
端口:4000
队列管理器:BC_TEST_IN
编码(CCSID):1381
发送消息通道:BC.AERSHAN.CHL
发送消息队列:DEMO_MQ1
接收消息通道:AERSHAN.BC.CHL
接收消息队列:AERSHAN.BC
///////////////////// 接收方 某机构 服务器配置信息(我方)///////////////////////////////////////
对外开发IP:12.40.13.2
对外发送IP:47.19.10.15
本地ip:192.168.10.6
检查对外地址命令:curl ip.cip.cc
用户和密码:mqm
队列管理器:FEDemo
接收队列:DEMO_MQ1
接收通道:BC.AERSHAN.CHL
发送通道:AERSHAN.BC.CHL
编码 1381
/////////////////////FEDemo mq 接收方配置///////////////////////////////////////
创建接收方通道--必须与发送方通道名称一致
define channel (BC.AERSHAN.CHL) chltype (RCVR) trptype (TCP)
创建接收方队列--放消息使用的
DEFINE QLOCAL(DEMO_MQ1) MAXDEPTH(20000) DEFPSIST(YES) REPLACE
创建服务器连接通道--放消息使用的
define channel (DEMO_CHANNEL) chltype(SVRCONN) REPLACE
/////////////////////FEDemo mq 发送方配置(接收方与发送方在一个队列管理器,使用同一个端口监听)///////////////////////////////////////
创建本地传输队列--传输消息使用
def ql(AERSHAN.BC.LOC) usage(xmitq) maxdepth(290000) trigger trigtype(first) initq(system.channel.initq) defpsist(yes) maxmsgl(10240000) trigdata(AERSHAN.BC.CHL) replace
创建发送方通道--必须与接收方通道名称一致
def chl(AERSHAN.BC.CHL) chltype(sdr) locladdr(192.168.10.6) conname('21.24.23.16(40000)') xmitq(AERSHAN.BC.LOC) trptype(tcp) maxmsgl(10240000) discint(0) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
创建远程队列----放消息使用的队列
def qr(AERSHAN.BC.REM) rname(AERSHAN.BC) rqmname(BC_TEST_IN) xmitq(AERSHAN.BC.LOC) defpsist(yes) replace
创建服务通道--放消息使用的通道
define channel(AERSHAN.SERVERCONN) chltype(svrconn) replace
runmqlsr -t tcp -p 15001 -m FEDemo &
//////////////SENDER 发送方配置(接收方与发送方在不同队列管理器,使用不同端口监听)///////////////////////////////////////
创建本地传输队列--传输消息使用
def ql(AERSHAN.BC.LOCAL) usage(xmitq) maxdepth(290000) trigger trigtype(first) initq(system.channel.initq) defpsist(yes) maxmsgl(10240000) trigdata(AERSHAN.BC.CHL) replace
创建发送方通道--传输消息使用
def chl(AERSHAN.BC.CHL) chltype(sdr) locladdr(192.168.10.6) conname('21.24.23.16(4000)') xmitq(AERSHAN.BC.LOCAL) trptype(tcp) maxmsgl(10240000) discint(0) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
创建远程队列----本地发送消息使用的队列
def qr(AERSHAN.BC.REMOTE) rname(AERSHAN.BC) rqmname(BC_TEST_IN) xmitq(AERSHAN.BC.LOCAL) defpsist(yes) replace
创建服务通道--本地发送消息使用的通道
define channel(SENDER.SERVERCONN) chltype(svrconn) replace
-- ALTER CHANNEL(SENDER.SERVERCONN) CHLTYPE(SVRCONN) MCAUSER('mqm')
/////////////////////mq常用命令///////////////////////////////////////
创建测试接收通道信息
创建队列管理器
crtmqm FEDemo
启动/停/删除
strmqm/endmqm/dltmqm FEDemo
进去队列管理器
runmqsc FEDemo
查看命令
display chl/queue/ql/qr(名称)
状态查看命令
display chs(channel名称)
启动、停、重置
start/stop/reset chl(channel名称)
修改队列管理器字符集
dis QMGR
ALTER QMGR FORCE CCSID(1381)
消息队列信息操作
amqsput DEMO_MQ1 FEDemo //放消息
amqsget DEMO_MQ1 FEDemo //拿消息