第一步:安装MQ
这里没什么好说的,一步一步往下走就行,要注意的是软件需求那里,要把没安装的都安装上。
第二步:配置第一个MQ队列管理器
这里需要:
1. 新建MQ队列管理器QM_TIPS_2027100000_01,用来转发报文给远程队列,并相应远程远程队列返回的报文。
2. 新建6个队列,其实测试过程中只用到了实时的队列,所以只要建立3个实时队列也就行了,但我这边后期会用到异步的报文发送,所以就多建了3个批量的队列,建立队列的时候需要配置一些参数,我已经做了截图,同时有解释,这里就不赘述了。
批量接收队列:PBC.202710000010.BATCH.OUT,此队列完成异步报文接收。
实时接收队列:PBC.202710000010.ONLINE.OUT,此队列完成实时报文发送。
批量传输队列:PBC.2600.BATCH.TRAN,此队列用来进行异步报文的数据传输。
实时传输队列:PBC.2600.ONLINE.TRAN,此队列用来进行实时报文的数据传输。
批量发送队列:PBC.EXT.BATCH.IN,此队列用来发送异步报文。
实时发送队列:PBC.EXT.ONLINE.IN,此队列用来发送实时报文。
3. 建立5个通道,和传输队列配合,这里需要对发送方通道配置上边定义的传输队列
本地批量发送方通道:202270000010.2600.B1
本地实时发送方通道:202710000010.2600.O1
本地批量接收方通道:2600.202710000010.B1
本地实时接收方通道:2600.202710000010.O1
服务器链接的通道:SVRCONN,用来相应java对MQ的链接的通道。
4. 建立,监听java连接MQ的端口,其实建立队里管理器的时候就会默认一个,这里为了命名的规范,重新配置了一个TCP:LSR.2027100000,正常操作此步骤也可以忽略。
下边一个一个建立。
新建MQ队列管理器QM_TIPS_2027100000_01
建立完成后需要把编码字符集改成819:简体中文,需要到dos下,启动队列管理启,并执行如下命令,执行完之后还需要重启队列管理器以更新字符集信息。
配置TCP,用来相应java的连接。
名称:LSR.2027100000,建议这里选择上队列管理器启动时同时启动的选项。
端口号:9009
建立发送和接收队列
实时传输队列:PBC.2600.ONLINE.TRAN
选择本地队列
这里选择非持久,传输
这里把队列深度、消息长队进行修改
这里需要配置对应的消息通道,和初始化队列(初始化队列写死:SYSTEM.CHANNEL.INITQ)
批量传输队列:PBC.2600.BATCH.TRAN
本地队列
传输、持久
长度和深度进行修改。
配置触发器通道、初始化队列
实时发送队列:PBC.EXT.ONLINE.IN
远程队列
非持久
远程队列:对应远程(下边要建立的第二个队里管理器的本地)实时接收队列
传输队列:对应本地实时传输队列
批量发送队列:PBC.EXT.BATCH.IN
远程队列
持久
远程队列:对应远程(下边要建立的第二个队里管理器的本地)异步接收队列
传输队列:对应本地异步传输队列
实时接收队列:PBC.202710000010.ONLINE.OUT
本地队列
非持久
修改长度和深度
批量接收队列:PBC.202710000010.BATCH.OUT
本地队列
持久
修改长度和深度
建立发送和接收通道
本地实时发送方通道:202710000010.2600.O1
发送方通道
连接名称:对应远程队列(下边要建立的第二个队里管理器的)java相应端口
传输队列:本地实时传输队列
传输协议:TCP
修改长度
本地批量发送方通道:202270000010.2600.B1
发送方通道
连接名称:对应远程队列(下边要建立的第二个队里管理器的)java相应端口
传输队列:本地异步传输队列
传输协议:TCP
修改长度
本地实时接收方通道:2600.202710000010.O1
接收方
修改消息长度
本地批量接收方通道:2600.202710000010.B1
接收方,注意修改消息的长度
服务器链接的通道:SVRCONN
服务器连接通道
修改长度
第三步:配置第二个MQ队列管理器
此队里管理器用来接收第一个队列管理器发送过来的报文,处理报文,并返回相应的消息。
这里需要:
1. 新建MQ队列管理器QM_TIPS_2600_01,用来接收并处理第一个队列管理器发过来的报文。
2. 新建6个队列
批量接收队列:PBC.2600.BATCH.OUT,此队列完成异步报文接收。
实时接收队列:PBC.2600.ONLINE.OUT,此队列完成实时报文发送。
批量传输队列:PBC.2027100000.BATCH.TRAN,此队列用来进行异步报文的数据传输。
实时传输队列:PBC.2027100000.ONLINE.TRAN,此队列用来进行实时报文的数据传输。
批量发送队列:PBC.EXT.BATCH.IN,此队列用来发送异步报文。
实时发送队列:PBC.EXT.ONLINE.IN,此队列用来发送实时报文。
3. 建立5个通道,和传输队列配合,这里需要对发送方通道配置上边定义的传输队列
本地批量发送方通道:2600.202710000010.B1
本地实时发送方通道:2600.202710000010.O1
本地批量接收方通道:202270000010.2600.B1
本地实时接收方通道:202710000010.2600.O1
服务器链接的通道:SVRCONN1,用来相应java对MQ的链接的通道。
4. 建立,监听java连接MQ的端口,其实建立队里管理器的时候就会默认一个,这里为了命名的规范,重新配置了一个TCP:LSR.2600,正常操作此步
骤也可以忽略。
下边一个一个建立。
新建MQ队列管理器QM_TIPS_2600_01
这里如果选择了,后边就不用再创建了。
编码字符集改成819,具体方法和上边的那个一样,修改完要重启队列管理器。
建立发送和接收队列
批量接收队列:PBC.2600.BATCH.OUT
本地队列
持久
修改消息的长度和深度
实时接收队列:PBC.2600.ONLINE.OUT
本地队列
修改消息的深度和长度
实时传输队列:PBC.2027100000.ONLINE.TRAN
本地队列
修改消息的长度和深度
同样这里需要配置对应的消息通道,和初始化队列(初始化队列写死:SYSTEM.CHANNEL.INITQ)
批量传输队列:PBC.2027100000.BATCH.TRAN
本地队列
持久
修改消息的长度和深度
同样这里需要配置对应的消息通道,和初始化队列(初始化队列写死:SYSTEM.CHANNEL.INITQ)
实时发送队列:PBC.EXT.ONLINE.IN
远程队列
非持久
远程队列:对应远程(下边要建立的第二个队里管理器的本地)实时接收队列
传输队列:对应本地实时传输队列
批量发送队列:PBC.EXT.BATCH.IN
远程队列
持久
远程队列:对应远程(下边要建立的第二个队里管理器的本地)异步接收队列
传输队列:对应本地异步传输队列
建立发送和接收通道
本地批量发送方通道:2600.202710000010.B1
发送放通道
连接名称:对应远程队列(上边建立的第一个队里管理器的)java相应端口,通过次通道返回处理后的报文
传输队列:本地异步传输队列
传输协议:TCP
本地实时发送方通道:2600.202710000010.O1
发送放通道
连接名称:对应远程队列(上边建立的第一个队里管理器的)java相应端口,通过次通道返回处理后的报文
传输队列:本地同步传输队列
传输协议:TCP
修改消息长度
本地批量接收方通道:202270000010.2600.B1
接收方
本地实时接收方通道:202710000010.2600.O1
服务器链接的通道:SVRCONN1
配置TCP,用来相应java的连接。
TCP侦听器
断口:1415
Ok,大概就这么多,其中*.BATCH的队列和*.B1的通道是用来进行异步报文发送的,先可以不用建立