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

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

MQ操作手册

文档修改历史

版本号修改日期编写评审批准修改内容

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

1.12008-10-13范德强添加生成环曳部署说明（集群部分）

1.22008-10-14范德强添加集群部分脚本说明部分

1.MQ配置简介

基本规则如下：

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

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

本地队列用于接收GSP返回的报文。（n表示该请求方需要请求的服务个数）,BDP

系统作为服务请求方，请求核心,即建立一个远程队列，一个本地队列.

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

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

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

依照上面规则，配置如下：

1.一个队列管理器：MQBDPOOU

2.一个传输队列：MQGSPGWK

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

LOCALQ.GSP.BOCOMFUNDACCOUNT.REQ

LOCALQ.GSP.BOCOMFUNDPRODUCT.REQ

LOCALQ.GSP.BOCOMFUNDRECONCILIATION.REQo

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

REMOTEQ.GSP.BOCOMFUNDACCOUNT.RSP

REMOTEQ.GSP.BOCOMFUNDPRODUCT.RSP

REMOTEQ.GSP.BOCOMFUNDRECONCILIATION.RSP

5.服务请求方一个本地队列

LOCALQ.GSP.RSP

6.服务请求方一个远程队列

REMOTEQ.GSP.CBKADAPTER.REQ

7.一个死信队列：MQBDP001.DEAD.QUEUEo

8.一个接收通道：MQGSPGW1.MQBDP001。

9.一个发送通道：MQBDP001.MQGSPGW1

注：确认小型机的字库Zh_GB和GB18030是否安装。export是否是LANG二Zh_CN（注

意大小写，不是zh_CN）。如果不是，请修改服务用户的.profile的LANG二Zh_CN。

2.常用命令

2.1队列管理器相关

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

I.创建队列管理器crtmqmMQBDPOOl

2.启动队列管理器strmqmMQBDPOOl

3.停止队列管理器endmqmMQBDPOOl

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

5.强制停止队列管理器endmqm-pMQBDPOOl

6.删除队列管理器dltmqmMQBDPOOl

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

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

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

2.2传输队列相关

8.创建传输队列

DEFINEQLOCAL(MQGSPGWI)+

USAGE(XMITQ)+

REPLACE

注：MQBDPOOl是传输队列名字。

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

2.3本地队列和远程队列

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

DEHNEQLOCALXLOCALQ.GSP.BOCOMFUNDACCOUNT.REQ)REPLACE

DEFINEQLOCAULOCALQ.GSP.BOCOMFUNDPRODUCT.REQ)REPLACE

DEFINEQLOCAL(LOCALQ.GSP.BOCOMFUNDRECONCILIATION.REQ)REPLACE

IL服务提供方三个远程队列

DEHNEQREMOTE(REMOTEQ.GSRBOCOMFUNDACCOUNT.RSP)+

RNAME(LOCALQ.BDPOOl.BOCOMFUNDACCOUNT.RSP)+

RQMNAME(MQGSPGWI.ALIAS)+

XMITQ(MQGSPGWl)REPLACE

DEHNEQREMOTE(REMOTEQ.GSP.BOCOMFUNDPRODUCT.RSP)+

RNAME(LOCALQ.BDPOOl.BOCOMFUNDPRODUCT.RSP)十

RQMNAME(MQGSPGW1_ALIAS)+

XMITQ(MQGSPGW1)REPLACE

DEHNEQREMOTE(REMOTEQ.GSP.BOCOMFUNDRECONCILIATION.RSP)+

RNAME(LOCALQ.BDPOO1.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(MQGSPGW1)+

REPLACE

14.显示本地队列信息

DISPLAYQLOCALf队列名)

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

DISPLAYQLOCAL(队列名)CURDEPTH

16.显示本地队列信息

DISPLAYQLOCAL(队列名)CURDEPTH

2.4死信队列相关

17.定义死信队列

DEHNEQLOCAL(MQBDPOO1.DEAD.QUEUE)+

DEFPSIST(YES)+

REPLACE

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

ALTERQMGRDEADQ(MQBDP001.DEAD.QUEUE)

19.显示死信队列

DISPLAYQLOCAL(MQBDPOO1.DEAD.QUEUE)CURDEPTH

2.6接收通道相关

20.创建接收通道

DEFINECHANNEUMQGSPGWI.MQBDP001)+

CHLTYPE(RCVR)+

REPLACE

21.显示接收通道DISPLAYCHANNEL(MQGSPGW1.MQBDP001)

2.7发送通道相关

22.创建发送通道

DEFINECHANNEL(MQBDPOOl.MQGSPGWI)CHLTYPE(SDR)+

DISCINT(O)CONNAME(,182.119.171.116(10001),)XMITQ(MQGSPGW1)+

REPLACE

注：MQBDPOOl.MQGSPGW11是发送通道名字

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

16是对方队列管理器的IP地址。

10001是对方QM的端口。

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

24.重置发送通道RESETCHL(MQBDP001.MQGSPGW1)

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

