交通银行理财产品销售平台MQ操作手册

交通银行理财产品销售平台

MQ操作手册

文档修改历史

版本号修改日期编写评审同意修改内容

1.0-9-15范德强初始版本

1.1-10-13范德强添加生成环境布署阐明（集群部分）

1.2-10-14范德强添加集群部分脚本阐明部分

1.MQ配置简介

基本规则如下：

1）队列管理器与GSP的一种QM建立双向通道,即建立一种发送通道，一种接受通道

2）对于单纯的服务祈求方，每个系统建立：n个远程队列用于发送报文到GSP,一种

当地队列用于接受GSP返回的报文。（n表达该祈求方需要祈求的服务个数），BDP

系统作为服务祈求方，祈求关键,即建立一种远程队列，一种当地队列.

3）对于单纯服务提供方，每个系统建立2m个队列：m个远程队列用于发送报文到

GSP,m个当地队列用于接受GSP返回的报文。（m表达服务方提供的服务数）BDP

系统作为服务提供方，对外提供三个服务，即建立三个当地队列,三个远程队列

根据上面规则，配置如下：

1.一种队列管理器：MQBDPOOlo

2.一种传播队列：MQGSPGWlo

3.服务提供方三个当地队列

LOCALQ.GSRBOCOMFUNDACCOUNT.REQ

LOCALQ.GSP.BOCOMFUNDPRODUCT.REQ

LOCALQ.GSRBOCOMFUNDRECONCILIATION.REQo

4.服务提供方三个远程队列;

2.常用命令

2.1队列管理器有关

注：MQBDPOOI是队列管理器名字。

I.创立队列管理器crtmqmMQBDPOOI

2.启动队列管理器strmqmMQBDPOOI

3.停止队列管理器cndmqmMQBDPOOI

4.立即停止队列管理器endmqm-iMQBDPOOI

5.强制停止队列管理器cndmqm-pMQBDPOOI

6.删除队列管理器dltmqmMQBDPOOI

7.进入管理队列管理器runmqscMQBDPOOI

a）显示队列管理器信息DISPLAYQMGR

b）修改队列管理器字符集ALTERQMGRCCSID(l38l)

2.2传播队列有关

8.创立传播队列

DEFINEQLOCAL(MQGSPGWl)+

USAGE(XMITQ)+

REPLACE

注：MQBDP001是传播队列名字。

9.显示传播队列信息DISPLAYQLOCAL(MQBDPOOl)

2.3当地队列和远程队列

io.服务提供方三个当地队列

DEFINEQLOCAL(LOCALQ.GSP.BOCOMFUNDACCOUNT.REQ)REPLACE

DEFINEQLOCAL(LOCALQ.GSP.BOCOMFUNDPRODUCT.REQ)REPLACE

DEFINEQLOCAL(LOCALQ.GSP.BOCOMFUNDRECONCILIATION.REQ)REPLACE

H.服务提供方三个远程队列

DEFINEQREMOTE(REMOTEQ.GSP.BOCOMFUNDACCOUNT.RSP)+

RNAME(LOCALQ.BDP001.BOCOMFUNDACCOUNT.RSP)+

RQMNAME(MQGSPGW1.ALIAS)+

XMITQ(MQGSPGWI)REPLACE

DEFINEQREMOTE(REMOTEQ.GSP.BOCOMFUNDPRODUCT.RSP)+

RNAME(LOCALQ.BDPOOl.BOCOMFUNDPRODUCT.RSP)+

RQMNAME(MQGSPGW1_ALIAS)+

XMITQ(MQGSPGWl)REPLACE

DEFINEQREMOTE(REMOTEQ.GSP.BOCOMFUNDRECONCILIATION.RSP)+

RNAME(LOCALQ.BDP()()1.BOCOMFUNDRECONCILIATION.RSP)+

RQMNAME(MQGSPGW1_ALIAS)+

XMITQ(MQGSPGWl)REPLACE