26.查看发送通道参数DISPLAYCHANNEL(MQBDP001.MQGSPGW1)

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

2.8Server端通道相关

28.修改Server端通道，以便接收Java请求

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

MCAUSER('mqm')

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

2.9启动监听服务

runmqlsr-ttcp-mMQBDFWl-p1414&

注：MQBDPOOI是队列管理器名字

1414是监听端口

2.10停止服务相关

1.停止队列管理器endmqmMQBDP001

2.查找线程并将其停止

ps-ef|greprunmqlsr

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

2.11重新启动MQ应用

i.启动队列管理器strmqmMQBDPOO1

2.进入队列管理器runmqscMQBDPOOl

a）启动发送通道STARTCHANNEL(MQBDP001.MQGSPGW1)

b）查看发送通道状态DISCHS(MQBDPOO1.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（QueueManager名字）

5.定义远程队列

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

6.定义本地队列

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

3.2在集成环境下如下建立

I.使用mqm用户，mqm/mqm

2.进入路径/usi7mqMava/bin

3.运行JMSAdmin

4.定义queueconnectionfactory

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

qmgr(MQBDPOO1)CCSID(1381)hostname(8)

SYNCPOINTALLGETS(YES)

5.定义本地队列

defineq(CBKL)queue(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)queue(REMOTEQ.GSP.BOCOMFUNDRECONCILIATION.RSP)

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

defineq(ACCOUNTR)queue(REMOTEQ.GSRBOCOMFUNDACCOUNT.RSP)

4生产环境部署（集群部分）

4.1术语说明

完整存储库：相当与每台单独部署的队列管理器，保存独立的队列信息,提供给单独的服务提

供者调用

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

请求外部服务

4.1策略说明

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

成集群共享方式;远程队处建立在部分存储库（网关）上面,设置成集群共享方式

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

享方式

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

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

4.3部署图

上图显示的是

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

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

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

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

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

MQBDP002,MQBDP003之间建立集群发送通道,集群接收通道

4.4部署脚本说明

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

〃创建MQBDP001

crtmqmMQBDP001

〃启动MQBDP001

strmqmMQBDP00I

//进入MQBDP001

runmqscMQBDP001

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

〃重新启动MQBDP001

endmqm-pMQBDP001

strmqmMQBDP001

〃启动监听端口

runmqisr-ttcp-mMQBDPOOl-p1414&

MQBDP001.txt说明:建立服务提供方三个远程队列，建立服务请求方一个本地队列，一

个远程队列

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

〃创建MQBDP002

crtmqmMQBDP002

〃启动MQBDP002

strmqmMQBDP002

〃进入MQBDP002

runmqscMQBDP002

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

〃重新启动MQBDP002

endmqm-pMQBDP002

stnnqmMQBDP002

〃启动监听端口

runmqlsr-ttcp-mMQBDP002-p1414&

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

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

〃创建MQBDP003

crtmqmMQBDP003

〃启动MQBDP003

strmqmMQBDP003

〃进入MQBDP003

runmqscMQBDP003

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

〃重新启动MQBDP003

endmqm-pMQBDP003

strmqmMQBDP003

〃启动监听端口

runmqlsr-ttcp-mMQBDP003-p1418&

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

4.5配置集群

上面的队列管理器配置完成以后,进行集群配置，配置的方法比较简单,以客户端连接建立为

例子说明

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

文件9窗口（1）帮助QP

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

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

步

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

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

列属性如下图：

测试输入队列是否会转发

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

i-■IQBDP001_ALIAS一属性

魂1常规

4集群

耳线计信息队列名IS：|MQBDP001_MJAS

I

二队列类型：|远程

-

描述：I

T放入消息：1允许2J

T

-1

缺省优先级：|0

-ZJ

持久：1力为久jd

作用域：1队列管峭二J

近程队列：

近程队列管理器：|

传给队列：[

二

2

5应用

3

|确定|取消]

队列名称队列管理器名称+ALIAS（别名）

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

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

4.6集群脚本说明

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

ALTERQMGRMQBDP002(BDPCLUSPRD);

ALTERQMGRMQBDP003(BDPCLUSPRD);

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

在MQBDP001上面执行MQSC命令：

DEFINECHANNEUTO.MQBDPOO1)CHETYPE(CLUSRCVR)TRPTYPE(TCP)

CONNAMEC8(1414)')CLUSTER(BDPCLUSPRD)

DEFINECHANNEL(TO.MQBDP003)CHETYPE(CLUSSDR)TRPTYPE(TCP)

CONNAMEC8(1418)')CLUSTER(BDPCLUSPRD)

〃在MQBDP002上面执行MQSC命令：

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

CONNAMEC35(1414)))CLUSTER(BDPCLUSPRD)

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

CONNAMEC8(1418)')CLUSTER(BDPCLUSPRD)

H在MQBDP003上面执行MQSC命令：

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

CONNAMEC8(1418),)CLUSTER(BDPCLUSPRD)

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

CONNAMEC