12.服务祈求方一种当地队列

DEFINEQLOCAL(LOCALQ.GSP.RSP)REPLACE

13.服务祈求方一种远程队列

DEFINEQREMOTE(REMOTEQ.GSRCBKADAPTER.REQ)+

RNAME(LOCALQ.GSP.CBKADAPTER,REQ>+

RQMNAME(MQGSPGW1_ALIAS)+

XMITQ(MQGSPGWI)+

REPLACE

14.显示当地队列信息

DISPLAYQLOCAL(队列名)

15.显示当地队列消息数量

DISPLAYQLOCAL(队歹ij名)CURDEPTH

16.显示当地队列信息

DISPLAYQLOCAL(队歹I」名)CURDEPTH

2.4死信队列有关

17.定义死信队列

DEFINEQLOCAL(MQBDPOOI.DEAD.QUEUE)+

DEFPSIST(YES)+

REPLACE

18.设定队列管理器的死信队列

ALTERQMGRDEADQ(MQBDPOOI.DEAD.QUEUE)

19.显示死信队列

DISPLAYQLOCAL(MQBDP001.DEAD.QUEUE)CURDEPTH

2.6接受通道有关

20.创立接受通道

DEFINECHANNEL(MQGSPGWI.MQBDPOO1)+

CHLTYPE(RCVR)+

REPLACE

21.显示接受通道DISPLAYCHANNEL(MQGSPGWI.MQBDPOOI)

2.7发送通道有关

22.创立发送通道

DEFINECHANNEL(MQBDPOO1.MQGSPGW1)CHLTYPE(SDR)+

DISCINT(O)CONNAMEC182.119.171.116(10001),)XMITQ(MQGSPGW1)+

REPLACE

注：MQBDP00LMQGSPGW11是发送通道名字

DISCINT(O)是处在永久监听状态

182.119.171.116是对方队列管理器的【P地址。

10001是对方QM的端口。

23.启动发送通道STARTCHANNEL(MQBDPOO1.MQGSPGW1)

24.重置发送通道RESETCHL(MQBDP(X)I.MQGSPGW1)

25.停止发送通道STOPCHANNEL(MQBDP001.MQGSPGW1)

26.查看发送通道参数DISPLAYCHANNEUMQBDP001.MQGSPGW1)

27.查看发送通道状态DISCHS(MQBDPOO1.MQGSPGW1)

2.8Server端通道有关

28.修改Server端通道，以便接受Java祈求

ALTERCHANNEL(SYSTEM.DEF.SVRCONN)CHLTYPE(SVRCONN)

MCAUSER('mqm')

注：这个命令可以使客户端软件连入MQ

2.9启动监听服务

runmqlsr-ttcp-mMQBDP001-p1414&

注：MQBDPOOI是队列管理器名字

1414是监听端口

2.10停止服务有关

I.停止队列管理器endmqmMQBDPOOI

2.查找线程并将其停止

ps-cf|greprunmqlsr

kill-9kill线程,一定要加-9

2.11重新启动MQ应用

i.启动队列管理器stnnqmMQBDP001

2.进入队列管理器runmqscMQBDPOOl

a）启动发送通道STARTCHANNEUMQBDPOOl.MQGSPGW1)

b）查看发送通道状态DISCHS(MQBDPOOl.MQGSPGW1)

3.启动监听服务runmqlsr-ttcp-mMQBDPOOl-p1414&

3配置jndi有关

3.1基本阐明

建立jndi环境，使程序可以使用jndi连入mq

I.使用mqm顾客，mqm/mqm

2.进入途径/usi7mqm/java/bin

3.运行JMSAdmin

4.定义queueconnectionfactory

命令如下：defineqcf（QCFl自己起的队列连接工厂的名字，供jndi用）

TRANSPORT（CLIENT）qmgr（QucucManagcr名字）

5.定义远程队列

defineq(RQ自己起的远程队列名字，供jndi用)queue(远程队列名)

6.定义当地队列

defineq(RQ自己起的远程队列名字，供jndi月)queue(远程队列名)

3.2在集成环境下如下建立

1.使用mqm顾客，mqm/mqm

2.进入途径/usr/mqm/java/bin

3.运行JMSAdmin

4,定义queueconnectionfactory

命令如卜：defineqcf(QueueConnectionFactory3)TRANSPORT(CLIENT)

qmgr(MQBDP001)CCSID(1381)hoslname(182.119.170.48)

SYNCPOINTALLGETS(YES)

5.定义当地队列

defineq(CBKL)qucuc(LOCALQ.GSP.RSP)CCSID(1381)

defineq(ERRORL)queue(LOCALQ.GSP.BOCOMFUNDRECONCILIATION.REQ)

CCSID(1381)

defineq(PRODUCTL)queue(LOCALQ.GSP.BOCOMFUNDPRODUCT.REQ)

CCSID(1381)

defineq(ACCOUNTL)queue(LOCALQ.GSP.BOCOMFUNDACCOUNT.REQ)

CCSID(1381)

6.定义远程队列

defineq(CBKR)queue(REMOTEQ.GSP.CBKADAPTER.REQ)

defineq(ERRORR)qucuc(REMOTEQ.GSP.BOC()MFUNDREC()NCILIATl()N.RSP)

defineq(PRODUCTR)queue(REMOTEQ.GSP.BOCOMFUNDPRODUCT.RSP)

defineq(ACCOUNTR)queue(REMOTEQ.GSP.BOCOMFUNDACCOUNT.RSP)

4生产环境布署(集群部分)

4.1术语阐明

完整存储库：相称马每台单独布署的队列管理器，保留独立的队列信息,提供应单独的服务提

供者调用

部分存储库：相称与网关，是与外界ESB关联的唯一通道,单独布署的队列管理器通过网关,

祈求外部服务

4.1方略阐明

D作为服务提供者，当地队列建立在完整存储库上面，与服务器直接连接，当地队列设置

成集群共享方式;远程队列建、工在部分存储库(网关)上面,没置成集群共享方式

2)作为服务祈求者,当地队列和远程队列都建立在部分存储库(网关)上面,设置成集群共

享方式

3)假如有n台服务器需要作负载均衡,那么需要建立n+1个队列管理器，其中1个队列管

理器设置成网关,n个队列管理器设置成完整存储库

4.3布署图

上图显不的是

MQBDP001作为部分存储库(网关)182.119.170.48(1414)

MQBDP002作为完整存储库182.119.171.235(1414)

MQBDP003作为完整存储库182.119.170.48(1418)

GSP与MQBDP001之间建立发送通道，接受通道

MQBDP001,MQBDP003之间建立集群发送通道,集群接受通道

MQBDPOO2,MQBDPOO3之间建立集群发送通道,集群接受通道

4.4布署脚本阐明

1）首先建立MQBDP001,部分存储库（假设建立在182.119.170.481414端口）

〃创立MQBDP001

crtniqmMQBDP001

〃启动MQBDP001

strmqmMQBDP001

〃进入MQBDP001

runmqscMQBDP001

〃打开MQBDP001.txt.将脚本拷贝执行，代码省略

〃重新启动MQBDP001

endmqm-pMQBDP001

strmqmMQBDPOOI

〃启动监听端M

runmqlsr-ttcp-mMQBDPOOI-p1414&

MQBDP001.txt阐明:建立服务提供方三个远程队列，建立服务祈求方一种当地队列，一

种远程队列

2）建立MQBDP002,完整存储库（假设建立在182.119.171.2351414端口）

〃创立MQBDP002

crtniqinMQBDP002

〃启动MQBDP002

strniqmMQBDP002

//进入MQBDP002

runmqscMQBDP002

〃打开MQBDP002.1XI.将脚本拷贝执行，代码省略

〃重新启动MQBDP002

endmqm-pMQBDP002

strmqmMQBDP002

〃启动监听端口

runmqlsr-（tcp-mMQBDP002-p1414&

MQBDP002.txt阐明:建立服务提供方三个当地队列

2）建立MQBDP003,完整存储库（假设建立在182.119.170.481418端口）

〃创立MQBDP003

crtmqmMQBDP003

〃启动MQBDP003

strmqmMQBDP003

〃进入MQBDP003

runmqscMQBDP003

〃打开MQBDP003.txt.将脚本拷贝执行，代码省略

〃重新启动MQBDP003

endmqm-pMQBDP003

strmqmMQBDP(X)3

〃启动监听端口

runmqlsr-ttcp-mMQBDP003-p1418&

MQBDP003.txt阐明:建立服务提供方三个当地队列

4.5配置集群

上面的队列管理器配置完毕后来，进行集群配置，配置的措施比较简朴,以客户端连接建立为

例子阐明

首先,新建队列管理器集群

文件9窗口/）帮助QD

选择队列管理器集群-＞右键新建队列管理器集群,输入名称BDPCLUSPRD下一步

«#>创建集群

2.选择第一个完整存偌库队列首理署船

选择要添加至集群的队列管理器

IBDPTEST

在以下情况中，未列示队列管理器：

♦此队列管理器已经是集群的成员.

*当前，在WebSphereMQ资源管理器队列管理器”文件夹中不显示此队列管理器.

将队列管理器添加至WebSphereMQ资源管理器…

<1一步⑥下—国）|取洎

选择第一种完整库队列管理器，前面已经说过了完整库有两个，这里选择MQBDP002下一

步

选择笫二个完整库队列管理器，这里选择MQBDP003,完毕

最终选择MQBDP001作为部分存储库，完毕，三个队列管理器之间,集群布署完毕，接着修改队

列属性如下图:

测试输入队列与否会转发

新建接受远程队列如下图:

队列名称队列管理器名称+ALIAS(别名)

队列管理器和远程队列填空

到这里BDP系统的集群就完毕了.

4.6集群脚本阐明

1)将队列管理器设置成为完整存储库

AITERQMGRMQBDP0fi2(BDPCI.1JSPRD);

ALTERQMGRMQBDP003(BDPCLUSPRD);

〃定义三个队列管理器的群集发送和群集接受通道

在MQBDP001I：面执行MQSC命令:

DEFINECHANNEL(TO.MQBDPOOI)CHLTYPE(CLUSRCVR)TRPTYPE(TCP)

CONNAMEC182.119.170.48(1414)1)CLUSTER(BDPCLUSPRD)

DEFINECHANNEL(TO.MQBDP()03)CHLTYPE(CLUSSDR)TRPTYPE(TCP)

CONNAMEC182.119.170.48(1418)')CLUSTER(BDPCLUSPRD)

〃在MQBDP002上面执行MQSC命令：

DEFINECHANNEL(TO.MQBDPO()2)CHLTYPE(CLUSRCVR)TRPTYPE(TCP)

CONNAMEC182.119.171.235(1414),)CLUSTER(BDPCLLSPRD)

DEFINECHANNEL(TO.QMGR1)CHLTYPE(CLUSSDR)TRPTYPE(TCP)

CONNAMEC182.119.170.48(1418),)CLUSTER(BDPCLUSPRD)

〃在MQBDP003上面执行MQSC命令：

DEFINECHANNEL(TO.QMGRI)CHLTYPE(CLUSRCVR)TRPTYPE(TCP)

CONNAMEC182.119.170.48(1418)')CLUSTER(BDPCLUSPRD)

DEFINECHANNEL(TO.QMGR1)CHLTYPE(CLUSSDR)TRPTYPE(TCP)

CONNAMEC182.119.171.235(1414),)CLUSTER(BDPCLUSPRD)

〃在MQBDP001上面定义远程队列，GSP访问远程队列作为队列管理器名称，远程队列名

MQBDP001.AL